From 75a80698fb323ecde74266ecfc1705f9c1a66bc8 Mon Sep 17 00:00:00 2001 From: "yhydev@outlook.com" Date: Sun, 15 Jun 2025 02:01:20 +0000 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- comsumer/order.py | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) diff --git a/comsumer/order.py b/comsumer/order.py index 572e756..591d6f1 100644 --- a/comsumer/order.py +++ b/comsumer/order.py @@ -7,8 +7,8 @@ async def start(): pass -async def start_bn_future_order_consumer(account_id, api_key, api_secret): - client = await AsyncClient.create(api_key, api_secret, testnet=True,https_proxy="http://127.0.0.1:7890") +async def start_bn_future_order_consumer(account_id, api_key, api_secret, testnet=False): + client = await AsyncClient.create(api_key, api_secret, testnet=testnet) bm = BinanceSocketManager(client, max_queue_size=100000) ws = bm.futures_user_socket() @@ -22,12 +22,4 @@ async def start_bn_future_order_consumer(account_id, api_key, api_secret): async def send_msg(msg): logger.info(f"send to kafka: {msg}") await kafka_service.send_to_kafka("binance_future_order_update", json.dumps(msg),key="DEFAULT",send_now=True) - logger.info(f"send to kafka success: {msg}") - - -if __name__ == "__main__": - import asyncio - api_key = "a47059edcf978d1e1f616634c2cce1b3ae22e741f745a5152b56c039e8bfa7a4" - secret = "6f69f45a686cfc7dae71c10ebd3419517582b0f4ce0253e6c21d853e8637c112" - asyncio.run(start_bn_future_order_consumer(1, api_key, secret)) - \ No newline at end of file + logger.info(f"send to kafka success: {msg}") \ No newline at end of file