| | |
|---|
| | | f"{code}#耗时：{int(time.time() * 1000) - timestamp}-{now_timestamp}#{_datas}") |
|---|
| | | thread_id = random.randint(0, 100000) |
|---|
| | | l2_log.threadIds[code] = thread_id |
|---|
| | | async_log_util.info(hx_logger_l2_upload, f"{code}数据处理开始：{thread_id}") |
|---|
| | | # async_log_util.info(hx_logger_l2_upload, f"{code}数据处理开始：{thread_id}") |
|---|
| | | try: |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, _datas) |
|---|
| | | finally: |
|---|
| | | async_log_util.info(hx_logger_l2_upload, f"{code}数据处理结束：{thread_id}") |
|---|
| | | pass |
|---|
| | | # async_log_util.info(hx_logger_l2_upload, f"{code}数据处理结束：{thread_id}") |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def l2_transaction(cls, code, datas): |
|---|
