aboutsummaryrefslogtreecommitdiff
path: root/SentimentAnalyser.py
diff options
context:
space:
mode:
authorjmreddy2106 <[email protected]>2021-12-25 15:07:36 -0500
committerjmreddy2106 <[email protected]>2021-12-25 15:07:36 -0500
commitbea259da7cf4219c5b81b081a5d45fb6664eef0d (patch)
treea2e6144c520c80a14529728a0b4bda95aac35ba8 /SentimentAnalyser.py
parentfea7e43ccb24734a5dee49460bd47bd9460b3f73 (diff)
downloadKafkaPySpark-bea259da7cf4219c5b81b081a5d45fb6664eef0d.tar.xz
KafkaPySpark-bea259da7cf4219c5b81b081a5d45fb6664eef0d.zip
Added sentiment analyser
Diffstat (limited to 'SentimentAnalyser.py')
-rw-r--r--SentimentAnalyser.py26
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