andyjk15/tweet-collector
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[10.10.20] Testing

Browse Source
This commit is contained in:
andrewso 2020-10-10 22:49:26 +01:00
parent 044fd62dcf
commit 0c41b72602
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/tweets/collector.py
View File

@ -82,8 +82,6 @@ class Listener(StreamListener):
def on_data(self, data): def on_data(self, data):
log("Received Tweet...", 'INFO')
if (time() - self.start_time) < self.limit: if (time() - self.start_time) < self.limit:
data = json.loads(data) data = json.loads(data)
@ -108,6 +106,8 @@ def processTweet():
processStack = dumpStack processStack = dumpStack
dumpStack.clear() dumpStack.clear()
log("Processing Tweets Stack...", 'INFO')
if len(processStack) != 0: if len(processStack) != 0:
for tweet in processStack: for tweet in processStack:
removedLines = fixLines(tweet["tweet"]) removedLines = fixLines(tweet["tweet"])
@ -167,6 +167,8 @@ def createHourJob():
processTweet() processTweet()
log("Extracting sentiment scores...", 'INFO')
if len(hourStack) != 0: if len(hourStack) != 0:
for item in hourStack: for item in hourStack:
ovPos = ovPos + item['pos'] ovPos = ovPos + item['pos']