From 8595dc22aa9dde6aba6d0f8cdcf1656a8a59513b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 18:05:10 +0800
Subject: [PATCH] redis封装
---
output/kp_client_msg_manager.py | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/output/kp_client_msg_manager.py b/output/kp_client_msg_manager.py
index 9962bf4..7404932 100644
--- a/output/kp_client_msg_manager.py
+++ b/output/kp_client_msg_manager.py
@@ -25,11 +25,11 @@
# 娣诲姞娑堟伅,2s鍐呮湁鏁�
def add_msg(self, client_id, msg):
RedisUtils.lpush(
- self.__get_redis(),f"kp_msg_queue-{client_id}", json.dumps((time.time() + 2, msg)))
+ self.__get_redis(), f"kp_msg_queue-{client_id}", json.dumps((time.time() + 2, msg)))
# 璇诲彇娑堟伅
def read_msg(self, client_id):
- data =RedisUtils.lpop(self.__get_redis(), f"kp_msg_queue-{client_id}")
+ data = RedisUtils.lpop(self.__get_redis(), f"kp_msg_queue-{client_id}")
if not data:
return None
data = json.loads(data)
--
Gitblit v1.8.0