|
@ -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()) |