首页 > 解决方案 > 有一种方法来停止 tweepy 流的最佳方法是什么?

问题描述

每当我创建一个状态流对象时,我都会从 twitter API 开始流式传输信息。如果我想做一种方法来停止流,那么这样做的方法是什么?我需要一些帮助的方法是 stopStream() ,它会在调用该方法时停止 twitter 流。

from tweepy.streaming import StreamListener
    from tweepy import OAuthHandler
    from tweepy import Stream
    import time
    import json
    import csv
    import sys
    import Tweet
    import DatabaseInteractor 
    import twitter_credentials




class StatusStream(StreamListener):

    def __init__(self):

      self.continueStream = True
      super(StatusStream, self).__init__()


      def on_status(self, status):

          print(status.text)
          if(self.continueStream ==False):
            return False 





    def on_error(self, status):
        print(status)
        return False

    @staticmethod
    def stopStream():
      self.continueStream = False


auth = OAuthHandler(twitter_credentials.API_KEY,twitter_credentials.API_SECRET_KEY)
auth.set_access_token(twitter_credentials.ACCESS_TOKEN,twitter_credentials.ACCESS_TOKEN_SECRET)
twitterStream = Stream(auth=auth, listener=StatusStream(),tweet_mode='extended')
twitterStream.filter(track=["plumber","visa","bathtub"])

标签: pythonobjecttwittertweepy

解决方案


推荐阅读