From 4d321ae069fce2c0f6f7884bec8fa6c4ec534d1a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 03 八月 2023 18:25:33 +0800
Subject: [PATCH] redis连接池归还
---
ths/l2_code_operate.py | 20 ++++++++------------
1 files changed, 8 insertions(+), 12 deletions(-)
diff --git a/ths/l2_code_operate.py b/ths/l2_code_operate.py
index 88a583b..6ddcbf6 100644
--- a/ths/l2_code_operate.py
+++ b/ths/l2_code_operate.py
@@ -110,7 +110,7 @@
while True:
cls.set_read_queue_valid()
try:
- data =RedisUtils.lpop(redis,"code_operate_queue")
+ data = RedisUtils.lpop(redis, "code_operate_queue", auto_free= False)
# print("璇诲彇鎿嶄綔闃熷垪", data, redis.llen("code_operate_queue"))
if data is not None:
data = json.loads(data)
@@ -186,10 +186,9 @@
# 09:25:10涔嬪悗鎵嶈兘鎿嶄綔
if int(tool.get_now_time_str().replace(":", "")) < int("092510"):
return
- redis = self.redis_manager_.getRedis()
- RedisUtils.rpush(redis, "code_operate_queue",
- json.dumps({"type": type, "msg": msg, "code": code, "client": client, "pos": pos,
- "create_time": round(time.time() * 1000)}))
+ RedisUtils.rpush(self.redis_manager_.getRedis(), "code_operate_queue",
+ 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):
# 濡傛灉鏈潵璇ヤ綅缃唬鐮佷负绌哄垯涓嶇敤淇
@@ -210,8 +209,7 @@
data = {"action": "repairL2Data",
"data": {"index": int(pos), "code": code, "min_price": float(min_price),
"max_price": float(max_price)}}
- redis = self.redis_manager_.getRedis()
- RedisUtils.rpush(redis, "code_operate_queue", json.dumps(
+ RedisUtils.rpush(self.redis_manager_.getRedis(), "code_operate_queue", json.dumps(
{"type": 3, "code": code, "client": client_id, "data": data, "create_time": round(time.time() * 1000)}))
# 绉婚櫎鐩戞帶
@@ -223,7 +221,7 @@
# 璁剧疆浠ｇ爜鎿嶄綔鐘舵�侊紝鏈嶅姟鍣ㄤ繚瀛樼殑浠ｇ爜鏄惁涓庡疄闄呰缃殑浠ｇ爜淇濇寔涓�鑷�
@classmethod
def set_operate_code_state(cls, client_id, channel, state):
- RedisUtils.setex(cls.getRedis(),"code-operate_state-{}-{}".format(client_id, channel), 10, state)
+ RedisUtils.setex(cls.getRedis(), "code-operate_state-{}-{}".format(client_id, channel), 10, state)
def get_operate_code_state(self, client_id, channel):
value = RedisUtils.get(self.getRedis(), "code-operate_state-{}-{}".format(client_id, channel))
@@ -234,13 +232,11 @@
# 璁剧疆璇诲彇闃熷垪鏈夋晥
@classmethod
def set_read_queue_valid(cls):
- redis = cls.getRedis()
- RedisUtils.setex( redis,"operate_queue_read_state", 20, 1)
+ RedisUtils.setex(cls.getRedis(), "operate_queue_read_state", 20, 1)
@classmethod
def is_read_queue_valid(cls):
- redis = cls.getRedis()
- return RedisUtils.get(redis, "operate_queue_read_state") is not None
+ return RedisUtils.get(cls.getRedis(), "operate_queue_read_state") is not None
# 閫氳繃l2浠ｇ爜鏍￠獙浠ｇ爜浣�
--
Gitblit v1.8.0