From 2a7e23ae3e01e05f2e01f179764e1c9cef71ac70 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 八月 2023 13:15:17 +0800
Subject: [PATCH] redis批量提交数据
---
db/redis_manager.py | 16 +++++++++++-----
1 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/db/redis_manager.py b/db/redis_manager.py
index 6401474..abd3751 100644
--- a/db/redis_manager.py
+++ b/db/redis_manager.py
@@ -2,11 +2,13 @@
redis绠＄悊鍣�
"""
import time
+from threading import Thread
import redis
import constant
from log_module.log import logger_redis_debug
+from utils import tool
config = constant.REDIS_CONFIG
@@ -87,6 +89,7 @@
@classmethod
def setex(cls, redis_, key, expire, val, auto_free=True):
+ time.sleep(1)
__start_time = time.time()
try:
return redis_.setex(key, expire, val)
@@ -95,6 +98,10 @@
if auto_free:
# redis_.connection_pool.disconnect()
pass
+
+ @classmethod
+ def setex_async(cls, redis_, key, expire, val, auto_free=True):
+ Thread(target=lambda: cls.setex(redis_, key, expire, val, auto_free)).start()
@classmethod
def setnx(cls, redis_, key, val, auto_free=True):
@@ -215,8 +222,7 @@
if __name__ == "__main__":
- redisManager = RedisManager(0)
- for i in range(0, 50):
- print(i)
- redis = redisManager.getRedis()
- redis
+ time1 = time.time()
+ RedisUtils.setex_async(RedisManager(0).getRedis(), "test123123", tool.get_expire(), "123213")
+ print(time.time() - time1)
+ input()
--
Gitblit v1.8.0