diff --git a/market_replay.py b/market_replay.py index e69de29..27018f1 100644 --- a/market_replay.py +++ b/market_replay.py @@ -0,0 +1,29 @@ +import asyncio +import websockets +import json + +# WebSocket URI +# URI: ws://192.168.34.9:8765 +# 请求参数 +# 平台 (platform): 指定交易平台的名称,gate_spot/gate_swap_u/binance_spot/binance_swap_u/bybit_spot/bybit_swap_u/okx_spot/okx_swap_u + +# 基础货币 (base): 交易对中的基础货币,如 btc。 +# 结算货币 (settle): 交易对中的结算货币,如 usdt。 +# 开始时间 (start_data): 数据请求的开始时间(格式应为 YYYY-MM-DD-HH,但注意您代码中写的是 start_data 可能是 start_date 的笔误)。 +# 结束时间 (end_data): 数据请求的结束时间(同上,格式应为 YYYY-MM-DD-HH,且可能应为 end_date)。 + + +async def connect_to_server(): + uri = "ws://192.168.34.9:8765" + async with websockets.connect(uri) as websocket: + msg = {'platform': 'gate_spot', 'base': 'btc', "settle": "usdt", "start_data": "2024-08-13-18", + "end_data": "2024-08-13-18"} + + await websocket.send(f"{json.dumps(msg)}") + + while True: + response = await websocket.recv() + print(json.loads(response)) + +if __name__ == "__main__": + asyncio.run(connect_to_server())