我正在努力找出如何正确关闭异步的tweepy流。
tweepy流模块可以在这里找到。
我是这样启动流的:
stream = Stream(auth, listener)
stream.filter(track=['keyword'], async=True)
关闭应用程序时,我尝试以简单的方式关闭流:
stream.disconnect()
这种方法似乎按预期工作,但它似乎存在一个问题:流线程仍处于循环的中间(等待/处理推文),并且直到下一次循环之前不会被终止,因此即使在应用程序关闭后,当流接收到推文时,它仍然尝试调用侦听器对象(可以通过对侦听器对象使用简单的打印语法来查看)。我不确定这是否是一件坏事,或者是否可以简单地忽略它。
我的2个问题:
- 这是关闭流的最佳方法还是我应该采取不同的方法?
- 异步线程不应该创建为守护线程吗?