huaxin_client/l1_client.py
@@ -125,8 +125,9 @@ return # 上传数据 type_ = "set_target_codes" request_id = f"sb_{int(time.time() * 1000)}" fdata = json.dumps( {"type": type_, "data": {"data": datas}}) {"type": type_, "data": {"data": datas}, "request_id": request_id}) if pipe_l2 is not None: pipe_l2.send(fdata) # 记录新增加的代码 @@ -136,7 +137,7 @@ for c in codes: __latest_subscript_codes.add(c) if add_codes: logger_local_huaxin_l1.info(f"新增加订阅的代码：{add_codes}") logger_local_huaxin_l1.info(f"({request_id})新增加订阅的代码：{add_codes}") def run(pipe_l2):
