1

我有这个代码可以连接到 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())
4

1 回答 1

1

好吧，首先你不需要将烛台保存到数据库，你可以从网络服务中获取蜡烛数据，你只需要告诉你从什么时候到什么时候，网络服务就会给你那个时期的烛台。要获取这些数据，您不需要 Web 套接字，您可以使用简单的 REST API 获取它。这是端点：/api/v1/market/candles

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

于 2021-10-18T12:57:12.877 回答