TwitterClient.py 文件源码

def _setup_stream(self):
        logger.info("Starting twitter steam")
        if not self.api:
            raise RuntimeError("Client not authenticated!")
        s_listener = HashtagStreamListener(self)
        stream = tweepy.Stream(auth=self.api.auth, listener=s_listener)
        stream.filter(track=self.tags, async=True)