| | |
| | | l2_data_callback.OnMarketData(temp[0], temp[2]) |
| | | else: |
| | | upload_data(temp[0], temp[1], temp[2]) |
| | | time.sleep(0.01) |
| | | |
| | | except Exception as e: |
| | | logger_local_huaxin_l2_error.exception(e) |
| | | logger_local_huaxin_l2_error.error(f"上传普通数据出错:{str(e)}") |
| | | finally: |
| | | time.sleep(0.01) |
| | | |
| | | |
| | | def __run_upload_trading_canceled(l2_data_callback: L2DataCallBack): |
| | |
| | | t.start() |
| | | __upload_trans_threads[code] = t |
| | | logger_local_huaxin_l2_upload.info(f"重新创建L2成交上传线程:{code}") |
| | | time.sleep(3) |
| | | except: |
| | | pass |
| | | finally: |
| | | time.sleep(3) |
| | | t = threading.Thread(target=lambda: upload_daemon(), daemon=True) |
| | | t.start() |
| | | |