From 21d753614ea7bbe936b8560cbf466c4e438821b2 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 23 九月 2022 16:08:16 +0800
Subject: [PATCH] l2数据计算优化
---
l2_code_operate.py | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/l2_code_operate.py b/l2_code_operate.py
index 282cdd8..e5d7d9c 100644
--- a/l2_code_operate.py
+++ b/l2_code_operate.py
@@ -74,6 +74,12 @@
data = json.loads(data)
logger_code_operate.info("璇诲彇鎿嶄綔闃熷垪锛歿}", data)
type, code = data["type"], data["code"]
+ create_time = data.get("create_time")
+ if create_time is not None:
+ # 璁剧疆10s瓒呮椂鏃堕棿
+ if round(time.time() * 1000) - create_time > 20 * 1000:
+ logger_code_operate.debug("璇诲彇鎿嶄綔瓒呮椂锛歿}", data)
+ continue
if type == 0:
# 鏄惁鍦ㄥ浐瀹氬簱
@@ -131,7 +137,8 @@
def add_operate(self, type, code, msg="", client=None, pos=None):
redis = self.redis_manager_.getRedis()
redis.rpush("code_operate_queue",
- json.dumps({"type": type, "msg": msg, "code": code, "client": client, "pos": pos}))
+ json.dumps({"type": type, "msg": msg, "code": code, "client": client, "pos": pos,
+ "create_time": round(time.time() * 1000)}))
def repaire_operate(self, client, pos, code):
# 濡傛灉鏈潵璇ヤ綅缃唬鐮佷负绌哄垯涓嶇敤淇
@@ -153,7 +160,7 @@
"data": {"index": int(pos), "code": code, "min_price": float(min_price),
"max_price": float(max_price)}}
redis = self.redis_manager_.getRedis()
- redis.rpush("code_operate_queue", json.dumps({"type": 3, "code": code, "client": client_id, "data": data}))
+ redis.rpush("code_operate_queue", json.dumps({"type": 3, "code": code, "client": client_id, "data": data, "create_time": round(time.time() * 1000)}))
# 绉婚櫎鐩戞帶
def remove_l2_listen(self, code, msg):
--
Gitblit v1.8.0