Async def get_currency_rate_binance(pair: str = 'btcusdt'): binance_ws

Question

Async def get_currency_rate_binance(pair: str = 'btcusdt'): binance_ws

= f'wss://stream.binance.com:9443/stream?streams={pair}@miniTicker'
async with websockets.connect(binance_ws) as client:
while True:
data = json.loads(await client.recv())['data']
event_time = time.localtime(data['E'] // 1000)
yield {'pair': pair, 'event_time': event_time, 'price': data['c']}
@router.get('/courses')
async def get_currency_courses(pairs: str, exchanger: str = 'binance'):
try:
tasks = [get_currency_rate_binance(pair) for pair in pairs]
result = await asyncio.gather(*tasks)
return result
except Exception as e:
print(e)

#backend #programming #python #russian

0

11.11.2023

2 ответов

9 просмотров

yegor Автор вопроса

Мисчаил
Попробуй писать await перед вызовом get_currency_r...

я вроде как фиксанул, теперь код выглядит вот так: async def get_currency_rate_binance(pair: str = 'btcusdt'): binance_ws = "wss://stream.binance.com:9443/stream?streams=ltcbtc@aggTrade/ethbtc@aggTrade" async with websockets.connect(binance_ws) as client: data = json.loads(await client.recv())['data'] print(data) return {'pair': data['s'], 'price': data['c']}

0

5 месяцев назад

Мисчаил · Accepted Answer

Мисчаил

Попробуй писать await перед вызовом get_currency_rate_binance

0

5 месяцев назад

170 похожих чатов

Async def get_currency_rate_binance(pair: str = 'btcusdt'): binance_ws

2 ответов

Похожие вопросы