websocketから収集したデータを、pandasのDataFrameに取り込みたいと思っています。
loop=run_until_complete()の後にpandasに取り込む処理を加えるべきかと考えたのですが、loopの後に書いた処理は実行されません。
そこで、二点ほど伺いたいのですが
- どのタイミングでpandasにデータを取り込んだら良いでしょうか。(pandasのデータは追加ではなく、更新したいと思っています。)
- どの様な関数を使ったら良いでしょうか。pandasは勉強を始めたばかりで全く検討が付かず、アドバイスを頂けると嬉しいです。
よろしくお願いします。
python3
1async def check_price(): 2 3 async def deal_msg(msg): 4 if msg['topic'] == '/spotMarket/level2Depth5:CHSB-ETH': 5 print(f'CHSB-ETH bestask/bestbid:{msg["data"]}') 6 7 client = WsToken(is_sandbox=False) 8 ws_client = await KucoinWsClient.create(None, client, deal_msg, private=False) 9 10 await ws_client.subscribe('/spotMarket/level2Depth5:CHSB-ETH') 11 12 13 while True: 14 await asyncio.sleep(60, loop=loop) 15 16if __name__ == "__main__": 17 loop = asyncio.get_event_loop() 18 loop.run_until_complete(check_price())
回答1件
あなたの回答
tips
プレビュー
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。