From 01a6c8606f5af8eaa328f562634a8950dd9d1f0d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 八月 2023 14:49:58 +0800
Subject: [PATCH] redis批量提交数据
---
db/redis_manager.py | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/db/redis_manager.py b/db/redis_manager.py
index 930ed86..467c280 100644
--- a/db/redis_manager.py
+++ b/db/redis_manager.py
@@ -59,9 +59,7 @@
try:
return redis_.delete(key)
finally:
- if _async:
- logger_redis_debug.info("delete_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
- else:
+ if not _async:
logger_redis_debug.info("delete({}):{}", round((time.time() - __start_time) * 1000, 3), key)
if auto_free:
# redis_.connection_pool.disconnect()
@@ -69,7 +67,9 @@
@classmethod
def delete_async(cls, redis_, key, auto_free=True):
+ __start_time = time.time()
Thread(target=lambda: cls.delete(redis_, key, auto_free,_async=True)).start()
+ logger_redis_debug.info("delete_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
@classmethod
def keys(cls, redis_, key, auto_free=True):
@@ -100,9 +100,7 @@
try:
return redis_.setex(key, expire, val)
finally:
- if _async:
- logger_redis_debug.info("setex_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
- else:
+ if not _async:
logger_redis_debug.info("setex({}):{}", round((time.time() - __start_time) * 1000, 3), key)
if auto_free:
# redis_.connection_pool.disconnect()
@@ -110,7 +108,9 @@
@classmethod
def setex_async(cls, redis_, key, expire, val, auto_free=True):
+ __start_time = time.time()
Thread(target=lambda: cls.setex(redis_, key, expire, val, auto_free,_async=True)).start()
+ logger_redis_debug.info("setex_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
@classmethod
def setnx(cls, redis_, key, val, auto_free=True):
@@ -184,9 +184,7 @@
try:
return redis_.incrby(key, num)
finally:
- if _async:
- logger_redis_debug.info("incrby_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
- else:
+ if not _async:
logger_redis_debug.info("incrby({}):{}", round((time.time() - __start_time) * 1000, 3), key)
if auto_free:
# redis_.connection_pool.disconnect()
@@ -194,7 +192,9 @@
@classmethod
def incrby_async(cls, redis_, key, num, auto_free=True):
+ __start_time = time.time()
Thread(target=lambda: cls.incrby(redis_, key, num, auto_free)).start()
+ logger_redis_debug.info("incrby_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
@classmethod
def lpush(cls, redis_, key, val, auto_free=True):
--
Gitblit v1.8.0