redis批量提交数据

Administrator

2023-08-07 e8ea6340db725a3b36a78e090fc6f97a90900264

 db/redis_manager.py

@@ -54,15 +54,22 @@
                pass

    @classmethod
    def delete(cls, redis_, key, auto_free=True):
    def delete(cls, redis_, key, auto_free=True, _async=False):
        __start_time = time.time()
        try:
            return redis_.delete(key)
        finally:
            logger_redis_debug.info("delete({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            if _async:
                logger_redis_debug.info("delete_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            else:
                logger_redis_debug.info("delete({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            if auto_free:
                # redis_.connection_pool.disconnect()
                pass

    @classmethod
    def delete_async(cls, redis_, key, auto_free=True):
        Thread(target=lambda: cls.delete(redis_, key, auto_free,_async=True)).start()

    @classmethod
    def keys(cls, redis_, key, auto_free=True):
@@ -88,19 +95,22 @@
                pass

    @classmethod
    def setex(cls, redis_, key, expire, val, auto_free=True):
    def setex(cls, redis_, key, expire, val, auto_free=True, _async = False):
        __start_time = time.time()
        try:
            return redis_.setex(key, expire, val)
        finally:
            logger_redis_debug.info("setex({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            if _async:
                logger_redis_debug.info("setex_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            else:
                logger_redis_debug.info("setex({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            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()
        Thread(target=lambda: cls.setex(redis_, key, expire, val, auto_free,_async=True)).start()

    @classmethod
    def setnx(cls, redis_, key, val, auto_free=True):
@@ -169,17 +179,24 @@
                pass

    @classmethod
    def incrby(cls, redis_, key, num, auto_free=True):
    def incrby(cls, redis_, key, num, auto_free=True, _async=False):
        __start_time = time.time()
        try:
            return redis_.incrby(key, num)
        finally:
            logger_redis_debug.info("incrby({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            if _async:
                logger_redis_debug.info("incrby_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            else:
                logger_redis_debug.info("incrby({}):{}", round((time.time() - __start_time) * 1000, 3), key)
            if auto_free:
                # redis_.connection_pool.disconnect()
                pass

    @classmethod
    def incrby_async(cls, redis_, key, num, auto_free=True):
        Thread(target=lambda: cls.incrby(redis_, key, num, auto_free)).start()

    @classmethod
    def lpush(cls, redis_, key, val, auto_free=True):
        __start_time = time.time()
        try: