[分享]成交主推行情有延时，验证方式

如果觉得成交主推延时，可以打一份日志验证下，和自己的程序做个校验, 以下是代码:

1. #coding=utf-8
   
2. import logging
   
3. import logging.handlers
   
4. import os
   
5. from random import randint
   
6. from xtquant.xttrader import XtQuantTrader, XtQuantTraderCallback
   
7. from xtquant.xttype import StockAccount
   
8. from datetime import datetime, timedelta
   
9. 
   
10. from xtquant.xttrader import XtQuantTraderCallback
    
11. 
    
12. 
    
13. class MyXtQuantTraderCallback(XtQuantTraderCallback):
    
14.     def on_disconnected(self):
    
15.         """
    
16.         连接断开
    
17.         :return:
    
18.         """
    
19.         pass
    
20. 
    
21.     def on_stock_order(self, order):
    
22.         """
    
23.         委托回报推送
    
24.         :param order: XtOrder对象
    
25.         :return:
    
26.         """
    
27.         pass
    
28. 
    
29.     def on_stock_trade(self, trade):
    
30.         global context1
    
31.         """
    
32.         成交变动推送
    
33.         :param trade: XtTrade对象
    
34.         :return:
    
35.         """
    
36.         td = datetime.fromtimestamp(trade.traded_time)
    
37.         mylog.info(
    
38.             f'on trade callback: 账号: {trade.account_id}, 合约: {trade.stock_code} 订单号: {trade.order_id}, 交易时间: {td}')
    
39.         # print(dir(trade))
    
40.         print(f'on trade callback: 账号: {trade.account_id}, 合约: {trade.stock_code} 订单号: {trade.order_id}, 交易时间: {td}')
    
41. 
    
42. 
    
43. 
    
44. # 记录日志
    
45. def set_log(local_path):
    
46.     logger = logging.getLogger('mylogger_buy')
    
47.     logger.setLevel(logging.INFO)
    
48.     format_str = logging.Formatter("%(asctime)s - %(levelname)s - %(message)s", datefmt='%Y-%m-%d %H:%M:%S')  # 设置日志格式
    
49.     sh_handler = logging.StreamHandler()  # 往屏幕上输出
    
50.     sh_handler.setFormatter(format_str)  # 设置屏幕上显示的格式
    
51.     rf_handler = logging.handlers.TimedRotatingFileHandler(
    
52.         local_path + os.sep + '主推日志{}.log'.format(datetime.now().strftime("%Y%m%d")),
    
53.         when='D', interval=1)
    
54.     rf_handler.setFormatter(format_str)
    
55.     logger.addHandler(sh_handler)  # 把对象加到logger里
    
56.     logger.addHandler(rf_handler)
    
57.     return logger
    
58. 
    
59. if __name__ == "__main__":
    
60.     print("demo test")
    
61.     # 日志路径
    
62.     local_path = r'C:\Users\admin\Desktop\stool_pool'
    
63.     mylog = set_log(local_path)
    
64.     # 写极简的安装路径
    
65.     path = r'E:\十月尔尔\qmt\31256\迅投极速交易终端睿智融科版\userdata_mini'
    
66.     session_id = randint(100000, 999999)
    
67.     stock_account_id = '800176'  # 资金账号
    
68.     xt_trader = XtQuantTrader(path, session_id)
    
69.     acc = StockAccount(stock_account_id, 'STOCK')
    
70.     callback = MyXtQuantTraderCallback()
    
71.     xt_trader.register_callback(callback)
    
72.     xt_trader.start()
    
73.     connect_result = xt_trader.connect()
    
74.     print('建立交易连接，返回0表示连接成功', connect_result)
    
75.     subscribe_result = xt_trader.subscribe(acc)
    
76.     print('对交易回调进行订阅，订阅后可以收到交易主推，返回0表示订阅成功', subscribe_result)
    
77.     try:
    
78.         xt_trader.run_forever()
    
79.     except:
    
80.         pass
    

复制代码

非常棒，学习了

如果能把最后的 log 输出, 关键点再指出说明一下, 就更好了

无门槛申请QMT(mini qmt)、ptrade，策略代写，股票低佣万0.854，融资4.5%起 ，联系：Annalidian-8285