华鑫托管改造初步设计

Administrator

2023-08-14 31823d638d8d824bb6240e5b0fe11c54d97473a7

 db/redis_manager.py

@@ -4,7 +4,6 @@
import logging
import queue
import time
from threading import Thread

import redis

@@ -172,10 +171,6 @@


if __name__ == "__main__":
    RedisUtils.setex_async(0, "test", tool.get_expire(), "123123")
    print("大小", RedisUtils.get_async_task_count())
    RedisUtils.incrby_async(0, "test_1", 1)
    print("大小", RedisUtils.get_async_task_count())
    RedisUtils.delete_async(0, "test")
    print("大小", RedisUtils.get_async_task_count())
    RedisUtils.run_loop()
    redis = RedisManager(1).getRedis()
    db = redis.connection_pool.connection_kwargs['db']
    print(db)