添加系统日志

Administrator

2023-08-31 b217ca6db84c273f0d1c24eed3fae6bec2431dbe

 main.py

@@ -42,11 +42,13 @@
    t1.start()

    # 启动L2订阅服务
    t1 = threading.Thread(target=huaxin_client.l2_client.run, args=(ptl2_l2, psl2_l2, trade_server.my_l2_data_callback), daemon=True)
    t1 = threading.Thread(target=huaxin_client.l2_client.run, args=(ptl2_l2, psl2_l2, trade_server.my_l2_data_callback),
                          daemon=True)
    t1.start()

    # 启动华鑫交易服务
    t1 = threading.Thread(target=huaxin_client.trade_client.run, args=(trade_server.my_trade_response, ptl2_trade, pst_trade),
    t1 = threading.Thread(target=huaxin_client.trade_client.run,
                          args=(trade_server.my_trade_response, ptl2_trade, pst_trade),
                          daemon=True)
    t1.start()

@@ -78,6 +80,7 @@


if __name__ == '__main__':
    try:
    logger_l2_trade.info("启动程序")
    logger_system.info("启动程序--------")
    log.close_print()
@@ -98,11 +101,14 @@
    # serverProcess.start()
    logger_system.info("主进程ID：{}", os.getpid())

    tradeServerProcess = multiprocessing.Process(target=createTradeServer,
                                                 args=(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy,ptl2_l2, psl2_l2,ptl2_trade,pst_trade))
    tradeServerProcess.start()

    # L1订阅数据
    huaxin_client.l1_client.run(pl1t_l1)
        l1Process = multiprocessing.Process(target=huaxin_client.l1_client.run, args=(pl1t_l1,))
        l1Process.start()

        # 主进程
        createTradeServer(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy, ptl2_l2, psl2_l2, ptl2_trade, pst_trade)

    # 将tradeServer作为主进程
    tradeServerProcess.join()
        l1Process.join()
    except Exception as e:
        logger_system.exception(e)