From b7000cbf5e67e90abe53e96a4ea931afbf906e24 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 16 九月 2022 18:51:47 +0800 Subject: [PATCH] l2数据计算优化 --- data_process.py | 23 +++++++++++++++++++---- 1 files changed, 19 insertions(+), 4 deletions(-) diff --git a/data_process.py b/data_process.py index 967df73..dbf1df5 100644 --- a/data_process.py +++ b/data_process.py @@ -12,7 +12,6 @@ import gpcode_manager import mongo_data - # 缁熻浠婃棩鍗栧嚭 # 缁熻浠婃棩涔板叆 import tool @@ -87,6 +86,7 @@ code = data["code"] trade_data = data["data"] return code, trade_data + # 浠g爜瀵瑰簲鐨勪环鏍兼槸鍚︽纭� def is_same_code_with_price(code, price): @@ -164,11 +164,11 @@ mongo_data.save("ths-zylt", _list) -def saveClientActive(client_id, host): +def saveClientActive(client_id, host, thsDead): if client_id <= 0: return redis = __redisManager.getRedis(); - redis.setex("client-active-{}".format(client_id), 10, host) + redis.setex("client-active-{}".format(client_id), 10, json.dumps((host, thsDead))) def getValidL2Clients(): @@ -183,9 +183,24 @@ return list(set(client_ids).intersection(set(l2_clients))) +# 鑾峰彇瀹㈡埛绔疘P def getActiveClientIP(client_id): redis = __redisManager.getRedis(); - return redis.get("client-active-{}".format(client_id)) + val = redis.get("client-active-{}".format(client_id)) + if val is None: + return None + val=json.loads(val) + return val[0] + + +# 鑾峰彇瀹㈡埛绔悓鑺遍『鐘舵�� +def getTHSState(client_id): + redis = __redisManager.getRedis(); + val = redis.get("client-active-{}".format(client_id)) + if val is None: + return None + val = json.loads(val) + return val[1] # 淇濆瓨閲忚兘 -- Gitblit v1.8.0