Python tweepy.streaming 模块，StreamListener() 实例源码

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

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.