redis异步数据提交

Administrator

2023-08-07 f366d71c79fa6a17ecc6d994ad6f57e645b84209

 db/redis_manager.py

@@ -88,8 +88,21 @@
        return cls.exec("expire", key, lambda: redis_.expire(key, expire))

    @classmethod
    def expire_async(cls, db, key, expire, auto_free=True):
        __start_time = time.time()
        cls.add_async_task(db, "expire", (key, expire))
        logger_redis_debug.info("expire_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)


    @classmethod
    def sadd(cls, redis_, key, val, auto_free=True):
        return cls.exec("sadd", key, lambda: redis_.sadd(key, val))

    @classmethod
    def sadd_async(cls, db, key, val, auto_free=True):
        __start_time = time.time()
        cls.add_async_task(db, "sadd", (key, val))
        logger_redis_debug.info("sadd_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)

    @classmethod
    def sismember(cls, redis_, key, val, auto_free=True):
@@ -104,6 +117,12 @@
        return cls.exec("srem", key, lambda: redis_.srem(key, val))

    @classmethod
    def srem_async(cls, db, key, val, auto_free=True):
        __start_time = time.time()
        cls.add_async_task(db, "srem", (key, val))
        logger_redis_debug.info("srem_async({}):{}", round((time.time() - __start_time) * 1000, 3), key)

    @classmethod
    def incrby(cls, redis_, key, num, auto_free=True, _async=False):
        return cls.exec("incrby", key, lambda: redis_.incrby(key, num))