3

我有一种情况,我开始使用默认主题标签进行 tweepy 流式传输,而不是程序接收队列并更改主题标签,但我的问题是如何将此新主题标签应用于已经运行的 tweepy 流式传输?

为了更清楚,将举一个例子:

    hashtag = 'number_1'

    auth = t_auth()
    self.stream = tweepy.streaming.Stream(auth,CustomStreamListener())
    self.stream.filter(follow=None, track=[hashtag])   

好的,上面的代码会监听 hashtag 'number_1',现在假设我收到了一个带有不同 hashtag 的队列:

    hashtag = 'Different_hashtag'

那么如何让我self.stream.filter(follow=None, track=[hashtag]开始收听新的主题标签呢?

4

1 回答 1

2

正如@alecxe 在评论中所说,您可以通过调用stream.disconnect()或返回将流与回调方法之一断开连接False

stream.filter另一种选择是使用调用async=True。这将异步监听推文,当您收到不同的主题标签时,允许您从主代码调用stream.disconnect()和调用。stream.filter()

于 2014-03-13T19:02:23.190 回答