Discussion on "Sentiment analysis on streaming Twitter data using Kafka, Spark Structured Streaming & Python (Part 2)"

Lorena Gongang · 2022-03-14T17:13:11.631Z

A friend told me one day that, a problem we face at x time is an assembly of small problems not resolved previously and that we aren't aware of. I decided weeks ago to learn how to do sentiment analysis on streaming Twitter Data, but to do the entire...

Hello Lorena,

There is a change in twitter API recently ,it is upgraded to new version V2 . Because of that i was unable to run producer.py. where we have to change the code accordingly. I was unable to change please help me with this. you can mail me at sarissa789@gmail.com

Hello Lorena, how can I change your code in pyspark to get full_text from Twitter? Thank you.

Hello, I have a problem "TypeError: write_row_in_mongo() takes 1 positional argument but 2 were given" when I run your code

Hello Minh Nguyen, I know where the problem came from : Just modify write_row_in_mongo and add another parameter, epoch_id. I just changed the article, and you won't get the error after it.

OMG Lorena. This article is pure awesomeness.

I read about sentiment analysis not so long ago and I was sure I will try some tools after I will have a bigger digital footprint, but I have not considered implementing my own solution. Up till now. 😊

Thank you Miki Szeles

Search Hashnode

Sentiment analysis on streaming Twitter data using Kafka, Spark Structured Streaming & Python (Part 2)

Responses(4)