Real-Time Streaming Project with Smartphone Sensor Data , Kafka , Rest API & Python

preview_player
Показать описание
If you are looking for free real-time or streaming data sources , then you are in right place!
This video explains how to stream data from sensors on your phones using an app, Sensor Logger & ingest them in Kafka Cluster for Processing.

Install Sensor Logger from the below link:

Prerequisite:
-------------------------
Creating a Serverless Apache Kafka(MSK) publisher using AWS Lambda

Code:
--------------

Learn Apache Kafka form scratch

Check this playlist for more Data Engineering related videos:

Snowflake Complete Course from scratch with End-to-End Project with in-depth explanation--

🙏🙏🙏🙏🙏🙏🙏🙏
YOU JUST NEED TO DO
3 THINGS to support my channel
LIKE
SHARE
&
SUBSCRIBE
TO MY YOUTUBE CHANNEL
Рекомендации по теме
Комментарии
Автор

Amazing tutorial & demonstration. The key issue with other tutorials is that they focus telling the theory part or at max with dummy data. You have overcome that with this tutorial so that we can see real time data generation and consumption. Thank you very much for all your efforts that you put in !!

gauravsrivastava
Автор

Very informative. Can you make a next video on continuenig this video as how to:

1) Process
2) Query
3) Visualize

This data that we captured. I think you can make a series on it, it is my small suggestion you can add it more.

mr.mechanic
Автор

Thanks for the great lecture!!!

following your steps but using MSK, I have observed multiple lambda timeout cases during streaming, which means some data failed to arrive to kafka. Added some logs for troubleshooting the lambda function, it shows "data send success" but not receive status code 200 from kafka. In addition, it shows that 'Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms'. Do we need to add some code to close producer in lambda function before it is timed out? otherwise there may be some dangling connections still keep open and hold on kafka resources. Thanks!

chenguo
Автор

Awesome bro, learned a lot, thank you 💯

சிவபாலன்வெங்கடேசன்
Автор

Good content!!
But when i tried i am getting below error in the logs:
[ERROR] Runtime.ImportModuleError: Unable to import module 'lambda_function': No module named 'kafka'
Traceback (most recent call last):

i have added the layer as provided by you!!
could you please help here.

girishdepu
Автор

what are the important topics required for aws data engineering?

avinash
Автор

can u make a video about streaming magentic sensor from android

geomarinesolutions
Автор

Please provide big data engineering end to end project with involving all components of big data with explaination, data and code

BhakthiYoutube
Автор

I tried for 2 times and follow exactly same step by step but its not showing the logs into the kafka consumer. What can be the reason???

abrarpinjari