小编Сер*_*нко的帖子

python - ThreadedWebsocketManager - 从未检索到任务异常

我正在尝试运行在 jupyter 笔记本上找到的教程中的以下代码:

from time import sleep

from binance import ThreadedWebsocketManager

btc_price = {'error':False}

def btc_trade_history(msg):

    if (msg['e'] != 'error'):

        print(msg['c'])

        btc_price['last'] = msg['c']

        btc_price['bid'] = msg['b']

        btc_price['last'] = msg['a']

        btc_price['error'] = False

    else:

        btc_price['error'] = True

bsm = ThreadedWebsocketManager()

bsm.start()

bsm.start_symbol_ticker_socket(callback=btc_trade_history, symbol='BTCUSDT')
Run Code Online (Sandbox Code Playgroud)

这是教程本身的链接:https ://algotrading101.com/learn/binance-python-api-guide/

我想,自从编写了教程以来,binance API 中发生了一些变化,所以我收到以下错误:

取消 read_loop 未来从未检索到任务异常:<任务完成名称='Task-14'coro=<ThreadedApiManager.start_listener()完成,在C:\Users\myusername\Anaconda3\lib\site-packages\binance\threaded_stream中定义。 py:42> 异常=RuntimeError("任务 <任务挂起名称='Task-20' coro=<Queue.get() 在 C:\Users\myusername\Anaconda3\lib\asyncio\queues.py:163 运行> cb =[_release_waiter(()]>)() at C:\Users\myusername\Anaconda3\lib\asyncio\tasks.py:429]> 让 Future 附加到不同的循环")>

请解释一下出了什么问题以及如何解决?

python python-asyncio binance-api-client

5
推荐指数
1
解决办法
2244
查看次数