From 8c3563969827850b9826ee1428f9deb1b6cb0081 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 29 十一月 2024 16:32:07 +0800
Subject: [PATCH] Redis数据同步队列修改/增加辨识度代码同步接口
---
db/redis_manager_delegate.py | 20 +-------------------
1 files changed, 1 insertions(+), 19 deletions(-)
diff --git a/db/redis_manager_delegate.py b/db/redis_manager_delegate.py
index 4d212b2..68f9de6 100644
--- a/db/redis_manager_delegate.py
+++ b/db/redis_manager_delegate.py
@@ -40,11 +40,10 @@
# 鏈満鎵цredis
__LOCAL_REQUEST = True
- __async_task_queue = queue.Queue(maxsize=4096)
+ __async_task_queue = queue.Queue(maxsize=10240)
@classmethod
def exec(cls, method_name, key, lamada_method):
- __start_time = time.time()
try:
return lamada_method()
finally:
@@ -272,23 +271,6 @@
results = cls.__batch__request(dataList)
last_upload_time = time.time()
dataList.clear()
- # try:
- # db = data[0]
- # method_name = data[1]
- # args = data[2]
- # _redis = RedisManager(db).getRedisNoPool()
- # method = getattr(RedisUtils, method_name)
- # if type(args) == tuple:
- # args = list(args)
- # args.insert(0, _redis)
- # args = tuple(args)
- # result = method(*args)
- # else:
- # args = tuple([_redis, args])
- # result = method(*args)
- # except Exception as e2:
- # logging.exception(e2)
- # logging.error(data)
except Exception as e1:
logging.exception(e1)
pass
--
Gitblit v1.8.0