将从KuCoin Websocket收到的蜡烛棒消息保存到变量，然后保存到数据库

Question

我有这个代码连接到KuCoin web套接字并接收蜡烛棒数据。 我的问题是：如何将消息保存到变量（可能在另一个脚本中）？ 我希望以后使用这些数据并将其保存到数据库中，然后将其用于计算和绘图

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())

Answer 1

首先，你们不需要将蜡烛棒保存到数据库中，你们可以从web服务中获取蜡烛数据，你们只需要知道从何时到何时，web服务就会给你们那个时期的蜡烛棒。 要获得这些数据，您不需要web套接字，您可以通过一个简单的REST API获得它。这是端点：/api/v1/market/cands

如何将此数据保存到变量？ 由于api调用的结果是JSON格式的，所以可以轻松地将其转换为模型类