diff --git a/src/tweets/collector.py b/src/tweets/collector.py index df5bdbf..b720226 100644 --- a/src/tweets/collector.py +++ b/src/tweets/collector.py @@ -103,13 +103,10 @@ class Listener(StreamListener): def processTweet(): - log("Dump Stack {}".format(len(dumpStack)), 'INFO') - processStack = dumpStack.copy() dumpStack.clear() log("Processing Tweets Stack...", 'INFO') - log(len(processStack), 'INFO') if len(processStack) != 0: for tweet in processStack: @@ -172,10 +169,7 @@ def createHourJob(): log("Extracting sentiment scores...", 'INFO') - log(len(hourStack), 'INFO') - if len(hourStack) != 0: - log("Boop", 'INFO') for item in hourStack: ovPos = ovPos + item['pos'] ovNeu = ovNeu + item['neu'] @@ -188,7 +182,8 @@ def createHourJob(): neg = round(ovNeg/len(hourStack), 3) compound = round(ovCompound/len(hourStack), 3) - print(pos, neu, neg, compound) + if type == "bitcoin": + type = 'btc_usd' hourStack.clear() @@ -206,7 +201,6 @@ def collectorMain(hashtag): for i in range(len(hashtag)): Thread(target=collector, args=[hashtag[i]]).start() - sleep(5) createHourJob() while True: