stream使用tweepy asyncstream异步推文

daolsyd0  于 2021-08-20  发布在  Java
关注(0)|答案(0)|浏览(265)

我正在尝试运行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文件中运行它时,它不工作,并返回错误“流中发生了http:420错误”。我也在jupiter中运行代码,只是没有使用async io.run(main()),而是编写await main(),它也会返回这个错误,但是流可以工作并返回响应。
为什么它在jupiter中工作,但在.py文件中不工作。如何解决这个问题?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题