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:12:44 +01:00
parent 886470d17e
commit 2a06d431b2
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/tweets/collector.py
View File

@ -82,6 +82,8 @@ class Listener(StreamListener):
def on_data(self, data): def on_data(self, data):
log("Received Tweet...")
if (time() - self.start_time) < self.limit: if (time() - self.start_time) < self.limit:
data = json.loads(data) data = json.loads(data)
@ -154,6 +156,7 @@ def timeFunction():
return timeF return timeF
def createHourJob(): def createHourJob():
log("Creating hour job...", 'INFO')
schedule.clear("sendToArtemis") schedule.clear("sendToArtemis")
ovPos, ovNeu, ovNeg, ovCompound = 0, 0, 0, 0 ovPos, ovNeu, ovNeg, ovCompound = 0, 0, 0, 0
@ -181,6 +184,8 @@ def createHourJob():
schedule.every().hour.at(timeF).do(createHourJob).tag("sendToArtemis") schedule.every().hour.at(timeF).do(createHourJob).tag("sendToArtemis")
log("Collection will run again at {} every hour".format(time), 'INFO')
def collectorMain(hashtag): def collectorMain(hashtag):
log("Starting Tweet Collector", 'INFO') log("Starting Tweet Collector", 'INFO')