主页 / 问题 / 1589254
Accepted
Кирилл Маликов
Asked:2024-08-02 17:21:10 +0000 UTC2024-08-02 17:21:10 +0000 UTC

python 中的 websocket

  • 772

我写了一个连续接收价格的网络套接字。

async def TickersChannel_ws():

    """ Websoket подписка на цены"""
    url = "wss://ws.okx.com:8443/ws/v5/public"
    async with websockets.connect(url) as ws:

        subs = {
            "op": "subscribe",
            "args": [
                dict(channel="mark-price", instId="NOT-USDT-SWAP")
            ]
        }

        await ws.send(json.dumps(subs))

        async for msg in ws:
            msg = json.loads(msg)
            if "event" not in msg:
                return msg.get("data")[0].get("markPx")

现在，我完全不清楚如何将 asyncio.run(TickersChannel_ws()) 订阅的价格与连续流中的给定数字进行比较。而True则不是一个选项，因为事实证明它不断地重新连接到服务器，这就失去了套接字的意义。

我知道我需要有条件地将其写入变量然后进行比较，但我也不能这样做，因为套接字在不断移动。

python

1 个回答

  1. Best Answer
    import json
import asyncio
import websockets


async def TickersChannel_ws():
    url = "wss://ws.okx.com:8443/ws/v5/public"
    async with websockets.connect(url) as ws:

        subs = {
            "op": "subscribe",
            "args": [
                dict(channel="mark-price", instId="NOT-USDT-SWAP")
            ]
        }

        await ws.send(json.dumps(subs))

        async for msg in ws:
            msg = json.loads(msg)
            if "event" not in msg:
                yield msg.get("data")[0].get("markPx")


async def main():
    async for ticker in TickersChannel_ws():
        print(ticker)


asyncio.run(main())
    • 2

相关问题