批量开/关跟单交易（WS）

{
  "id": 1761291309, // 调用id,响应结果返回相同ID
  "method": "batchToggleFollowOrder", // 调用批量开/关跟单交易任务方法
  "params": {
    "ids": [ 
      "m8zl720z0043pp",
      "m81lt5qn043csv",
      "m7cpk8n00043l1" 
    ], // 跟单任务id列表
    "enabled": true, // "true"表示启用跟单任务
    "closePnlOrder": "false" // 是否同时关闭跟单任务创建的所有止盈止损任务，默认false，表示不关闭（当"enabled"为false时有效）
  }
}

{
    "method": "rpcResponse", // rpc响应
    "id": 1761291309, // 调用id
    "result": {
        "err": false // 是否发生错误
    }
}

const WebSocket = require('ws')

function main() {
  const ws = new WebSocket('wss://api-data-v1.dbotx.com/trade/ws/', {
    headers: {
      'x-api-key': 'YOUR_API_KEY',
    },
  })

  ws.on('open', () => {
    ws.send(
      JSON.stringify({
        "id": 1761291309,
        "method": "batchToggleFollowOrder",
        "params": {
          "ids": [
            "m8zl720z0043pp",
            "m81lt5qn043csv",
            "m7cpk8n00043l1"
          ],
          "enabled": true,
          "closePnlOrder": "false"
        }
      })
    )

    setInterval(() => {
      ws.ping()
    }, 30000)
  })

  ws.on('message', res => {
    console.log('res:', res.toString('utf-8'));
  })
}

main()

import asyncio
import websockets
import json

async def main():
    uri = "wss://api-data-v1.dbotx.com/trade/ws/"
    headers = {"x-api-key": "YOUR_API_KEY"}
    msg = {
        "id": 1761291309,
        "method": "batchToggleFollowOrder",
        "params": {
            "ids": [
                "m8zl720z0043pp",
                "m81lt5qn043csv",
                "m7cpk8n00043l1"
            ],
            "enabled": true,
            "closePnlOrder": "false"
        }
    }

    async with websockets.connect(uri, additional_headers=headers) as ws:
        await ws.send(json.dumps(msg))

        async def keep_alive():
            while True:
                await ws.ping()
                await asyncio.sleep(30)

        async def listen_for_messages():
            async for message in ws:
                print(message)

        await asyncio.gather(keep_alive(), listen_for_messages())

if __name__ == "__main__":
    asyncio.run(main())