From 0c41b72602266d295e6b60719f4b1fc4e5ad379f Mon Sep 17 00:00:00 2001 From: andrewso <9V5f1FkzI2LD> Date: Sat, 10 Oct 2020 22:49:26 +0100 Subject: [PATCH] [10.10.20] Testing --- src/tweets/collector.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/tweets/collector.py b/src/tweets/collector.py index bf1f374..def7449 100644 --- a/src/tweets/collector.py +++ b/src/tweets/collector.py @@ -82,8 +82,6 @@ class Listener(StreamListener): def on_data(self, data): - log("Received Tweet...", 'INFO') - if (time() - self.start_time) < self.limit: data = json.loads(data) @@ -108,6 +106,8 @@ def processTweet(): processStack = dumpStack dumpStack.clear() + log("Processing Tweets Stack...", 'INFO') + if len(processStack) != 0: for tweet in processStack: removedLines = fixLines(tweet["tweet"]) @@ -167,6 +167,8 @@ def createHourJob(): processTweet() + log("Extracting sentiment scores...", 'INFO') + if len(hourStack) != 0: for item in hourStack: ovPos = ovPos + item['pos']