使用 Tweepy AsyncStream 异步传输推文

如何解决使用 Tweepy AsyncStream 异步传输推文

我正在尝试运行 AsyncStream Tweepy，但遇到了问题

from __future__ import absolute_import,print_function
from tweepy.streaming import Stream
from tweepy import OAuthHandler
from tweepy import Stream
from pprint import pprint
from tweepy.asynchronous import AsyncStream 
import asyncio

async def main():

    stream = StdOutListener(CONSUMER_KEY,CONSUMER_SECRET,ACCESS_TOKEN,ACCESS_TOKEN_SECRET)
    await stream.filter(follow=['1082189695252074496'])
    await asyncio.sleep(1.5)


class StdOutListener(AsyncStream):
    
    
    async def on_status(self,status):
        print(status_json)

    async def on_error(self,status):
        print(status)
            
if __name__ == '__main__':
    asyncio.run(main())

当我在 .py 文件中运行它时，它不起作用并返回错误“An HTTP: 420 error occurred in the stream”。我也在 Jupyter Notebook 中运行代码，只是我写了 await main() 而不是 async io.run(main())，它也返回此错误，但流工作并返回响应。

为什么它在 Jupyter Notebook 中有效，而在 .py 文件中无效。如何解决这个问题？