我有这个代码可以连接到 KuCoin 网络套接字并接收烛台数据。我的问题是:如何将消息保存到变量中(可能在另一个脚本中)?我想以后使用这些数据并将其保存到数据库中,然后将其用于计算和绘图。
import asyncio
from kucoin.client import WsToken
from kucoin.ws_client import KucoinWsClient
async def kline_msg(msg):
if msg["topic"] == "/market/candles:SLP-USDT_30min":
print(msg["data"])
async def wsocket():
client = WsToken()
ws_client = await KucoinWsClient.create(None, client, kline_msg, private=False)
await ws_client.subscribe("/market/candles:SLP-USDT_30min")
while True:
print("Sleep until message")
await asyncio.sleep(60)
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(wsocket())