redis批量提交数据

Administrator

2023-08-07 e0ca7b43c17ebe25e718d5ca229c989f48340015

 trade/huaxin/trade_api_server.py

@@ -344,6 +344,12 @@
                        except:
                            fdata["mysql"] = 0

                        try:
                            # redis异步任务数量
                            fdata["redis_async_task_count"] = redis_manager.RedisUtils.get_async_task_count()
                        except:
                            pass

                        # 获取CPU与内存适用情况
                        memory_info = psutil.virtual_memory()
                        cpu_percent = psutil.cpu_percent(interval=1)
@@ -447,14 +453,14 @@
                    if type_ == "want_list":
                        print("want_list before", gpcode_manager.WantBuyCodesManager().list_code_cache())
                        gpcode_manager.WantBuyCodesManager().sync()
                        print("want_list after",gpcode_manager.WantBuyCodesManager().list_code_cache())
                        print("want_list after", gpcode_manager.WantBuyCodesManager().list_code_cache())
                    elif type_ == "white_list":
                        print("white_list before", l2_trade_util.WhiteListCodeManager().list_codes_cache())
                        l2_trade_util.WhiteListCodeManager().sync()
                        print("white_list after", l2_trade_util.WhiteListCodeManager().list_codes_cache())
                    elif type_ == "black_list":
                        print("black_list before", l2_trade_util.BlackListCodeManager().list_codes_cache())
                        l2_trade_util. BlackListCodeManager().sync()
                        l2_trade_util.BlackListCodeManager().sync()
                        print("black_list after", l2_trade_util.BlackListCodeManager().list_codes_cache())
                    elif type_ == "pause_buy_list":
                        print("pause_buy_list before", gpcode_manager.PauseBuyCodesManager().list_code_cache())