redis数据同步改进

admin

2025-05-21 40f9e27feb5f5483db08218916bd0443dbc97c0e

redis数据同步改进

 db/redis_manager_delegate.py

@@ -204,7 +204,11 @@
        last_upload_time = time.time()
        while True:
            try:
                data = cls.__async_task_queue.get()
                if not cls.__async_task_queue.empty():
                    data = cls.__async_task_queue.get()
                else:
                    data = None
                    time.sleep(1)
                if data:
                    temp_data = [data[0], data[1]]
                    if type(data[2]) == tuple or type(data[2]) == list:
@@ -227,23 +231,6 @@
                    results = cls.__batch__request(dataList)
                    last_upload_time = time.time()
                    dataList.clear()
                    # try:
                    #     db = data[0]
                    #     method_name = data[1]
                    #     args = data[2]
                    #     _redis = RedisManager(db).getRedisNoPool()
                    #     method = getattr(RedisUtils, method_name)
                    #     if type(args) == tuple:
                    #         args = list(args)
                    #         args.insert(0, _redis)
                    #         args = tuple(args)
                    #         result = method(*args)
                    #     else:
                    #         args = tuple([_redis, args])
                    #         result = method(*args)
                    # except Exception as e2:
                    #     logging.exception(e2)
                    #     logging.error(data)
            except Exception as e1:
                logging.exception(e1)
                pass

 strategy/order_methods.py

@@ -293,6 +293,4 @@

if __name__ == '__main__':
    # 测试代码
    TodayBuyCodeManager().place_order("000001", 1)
    TodayBuyCodeManager().buy_fail(1)
    print(TodayBuyCodeManager().get_buy_codes())