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 回答