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