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

【问题标题】：Save Received Candle Stick Message from KuCoin Websocket to variable and then to database从 KuCoin Websocket 接收到的蜡烛棒消息保存到变量，然后保存到数据库
【发布时间】：2021-10-15 20:13:44
【问题描述】：

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

【问题讨论】：

标签： python websocket async-await python-asyncio kucoin

【解决方案1】：

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

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

【讨论】：