This project demonstrates real-time streaming using Kafka. It simulates fake tweets and stock prices, performs sentiment analysis, and plots stock data live on a dashboard.
producer.py
: Produces fake tweets and stock pricesconsumer_tweet_sentiment.py
: Consumes tweets and analyzes sentimentdashboard_stock_plot.py
: Plots live stock prices using Dash
- Install dependencies:
pip install -r requirements.txt
python -m textblob.download_corpora
-
Start Kafka locally on
localhost:9092
-
Run each component in separate terminals:
python producer.py
python consumer_tweet_sentiment.py
python dashboard_stock_plot.py