我有一种情况,我开始使用默认的hashtag的tweet流,然后程序接收队列并更改hashtag,但我的问题是如何将这个新的hashtag应用于已经运行的tweet流?
为了更清楚地说明,我将给出一个例子:
hashtag = 'number_1'
auth = t_auth()
self.stream = tweepy.streaming.Stream(auth,CustomStreamListener())
self.stream.filter(follow=None, track=[hashtag])
好的,上面的代码将监听标签'number_1'
,现在假设我收到了一个具有不同标签的队列:
hashtag = 'Different_hashtag'
那么如何让我的self.stream.filter(follow=None, track=[hashtag]
开始侦听新的标签呢?
正如@alecxe在评论中所述,您可以通过调用stream.disconnect()
或返回False
来断开流与回调方法之一的连接
另一种选择是用async=True
调用stream.filter
。这将异步侦听Tweets,允许您在收到不同的标签时从主代码调用stream.disconnect()
和stream.filter()
。