Twitter sentiment analysis using Apache Kafka, Apache Spark structured streaming and dashboard monitoring page.
Table of Contents
This project is for Distributed enabling platforms course 21/22 A.Y at unipi given by Prof. Patrizio Dazzi. I implemeted a tweet sentiment analysis using distributed systems. Technologies used will be listed below. In this project, you will find three separate modules (applications).
Kafka-producer: This module reads tweets from twitter API and publish tweets to kafka topic continously.Kafka-consumer: This is a spark application which uses spark structured streaming. It reads tweets from kafka server and make a prediction for each tweets and aggrigate the total tweet predicted for each sentiments(posetive, negative or neutral) andPOSTresult to the web-serverweb-server: web-server is a flask web admin dashboard where all the total amount of tweets predicted and additional information are displayed
I have utilized the following libraries for the development of this project.
Loading ...
Loading . . .
Contributions are what make the open source community such an amazing place to learn, inspire, and create. Any contributions you make are greatly appreciated.
If you have a suggestion that would make this better, please fork the repo and create a pull request. You can also simply open an issue with the tag "enhancement". Don't forget to give the project a star! Thanks again!
- Fork the Project
- Create your Feature Branch (
git checkout -b feature/AmazingFeature) - Commit your Changes (
git commit -m 'Add some AmazingFeature') - Push to the Branch (
git push origin feature/AmazingFeature) - Open a Pull Request
Distributed under the MIT License. See LICENSE.txt for more information.
Website - joetelila.com
Project Link: https://github.com/joetelila/Sentiment-analysis-using-kafka-spark
