redis批量提交数据

Administrator

2023-08-07 01a6c8606f5af8eaa328f562634a8950dd9d1f0d

redis批量提交数据

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