From 8595dc22aa9dde6aba6d0f8cdcf1656a8a59513b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 18:05:10 +0800
Subject: [PATCH] redis封装
---
ths/l2_code_operate.py | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/ths/l2_code_operate.py b/ths/l2_code_operate.py
index c6be5ef..88a583b 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 = redis.lpop("code_operate_queue")
+ data =RedisUtils.lpop(redis,"code_operate_queue")
# print("璇诲彇鎿嶄綔闃熷垪", data, redis.llen("code_operate_queue"))
if data is not None:
data = json.loads(data)
@@ -187,7 +187,7 @@
if int(tool.get_now_time_str().replace(":", "")) < int("092510"):
return
redis = self.redis_manager_.getRedis()
- redis.rpush("code_operate_queue",
+ RedisUtils.rpush(redis, "code_operate_queue",
json.dumps({"type": type, "msg": msg, "code": code, "client": client, "pos": pos,
"create_time": round(time.time() * 1000)}))
@@ -211,7 +211,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(
+ RedisUtils.rpush(redis, "code_operate_queue", json.dumps(
{"type": 3, "code": code, "client": client_id, "data": data, "create_time": round(time.time() * 1000)}))
# 绉婚櫎鐩戞帶
@@ -240,7 +240,7 @@
@classmethod
def is_read_queue_valid(cls):
redis = cls.getRedis()
- return redis.get("operate_queue_read_state") is not None
+ return RedisUtils.get(redis, "operate_queue_read_state") is not None
# 閫氳繃l2浠ｇ爜鏍￠獙浠ｇ爜浣�
--
Gitblit v1.8.0