def init_app(self, key):
self.key = key
self.listener = StreamListener()
self.listener.on_data = self.on_messages_received
self.listener.on_error = self.on_error
python类StreamListener()的实例源码
def on_data(self, data):
global count
# Loop keeps on fetching data and incrementing count until the time limit is reached.
while ((time.time() - self.time) < self.limit):
try:
count+=1
return True
except BaseException as e:
time.sleep(5)
pass
return False
# StreamListener Class Ends Here.
# REST API that fetches data from the past days till today.
# As per the API documentation twitter allows the user to access Tweets that are no more than 7 days old.