diff options
| author | jmreddy2106 <[email protected]> | 2021-12-25 15:07:36 -0500 |
|---|---|---|
| committer | jmreddy2106 <[email protected]> | 2021-12-25 15:07:36 -0500 |
| commit | bea259da7cf4219c5b81b081a5d45fb6664eef0d (patch) | |
| tree | a2e6144c520c80a14529728a0b4bda95aac35ba8 | |
| parent | fea7e43ccb24734a5dee49460bd47bd9460b3f73 (diff) | |
| download | KafkaPySpark-bea259da7cf4219c5b81b081a5d45fb6664eef0d.tar.xz KafkaPySpark-bea259da7cf4219c5b81b081a5d45fb6664eef0d.zip | |
Added sentiment analyser
| -rw-r--r-- | SentimentAnalyser.py | 26 |
1 files changed, 26 insertions, 0 deletions
diff --git a/SentimentAnalyser.py b/SentimentAnalyser.py new file mode 100644 index 0000000..ba415dc --- /dev/null +++ b/SentimentAnalyser.py @@ -0,0 +1,26 @@ +from nltk.sentiment.vader import SentimentIntensityAnalyzer +from cassandra.cluster import Cluster +import re + + +compound = [] +pos = [] +neu = [] +neg = [] + +def sentence_score(rs): + review_score = SentimentIntensityAnalyzer() + compound.append(review_score.polarity_scores(rs)['compound']) + neg.append(review_score.polarity_scores(rs)['neg']) + neu.append(review_score.polarity_scores(rs)['neu']) + pos.append(review_score.polarity_scores(rs)['pos']) + + +cluster = Cluster() +session = cluster.connect('twitter') +rows = session.execute('SELECT tweet FROM twitterdata') +for tweet in rows: + try: + sentence_score(tweet) + except re.error: + print(tweet)
\ No newline at end of file |
