twitter.py 文件源码

def start_streaming(self, user_id, callback):
        """
        :param user_id: String
        :param callback: method that takes Tweet text (String) as a parameter. 
        Starts streaming tweets and returning data to the callback.
        """

        self.twitter_listener = TwitterListener(user_id, callback=callback)
        twitter_stream = Stream(self._auth, self.twitter_listener)

        print("Starting Twitter stream for account: %s" % user_id)
        twitter_stream.filter(follow=[user_id])

        # If we got here because of an API error, raise it.
        if self.twitter_listener and self.twitter_listener.get_error_status():
            raise Exception("Twitter API error: %s" %
                            self.twitter_listener.get_error_status())