| | |
|---|
| | | |
|---|
| | | times = _datas[0] |
|---|
| | | datas = _datas[1] |
|---|
| | | logger_l2_codes_subscript.info("读取L2代码处理队列：数量-{}", len(datas)) |
|---|
| | | request_id = _datas[2] |
|---|
| | | logger_l2_codes_subscript.info("({})读取L2代码处理队列：数量-{}",request_id, len(datas)) |
|---|
| | | print("时间戳：", times) |
|---|
| | | print("内容：", datas) |
|---|
| | | # 只处理20s内的数据 |
|---|
| | |
|---|
| | | root_data = socket_util.encryp_client_params_sign(root_data) |
|---|
| | | pipe_l2.send(json.dumps(root_data)) |
|---|
| | | print("设置L2代码结束") |
|---|
| | | logger_l2_codes_subscript.info("发送到华鑫L2代码处理队列：数量-{}", len(datas)) |
|---|
| | | logger_l2_codes_subscript.info("({})发送到华鑫L2代码处理队列：数量-{}",request_id, len(datas)) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | logger_l2_codes_subscript.exception(e) |
|---|
