| | |
|---|
| | | |
|---|
| | | import constant |
|---|
| | | from log_module.log import logger_redis_debug |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | config = constant.REDIS_CONFIG |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | class RedisUtils: |
|---|
| | | __async_task_queue = queue.Queue() |
|---|
| | | __async_task_queue = queue.Queue(maxsize=1024) |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def exec(cls, method_name, key, lamada_method): |
|---|
| | |
|---|
| | | try: |
|---|
| | | return lamada_method() |
|---|
| | | finally: |
|---|
| | | logger_redis_debug.info("{}({}):{}", method_name, round((time.time() - __start_time) * 1000, 3), key) |
|---|
| | | # logger_redis_debug.info("{}({}):{}", method_name, round((time.time() - __start_time) * 1000, 3), key) |
|---|
| | | pass |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def get(cls, redis_, key, auto_free=True): |
|---|
| | |
|---|
| | | |
|---|
| | | except Exception as e1: |
|---|
| | | logging.exception(e1) |
|---|
| | | pass |
|---|
| | | time.sleep(1) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
