# 生成session id 整数类型 同时运行的策略不能重复
session_id = int(time.time())
# 指定客户端所在路径
xt_trader = XtQuantTrader(G.CONFIG.get('miniqmt客户端路径'), session_id)
# 开启主动请求接口的专用线程 开启后在on_stock_xxx回调函数里调用XtQuantTrader.query_xxx函数不会卡住回调线程,但是查询和推送的数据在时序上会变得不确定
# 详见: http://docs.thinktrader.net/vip/pages/ee0e9b/#开启主动请求接口的专用线程
# xt_trader.set_relaxed_response_order_enabled(True)
# 创建证券账号对象
G.ACCOUNT = StockAccount(G.CONFIG.get('股票账号'), 'STOCK')
# 创建交易回调类对象,并声明接收回调
callback = MyXtQuantTraderCallback()
xt_trader.register_callback(callback)
# 启动交易线程
xt_trader.start()
# 建立交易连接,返回0表示连接成功
connect_result = xt_trader.connect()
print('建立交易连接,返回0表示连接成功:', connect_result)
# 对交易回调进行订阅,订阅后可以收到交易主推,返回0表示订阅成功
subscribe_result = xt_trader.subscribe(G.ACCOUNT)
print('对交易回调进行订阅,订阅后可以收到交易主推,返回0表示订阅成功 :', subscribe_result)
# 这一行是注册全推回调函数 包括下单判断 安全起见处于注释状态 确认理解效果后再放开
开始的代码是这样,然后就是死循环买入卖出query_stock_asset查询余额,有老师能帮忙看看么 |