redis批量提交数据

Administrator

2023-08-07 2a7e23ae3e01e05f2e01f179764e1c9cef71ac70

 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()