import asyncio
from binance import AsyncClient, BinanceSocketManager
async def main():
client = await AsyncClient.create()
bm = BinanceSocketManager(client)
# start any sockets here, i.e a trade socket
ts = bm.trade_socket('BNBBTC')
# then start receiving messages
async with ts as tscm:
while True:
res = await tscm.recv()
print(res)
await client.close_connection()
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
Witam, mniej więcej taka funkcja musi się znaleźć w moim programie problem w tym że nie wiem jak zwrócić z tego wartoś zmiennej res. Chcę to uruchomić i w momencie kiedy świece na giełdzie się zamknie to też zamknąć połączenie i przejść do przetwarzania tego w dalszej części programu. Zmienne globalne mnie nie interesują. Z góry dzięki. Ze zwykłym websocketem też mam problem więc jak by ktoś napisał jakąś uniwersalną odpowiedź było by pięknie