python策略API文档 ==================== 快速上手 ----------- 策略逻辑简介 ~~~~~~~~~~~~~~ 功夫系统上的策略在策略连接行情交易柜台，发送订阅请求以后，通过以下回调函数给用户发送消息， 用户在不同的回调函数中调用功能函数实现获取行情，下单，时间回调等逻辑。详细数据定义和接口函数定义可查看后文，以下为一个策略示例 **注意 ： 策略应和功夫安装目录在一个盘符下面，策略文件路径最好不要有空格** **注意 : 在运行策略之前一定要看下启动的账户柜台进程(td)和行情源柜台进程(md)是否与策略中填写的柜台ID一致** :: # -*- coding: UTF-8 -*- import kungfu.yijinjing.time as kft from kungfu.wingchun.constants import * # 期货 # SOURCE = "ctp" # ACCOUNT = "089270" # tickers = ["rb2001","rb2003"] # VOLUME = 2 # EXCHANGE = Exchange.SHFE # 股票柜台 SOURCE = "xtp" # 要链接的账户 ACCOUNT = "15040910" # 准备订阅的标的 tickers = ["600000", "600001"] # 下单数量 VOLUME = 200 # 标的对应的交易所 EXCHANGE = Exchange.SSE # 启动前回调，添加交易账户，订阅行情，策略初始化计算等 def pre_start(context): context.add_account(SOURCE, ACCOUNT) context.subscribe(SOURCE, tickers, EXCHANGE) # 启动准备工作完成后回调，策略只能在本函数回调以后才能进行获取持仓和报单 def post_start(context): context.log.warning("post_start") log_book(context, None) # 收到快照行情时回调，行情信息通过quote对象获取 def on_quote(context, quote, location,dest): context.log.info("[on_quote] {}".format(quote)) if quote.instrument_id in tickers: order_id = context.insert_order(quote.instrument_id, EXCHANGE, SOURCE, ACCOUNT, quote.last_price, VOLUME, PriceType.Limit, Side.Buy, Offset.Open) context.log.info("[order] (rid){} (ticker){}".format(order_id, quote.instrument_id)) if order_id > 0: # 通过添加时间回调，在三秒以后撤单 context.add_timer(context.now() + 3 * 1000000000, lambda ctx, event: cancel_order(ctx, order_id)) # 收到订单状态回报时回调 def on_order(context, order, location,dest): context.log.info("[on_order] {}".format(order)) # 收到成交信息回报时回调 def on_trade(context, trade, location,dest): context.log.info("[on_trade] {}".format(trade)) # 策略退出前方法，仍然可以获取持仓和报单 def pre_stop(context): context.log.info("[before strategy stop]") # 策略进程退出前方法 def post_stop(context): context.log.info("[before process stop]") # 自定义函数 # 账户中资金/持仓情况 def log_book(context, event): context.account_book = context.get_account_book(SOURCE, ACCOUNT) context.log.warning("账户资金组合信息 {}".format(context.account_book.asset)) # 账户中多头持仓数据 long_position = context.account_book.long_positions for key in long_position: pos = long_position[key] context.log.info("多头持仓数据 (instrument_id){} (volume){} (yesterday_volume){}".format(pos.instrument_id,pos.volume,pos.yesterday_volume)) # 自定义撤单回调函数 def cancel_order(context, order_id): action_id = context.cancel_order(order_id) if action_id > 0: context.log.info("[cancel order] (action_id){} (rid){} ".format(action_id, order_id)) 函数定义 ----------- 基本方法 ~~~~~~~~~~~~~~ pre_start ^^^^^^^^^^^^^ **启动前调用函数，在策略启动前调用，用于完成添加交易账户，订阅行情，策略初始化计算等** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性。 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def pre_start(context): # 添加柜台id,账户 context.add_account(source, account) # 订阅行情 context.subscribe(source, tickers, exchange) post_start ^^^^^^^^^^^^^^^^^ **启动后调用函数，策略连接上行情交易柜台后调用，本函数回调后，策略可以执行添加时间回调、获取策略持仓、报单等操作** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性。 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def post_start(context): context.log.info("[post_start] {}".format("post_start")) pre_stop ^^^^^^^^^^^^ **策略退出前方法** (当关闭策略的时候,策略退出之前调用这个方法) 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性。 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: # 退出前函数 def pre_stop(context): context.log.info("strategy will stop") post_stop ^^^^^^^^^^^^ **进程退出前方法** (当关闭策略的时候,策略进程退出之前调用这个方法) 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性。 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: # 退出前函数 def post_stop(context): context.log.info("process will stop") on_quote ^^^^^^^^^^^ **行情数据的推送会自动触发该方法的调用。** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - quote - :ref:`Quote对象 ` - 行情数据 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_quote(context, quote, location, dest): context.log.info('[on_quote] {}, {}, {}'.format( quote.instrument_id, quote.last_price, quote.volume)) dest举例说明:: def on_quote(context, quote, location, dest): context.log.info("[on_quote] ----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_quote] ---- md, xtp, xtp, 0x0 # location.category为: "md" , location.group为 : "xtp" ,location.name为: "xtp" , hex(dest)为 : 0x0 # 数据存储在kf_home(kungfu\home\runtime\ md \ xtp \ xtp \journal\live) 中以16进制打印dest的同名文件中: 00000000.1.journal on_transaction ^^^^^^^^^^^^^^^^^ **逐笔成交行情数据的推送会自动触发该方法的调用** 注意 : sim模拟柜台不支持逐笔行情 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - transaction - :ref:`Transaction对象 ` - 逐笔成交行情数据 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_transaction(context, transaction, location, dest): context.log.info('[on_transaction] {}'.format(transaction)) dest举例说明:: def on_transaction(context, transaction, location, dest): context.log.info("[on_transaction] ----{}, {}, {}".format(location.category, location.group, location.name,hex(dest))) # [on_transaction] ---- md, xtp, xtp, 0x0 # location.category为: "md" , location.group为 : "xtp" ,location.name为: "xtp" , hex(dest)为 : 0x0 # 数据存储在kf_home(kungfu\home\runtime\ md \ xtp \ xtp \journal\live) 中以16进制打印dest的同名文件中: 00000000.1.journal on_entrust ^^^^^^^^^^^^^^^^^ **逐笔委托行情数据的推送会自动触发该方法的调用** 注意 : sim模拟柜台不支持逐笔行情 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - entrust - :ref:`Entrust对象 ` - 逐笔委托行情数据 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_entrust(context, entrust, location, dest): context.log.info('[on_entrust] {}'.format(entrust)) dest举例说明:: def on_entrust(context, entrust, location, dest): context.log.info("[on_entrust] ----{}, {}, {}".format(location.category, location.group, location.name,hex(dest))) # [on_entrust] ---- md, xtp, xtp, 0x0 # location.category为: "md" , location.group为 : "xtp" ,location.name为: "xtp" , hex(dest)为 : 0x0 # 数据存储在kf_home(kungfu\home\runtime\ md \ xtp \ xtp \journal\live) 中以16进制打印dest的同名文件中: 00000000.1.journal on_order ^^^^^^^^^^^^^^^^^ **订单信息的更新会自动触发该方法的调用** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - order - :ref:`Order对象 ` - 订单信息更新数据 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_order(context, order, location, dest): context.log.info('[on_order] {}, {}, {}'.format( order.order_id, order.status, order.volume)) dest举例说明:: def on_order(context, order, location, dest): context.log.info("[on_order] -----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_order] ----td, xtp, 00031075, 0x44a836d8 # location.category为: "td" , location.group为 : "xtp" ,location.name为: "00031075" , hex(dest)为 : 0x44a836d8 # 数据存储在kf_home(kungfu\home\runtime\ td \ xtp \ 00031075 \journal\live) 中以16进制打印dest的同名文件中 : 44a836d8.1.journal on_trade ^^^^^^^^^^^^^^^^^ **策略订单成交信息的更新会自动触发该方法的调用** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - trade - :ref:`Trade对象 ` - 订单成交更新数据 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_trade(context, trade, location, dest): context.log.info('[on_trade] {}, {}, {}'.format(trade.order_id, trade.volume, trade.price)) dest举例说明:: def on_trade(context, trade, location, dest): context.log.info("[on_trade] -----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_trade] ----td, xtp, 00031075, 0x44a836d8 # location.category为: "td" , location.group为 : "xtp" ,location.name为: "00031075" , hex(dest)为 : 0x44a836d8 # 数据存储在kf_home(kungfu\home\runtime\ td \ xtp \ 00031075 \journal\live) 中以16进制打印dest的同名文件中 : 44a836d8.1.journal on_history_order ^^^^^^^^^^^^^^^^^^^^^ **当天历史订单委托信息回报** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - history_order - :ref:`HistoryOrder对象 ` - 当日历史委托信息 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def post_start(context): context.req_history_order(SOURCE,ACCOUNT,100) def on_history_order(context, history_order, location, dest): context.log.info('[on_history_order] {}'.format(history_order)) dest举例说明:: def on_history_order(context, history_order, location, dest): context.log.info("[on_history_order] -----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_history_order] ----td, xtp, 00031075, 0x44a836d8 # location.category为: "td" , location.group为 : "xtp" ,location.name为: "00031075" , hex(dest)为 : 0x44a836d8 # 数据存储在kf_home(kungfu\home\runtime\ td \ xtp \ 00031075 \journal\live) 中以16进制打印dest的同名文件中 : 44a836d8.1.journal on_history_trade ^^^^^^^^^^^^^^^^^^^^ **当天历史订单成交信息回报** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - history_trade - :ref:`HistoryTrade对象 ` - 当日历史订单成交信息 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def post_start(context): context.req_history_trade(SOURCE,ACCOUNT,100) def on_history_trade(context, history_trade, location, dest): context.log.info('[on_history_trade] {}'.format(history_trade)) dest举例说明:: def on_history_trade(context, history_trade, location, dest): context.log.info("[on_history_trade] -----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_history_trade] ----td, xtp, 00031075, 0x44a836d8 # location.category为: "td" , location.group为 : "xtp" ,location.name为: "00031075" , hex(dest)为 : 0x44a836d8 # 数据存储在kf_home(kungfu\home\runtime\ td \ xtp \ 00031075 \journal\live) 中以16进制打印dest的同名文件中 : 44a836d8.1.journal on_req_history_order_error ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **历史订单查询报错回调** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - error - :ref:`RequestHistoryOrderError对象 ` - 报错信息 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_req_history_order_error(context, error, location,dest): context.log.info('[on_req_history_order_error] {}'.format(error)) dest举例说明:: def on_req_history_order_error(context, error, location, dest): context.log.info("[on_req_history_order_error] -----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_req_history_order_error] ----td, xtp, 00031075, 0x44a836d8 # location.category为: "td" , location.group为 : "xtp" ,location.name为: "00031075" , hex(dest)为 : 0x44a836d8 # 数据存储在kf_home(kungfu\home\runtime\ td \ xtp \ 00031075 \journal\live) 中以16进制打印dest的同名文件中 : 44a836d8.1.journal on_req_history_trade_error ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **历史成交查询报错回调** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - error - :ref:`RequestHistoryTradeError对象 ` - 错误信息 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_req_history_trade_error(context, error, location,dest): context.log.info('[on_req_history_trade_error] {}'.format(error)) dest举例说明:: def on_req_history_trade_error(context, error, location, dest): context.log.info("[on_req_history_trade_error] -----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_req_history_trade_error] ----td, xtp, 00031075, 0x44a836d8 # location.category为: "td" , location.group为 : "xtp" ,location.name为: "00031075" , hex(dest)为 : 0x44a836d8 # 数据存储在kf_home(kungfu\home\runtime\ td \ xtp \ 00031075 \journal\live) 中以16进制打印dest的同名文件中 : 44a836d8.1.journal on_position_sync_reset ^^^^^^^^^^^^^^^^^^^^^^^^^^ **本地交易柜台(TD)的持仓与柜台持仓数据不一致时被调用 (60s同步一次)** 注 : 系统会每60s从柜台同步一次账户持仓,并覆盖本地维护的账户持仓数据.当本地维护的账户持仓列表中任意标的数量或者昨仓信息与柜台的不一致就触发此函数 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - old_book - :ref:`book对象 ` - 本地维护持仓数据 * - new_book - :ref:`book对象 ` - 柜台持仓数据 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_position_sync_reset(context, old_book, new_book): positions_old_book = old_book.long_positions for key in positions_old_book: pos = positions_old_book[key] context.log.info("positions_old_book (instrument_id){} (direction){} (volume){} (yesterday_volume){} ".format( pos.instrument_id, pos.direction, pos.volume, pos.yesterday_volume)) positions_new_book = new_book.long_positions for key in positions_new_book: pos = positions_new_book[key] context.log.info("positions_new_book (instrument_id){} (direction){} (volume){} (yesterday_volume){} ".format( pos.instrument_id, pos.direction, pos.volume, pos.yesterday_volume)) on_asset_sync_reset ^^^^^^^^^^^^^^^^^^^^ **本地维护账户资金与柜台不一致时被调用 (60s同步一次)** 注 : 系统会每60s从柜台同步一次账户资金信息,并覆盖本地维护的账户资金信息.当本地维护的账户中可用资金或者保证金(期货)与柜台同步的不一致时此函数被调用 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - old_asset - :ref:`asset ` - 本地维护资金信息 * - new_asset - :ref:`asset ` - 柜台资金信息 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_asset_sync_reset(context, old_asset, new_asset): context.log.warning("on_asset_sync_reset ---- {},{}".format(old_asset.avail, new_asset.avail)) on_order_action_error ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **撤单报错信息触发调用** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - error - :ref:`OrderActionError对象 ` - 撤单报错信息 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_order_action_error(context, error, location, dest): context.log.warning("on_order_action_error {}".format(error)) dest举例说明:: def on_order_action_error(context, error, location, dest): context.log.info("[on_order_action_error] -----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_order_action_error] ----td, xtp, 00031075, 0x44a836d8 # location.category为: "td" , location.group为 : "xtp" ,location.name为: "00031075" , hex(dest)为 : 0x44a836d8 # 数据存储在kf_home(kungfu\home\runtime\ td \ xtp \ 00031075 \journal\live) 中以16进制打印dest的同名文件中 : 44a836d8.1.journal on_deregister ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **交易账户(TD)进程 / 行情(MD)进程断开回调此函数** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - deregister - :ref:`Deregister对象 ` - 断开回调信息 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_deregister(context, deregister, location): context.log.info('[on_deregister] {}'.format(deregister)) on_broker_state_change ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **客户端状态变化回调** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - broker_state_update - :ref:`BrokerStateUpdate对象 ` - 客户端状态变化回调信息 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_broker_state_change(context, broker_state_update, location): context.log.info('[on_broker_state_change] {}'.format(broker_state_update)) on_synthetic_data ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **订阅的算子器发布的数据返回** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - synthetic_data - :ref:`SyntheticData对象 ` - 订阅的算子器发布的数据 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 * - dest - int - 以16进制打印出来与location配合可以知道数据保存的journal文件名 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_synthetic_data(context, synthetic_data, location, dest): context.log.info("on_synthetic_data: {}".format(synthetic_data)) dest举例说明:: def pre_start(context): context.subscribe_operator("bar", "test") def on_synthetic_data(context, synthetic_data, location, dest): context.log.info("[on_synthetic_data] -----{}, {}, {}".format(location.category, location.group, location.name, hex(dest))) # [on_synthetic_data] ----operator, bar, test, 0x0 # location.category为: "operator" , location.group为 : "bar" ,location.name为: "test" , hex(dest)为 : 0x0 # 数据存储在kf_home(kungfu\home\runtime\ operator \ bar \ test \journal\live) 中以16进制打印dest的同名文件中 : 00000000.1.journal on_operator_state_change ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **订阅的算子器状态变化回调** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - context - python对象 - 策略的全局变量，通过点标记（”.”）来获取其属性 * - operator_state_update - :ref:`OperatorStateUpdate对象 ` - 订阅的其他算子器的状态信息 * - location - :ref:`Location对象 ` - 数据的来源是来自哪个进程 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def on_operator_state_change(context, operator_state_update, location): context.log.info("on_operator_state_change {}".format(operator_state_update)) 行情交易函数 ~~~~~~~~~~~~~~ context.add_account ^^^^^^^^^^^^^^^^^^^^^^^^^ **添加交易柜台，策略需要先添加账户，才能使用该账户报单** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - source - str - 行情柜台ID * - account - str - 账户ID 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: # 添加柜台、账户 context.add_account(source, account) # 例如 : 添加账户为123456的xtp柜台 # context.add_account("xtp", "123456") context.subscribe ^^^^^^^^^^^^^^^^^^^^^^^^^ **订阅行情(支持动态订阅)** 注意 : 在pre_start中订阅,策略持仓中此标的的持仓信息会与账户持仓中此标的的持仓信息同步 在非pre_start中订阅,策略中的此标的持仓信息只维护本策略中的. 比如 : 账户中有 “600000” , “600008” 标的持仓 , 持仓分别为500 , 600. 在策略的pre_start订阅 “600000” , post_start中订阅”600008”.运行策略 , 分别下单买入100 , 那么 策略持仓中的标的 “600000” , “600008” 持仓信息分别为 : 600 , 100 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - source - str - 行情柜台ID * - instrument - list - 代码列表 * - exchange_id - :ref:`Exchange对象 ` - 交易所ID 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: # 向source柜台的exchange_id交易所订阅了instruments列表中的合约的行情 context.subscribe(source, instruments, exchange_id) # 例如 : 在行情源柜台为xtp柜台订阅上交所的 600001,600002这两支股票 # context.subscribe("xtp", ['600001','600002'], "SSE") context.subscribe_operator ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **订阅算子器/bar数据** 注意 : 注意 :算子器的 group 默认为 'default' ； bar数据的 group 为 'bar' 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - group - str - 组名 * - name - str - 名字ID 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: context.subscribe_operator(group, name) # 例如 : 订阅算子id为test的算子器 # context.subscribe_operator("default", "test") # 例如 : 订阅Bar_id为 bar1 的bar数据 # context.subscribe_operator("bar", "bar1") context.subscribe_all ^^^^^^^^^^^^^^^^^^^^^^^^^ **订阅全市场行情** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - source - str - 行情柜台ID 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: # 订阅source柜台全市场标的 context.subscribe_all(source) # 例如 xtp的全市场股票 # context.subscribe_all("xtp") context.req_history_order ^^^^^^^^^^^^^^^^^^^^^^^^^ **查询当天历史委托数据** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - source - str - 行情柜台ID * - account - str - 交易账户 * - num - int - 本次查询数量(不填,返回本次查询最大值) 注意 : num 这个参数只对某些有限制的柜台起效, 对无限制的柜台, 直接查全部的 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def post_start(context): context.req_history_order(source,account,100) context.req_history_trade ^^^^^^^^^^^^^^^^^^^^^^^^^ **查询当天历史成交数据** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - source - str - 行情柜台ID * - account - str - 交易账户 * - num - int - 本次查询数量(不填,返回本次查询最大值) 注意 : num 这个参数只对某些有限制的柜台起效, 对无限制的柜台, 直接查全部的 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: def post_start(context): context.req_history_trade(source,account,100) context.insert_order ^^^^^^^^^^^^^^^^^^^^^^^^^ **报单函数** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - source_id - str - 柜台ID * - account_id - str - 交易账号 * - limit_price - float - 价格 * - volume - int - 数量 * - priceType - :ref:`PriceType ` - 报单类型 * - side - :ref:`Side ` - 买卖方向 * - offset - :ref:`Offset ` - 开平方向 * - hedgeFlag - :ref:`HedgeFlag ` - 投机套保标识 (选填) * - is_swap - :ref:`is_swap ` - 互换单 (选填,默认为False) * - block_id - int - 大宗交易信息 （不填，默认为0） * - parent_id - int - 母单号 （不填，默认为0） 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - order_id - long - 订单ID 范例 - 通过"xtp"柜台的交易账户acc_1以12.0元的价格买200股浦发银行: :: context.insert_order("600000", Exchange.SSE, "xtp","acc_1", 12.0, 200, PriceType.Limit, Side.Buy, Offset.Open) - 通过"ctp"柜台的交易账户acc_2以3500元的价格开仓买入2手上期所rb1906合约： :: context.insert_order("rb1906", Exchange.SHFE, "ctp","acc_2", 3500.0, 2, PriceType.Limit, Side.Buy, Offset.Open) **注（期权）：当买卖方向为：Lock（锁仓）、Unlock（解锁）、Exec（行权）、Drop（放弃行权）时，设定的price（委托价）以及offset（开平方向）都不生效** context.cancel_order ^^^^^^^^^^^^^^^^^^^^^^^^^ **撤单函数** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - order_id - long - 订单ID 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - action_id - long - 订单操作 范例:: # 通过context.insert_order函数进行下单，同时用order_id记录下单的订单ID号，然后撤单 order_id = context.insert_order(quote.instrument_id, exchange, source,account, quote.last_price, volume, PriceType.Limit, Side.Buy, Offset.Open) action_id = context.cancel_order(order_id) 投资组合相关功能 ~~~~~~~~~~~~~~~~~~~~~ 策略持仓维护相关 ^^^^^^^^^^^^^^^^^^^^^^^^^ 功夫系统支持实时维护策略收益及持仓及对应的历史记录，针对不同的应用场景，提供共计四种不同的维护收益及持仓的模式。对于任一策略，具体采用的模式由两个 API 决定：context.hold_book() 及 context.hold_positions()，使用者需要在策略的 pre_start() 方法里决定是否调用这两个方法，系统在 pre_start() 处理完成时会根据是否调用这两个方法对应出的共计四种状态来设置维护收益及持仓的结果。 context.hold_book() +++++++++++++++++++++ **保持策略运行历史上的交易过的标的。缺省设置即没有调用此方法时，系统只会维护当前策略代码中通过 subscribe 方法订阅过的标的；当调用此方法后，系统会在策略启动后，根据该同名策略在历史上的交易情况，构造一份包含所有该同名策略所交易过标的，及当前策略代码中通过 subscribe 订阅的标的的账目。注意此方法仅影响标的列表，对于每个标的的具体持仓数值，是由 hold_positions() 方法来决定。** 范例:: # 历史曾执行过订阅某些标的 # context.subscribe(source, ['600000', '600001'], EXCHANGE) # 当前代码中重置了 subscribe，且没有调用 context.hold_book()，则该策略只会收到新订阅的标的行情，且账目收益及持仓中只包含新订阅的标的 context.subscribe(source, ['600002', '600003'], EXCHANGE) # 如果调用 hold_book，则该策略订阅行情列表中会自动包含历史记录中有的标的 #，且账目收益及持仓中也会包含对应标的的数据 context.hold_book() context.hold_positions() ++++++++++++++++++++++++++++++ **保持账目中每一标的的历史持仓。缺省设置即没有调用此方法时，系统会通过同步柜台查询到的持仓数据来构建策略账目，每次策略启动后，账目中所有标的的持仓都会同步为最新的柜台账户对应的持仓；当调用此方法后，系统会使用功夫内部记录的历史数据来恢复策略的账目持仓。缺省设置保证了策略账目中的持仓数据是绝对准确的，但无法反映功夫运行期间内的策略历史交易情况；如果需要获取之前运行策略时产生的历史持仓记录，则需要通过调用该方法来使系统使用本地存储的历史记录，在这种情况下，当因为各种因素（例如在功夫系统外使用别的软件对同一账户手动交易）都会使得功夫内部维护的持仓记录产生偏差，（例如同一账户下对应的不同策略持仓汇总之和不等于账户总持仓），当发生此类偏差时，建议使用缺省模式来从账户持仓恢复策略持仓。** 范例:: # 策略账目所包含的持仓标的列表取决于是否调用context.hold_book()，但每个标的的具体持仓数值则由context.hold_positions()来决定， # 当缺省即没有调用该方法时，策略启动后的账目中的标的持仓等于所对应账户下的标的持仓： context.subscribe(source, ['600000', '600001'], EXCHANGE) # 当调用 hold_positions() 方法后，策略启动后的账目中标的持仓等于上次运行策略结束时所对应的标的持仓： context.hold_positions() Utils 状态判断 ^^^^^^^^^^^^^^^^^^^^^^^^^ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - hash_instrument - long - 获取账户中某个标的信息对应的key值 * - is_valid_price - bool - 判断当前价格是否为有效价格 * - is_final_status - bool - 判断当前状态是否为最终状态 * - get_instrument_type - :ref:`InstrumentType ` - 获取类型 Utils范例:: # hash_instrument 案例示范 from pykungfu import wingchun as wc # 1. 获取某个可交易标的信息对应的key值 wc.utils.hash_instrument(exchange_id, instrument_id) instrument_key = wc.utils.hash_instrument("SHFE", "rb2405") instrument = context.get_account_book(source,account).instruments[instrument_key] context.log.info("instrument {}".format(instrument)) # 2. 获取某个标的持仓信息对应的key值 wc.utils.hash_instrument(account_uid, exchange_id, instrument_id) account_uid = context.get_account_uid(source, account) position_key = wc.utils.hash_instrument(account_uid, "SHFE", "au2404") position = context.get_account_book(source,account).long_positions[position_key] context.log.info("position {}".format(position)) # 3. 获取某个标的保证金信息对应的key值 wc.utils.hash_instrument(account_uid, exchange_id, instrument_id) account_uid = context.get_account_uid(source, account) instrument_factor_key = wc.utils.hash_instrument(account_uid, "SHFE", "ag2401") instrument_factor = context.get_account_book(source,account).instrument_factors[instrument_factor_key] context.log.info("instrument_factor {}".format(instrument_factor)) # 其他案例示范 def on_quote(context, quote, location,dest): is_valid_price = wc.utils.is_valid_price(quote.last_price) context.log.warning("当前价格是否为有效价格 {}".format(is_valid_price)) def on_order(context, order, location,dest): is_valid_status = wc.utils.is_final_status(order.status) context.log.warning("当前状态是否为最终状态 {}".format(is_valid_status)) def post_start(context): ticker_instrument_type = wc.utils.get_instrument_type("SSE", "600000") context.log.warning("标的的合约类型是 {}".format(ticker_instrument_type)) 投资组合相关 ^^^^^^^^^^^^^^^^^^^^^^^^^ context.book ++++++++++++++++++ **策略的投资组合** (当前策略的投资组合信息) .. list-table:: :width: 600px * - 类型 * - :ref:`book对象 ` 范例:: #获取策略的投资组合，并打印相关参数 book = context.book context.log.warning("[strategy capital] (avail){} (margin){}".format(book.asset.avail, book.asset.margin)) context.get_account_book(SOURCE, ACCOUNT) +++++++++++++++++++++++++++++++++++++++++++++++ **账户的投资组合** (获取填写的这个柜台的账户的持仓,账户资金等信息) .. list-table:: :width: 600px * - 类型 * - :ref:`book对象 ` 范例:: #获取账户的投资组合，并打印相关参数 book = context.get_account_book(SOURCE, ACCOUNT) context.log.warning("[account capital] (avail){} (margin){} ".format(book.asset.avail, book.asset.margin)) .. _book对象: 使用方法 ++++++++++++++++++++++ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - asset - :ref:`asset ` - 投资组合资金信息 * - commissions - :ref:`Commission ` - 获取佣金信息 * - instruments - :ref:`Instrument ` - 获取当日可交易标的信息 * - instrument_factors - :ref:`InstrumentFactor ` - 获取账户保证金信息 * - long_positions - :ref:`Position ` - 投资组合的持仓列表，对应多头仓位 * - short_positions - :ref:`Position ` - 投资组合的持仓列表，对应空头仓位 * - orders - :ref:`Order ` - 获取订单委托信息 * - trades - :ref:`Trade ` - 获取订单成交信息 * - order_inputs - :ref:`OrderInput ` - 获取订单输出信息 * - has_long_position - bool - 判断是否为多头仓位 * - has_short_position - bool - 判断是否为空头仓位 * - get_long_position - dict - 多头持仓信息 * - get_short_position - dict - 空头持仓信息 注意 :: 1. 对于 context.book 来说 1). orders 是获取跟该策略本身相关的所有委托，这个“所有委托”，包含了不同账户的委托信息 2). trades 是获取跟该策略本身相关的所有成交，这个“所有成交”，包含了不同账户的成交信息 3). order_inputs 是获取该策略本次的所有订单输出，这个“所有订单输出”，包含了不同账户的订单输出信息 2. 对于 context.get_account_book(source, account) 来说 1). orders 是获取目标账户的所有委托信息 2). trades 是获取目标账户的所有成交信息 3). order_inputs 是获取目标账户在本次策略中的订单输出信息 获取投资组合持仓列表范例:: def post_start(context): context.log.warning("post_start") context.account_book = context.get_account_book(SOURCE, ACCOUNT) book = context.book context.log.warning("资金组合信息 {}".format(context.account_book.asset)) # 账户中多头持仓数据 long_position = context.account_book.long_positions for key in long_position: pos = long_position[key] context.log.info("多头持仓数据 (instrument_id){} (volume){} (yesterday_volume){} ".format(pos.instrument_id,pos.volume,pos.yesterday_volume)) # 账户中空头持仓数据 short_position = context.account_book.short_positions for key in short_position: pos = short_position[key] context.log.info("空头持仓数据 (instrument_id){} (volume){} (yesterday_volume){} ".format(pos.instrument_id,pos.volume,pos.yesterday_volume)) # 获取佣金信息 commission = context.account_book.commissions for key in commission: pos = commission[key] context.log.info( "佣金信息 product_id {}，exchange_id {} ,open_ratio {} ".format(pos.product_id, pos.exchange_id, pos.open_ratio)) # 获取当日可交易标的信息 instrument = context.account_book.instruments for key in instrument: pos = instrument[key] context.log.info( "当日可交易标的信息 instrument_id {} , exchange_id {}".format(pos.instrument_id, pos.exchange_id)) # 获取账户保证金信息 instrument_factor = context.account_book.instrument_factors for key in instrument_factor: pos = instrument_factor[key] context.log.info( "获取账户保证金信息 {} ".format(pos)) # 获取策略所有委托信息 book_order = book.orders for key in book_order: pos = book_order[key] context.log.info("book orders order_id {} ".format(pos.order_id)) # 获取策略所有成交信息 book_trade = book.trades for key in book_trade: pos = book_trade[key] context.log.info("book trades trade_id {} ".format(pos.trade_id)) # 获取策略本次订单输出信息 book_order_input = book.order_inputs for key in book_order_input: pos = book_order_input[key] context.log.info("book order_inputs order_id {} ".format(pos.order_id)) # 获取账户所有委托信息 account_order = context.account_book.orders for key in account_order: pos = account_order[key] context.log.info("account orders order_id {} ".format(pos.order_id)) # 获取账户所有成交信息 account_trade = context.account_book.trades for key in account_trade: pos = account_trade[key] context.log.info("account trades trade_id {} ".format(pos.trade_id)) # 获取账户在本次策略中的订单输出信息 account_order_input = context.account_book.order_inputs for key in account_order_input: pos = account_order_input[key] context.log.info("account order_inputs order_id {} ".format(pos.order_id)) # 判断是否为多头仓位 context.log.warning("判断是否为多头仓位 {}".format(context.account_book.has_long_position(SOURCE, ACCOUNT,"SSE", "600000"))) # 判断是否为空头仓位 context.log.warning("判断是否为空头仓位 {}".format(context.account_book.has_short_position(SOURCE, ACCOUNT,"SHFE", "ag2212"))) # 多头标的持仓信息 context.log.warning("多头标的持仓信息 {}".format(context.account_book.get_long_position(SOURCE, ACCOUNT,"SSE", "600000"))) # 空头标的持仓信息 context.log.warning("空头标的持仓信息 {}".format(context.account_book.get_short_position(SOURCE, ACCOUNT,"SHFE", "ag2212"))) 静态数据信息 ^^^^^^^^^^^^^^^^^^^^^^^^^ context.static_data ++++++++++++++++++++++++ **静态数据信息获取** .. list-table:: :width: 600px * - 类型 * - :ref:`static_data对象 ` 范例:: #获取静态数据 static_data = context.static_data .. _static_data对象: 使用方法 ++++++++++++++++++++++ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - commissions - :ref:`Commission ` - 获取佣金信息 * - instruments - :ref:`Instrument ` - 获取当日可交易标的信息 * - instrument_factors - :ref:`InstrumentFactor ` - 获取账户保证金信息 范例:: # 获取佣金信息 static_data_commissions = context.static_data.commissions for key in static_data_commissions: pos = static_data_commissions[key] context.log.info("static_data 当日可交易标的佣金信息 品种 {} , 交易所 {} , 开仓费率 {}".format(pos.product_id, pos.exchange_id, pos.open_ratio)) # 获取可交易标的信息 static_data_instrument = context.static_data.instruments for key in static_data_instrument: pos = static_data_instrument[key] context.log.info( "static_data 当日可交易标的信息 标的 {} , 交易所 {}".format(pos.instrument_id, pos.exchange_id)) # 获取保证金信息 static_data_instrument_factors = context.static_data.instrument_factors for key in static_data_instrument_factors: pos = static_data_instrument_factors[key] context.log.info( "static_data 获取保证金信息 标的 {} , 交易所 {} , 多头保证金率".format(pos.instrument_id, pos.exchange_id, pos.long_margin_ratio)) Orderbook 重建订单簿 ^^^^^^^^^^^^^^^^^^^^^^^^^ .. note:: **重建订单簿有何用处？** - **1. 市场深度和流动性分析：** 重建订单簿可以展示不同价格水平上愿意买卖的订单数量，直观展示市场深度的。有助于评估市场的流动性，特定价格区间内能够吸收多少交易量而不会引起价格显著变动。了解市场深度对于制定交易策略和评估市场冲击成本至关重要。 - **2. 价格发现：** 订单簿中的买卖订单反映了市场参与者对未来价格的预期和需求。通过分析订单簿，更好地理解价格形成机制以预测价格走势。 - **3. 交易执行优化：** 在量化交易中，了解订单簿的状态可以帮助交易算法选择最佳的交易路径和价格，以最小化交易成本。例如，如果订单簿显示买方需求强劲，可考虑以略高于当前市场价格的价格买入，以提高成交概率。 - **4. 风险管理：** 通过监控订单簿的变化，可以及时发现潜在的市场异常或流动性枯竭情况，从而采取相应的风险控制措施。 .. list-table:: :width: 600px * - 属性 - 说明 * - get_bids - 获取买单信息 * - get_asks - 获取卖单信息 - **注意**： - 只有在行情源提供逐笔行情数据的情况下，才能准确地重建订单簿 - 将维护从策略开始到策略结束收到的所有逐笔数据 :: 订单簿维护规则详解 ( **只适用于Entrust 逐笔委托** ) : 当收到一笔新的逐笔数据时,检测当前数据的price和side 是否被记录过， 1). 若当前数据的价格档位不存在，则将当前数据的volume增加到对应价格档位的volume中 2). 若当前数据的价格档位已存在。将根据以下规则更新订单簿 : a. 如果当前数据方向（side）为买, 比较当前price和买1价, 如果小于买1价, 直接存储; 进一步与最低要价（卖1价）比较，若大于卖一价则撮合成交。 b. 如果当前数据方向（side）为卖, 比较当前price和卖1价, 如果大于买1价, 直接存储; 进一步与最高出价（买1价）比较，若小于买一价则撮合成交。 c. 如果产生撮合且新数据的volume小于买1/卖1单的volume, 此时买1/卖1单的volume会扣除对应数量; 如果大于买/卖单的volume, 原买1单/卖1单的price档位会被消除 ,然后继续和新的买1价(原买2价)和卖1价(原卖2价)进行判断是否会和当前数据发生撮合,如果继续撮合则重复本条逻辑。如果未发生撮合，就把对应的价格和剩余的volume存到买单或者卖单里。 d. 撮合规则 : 新数据为买入方向: 新数据的price >= 卖1价 则触发撮合 ; 新数据为卖出方向: 新数据的price <= 买1价 则触发撮合。 e. 卖1价 : 当前已存储的卖单信息, 按照价格由低到高排列, 卖1价为当前卖单信息的最低价格 f. 买1价 : 当前已存储的买单信息, 按照价格由高到低排列, 买1价为当前买单信息的最高价格 3). 撤单处理: 只有当Transaction的exex_type（成交类型）为Cancel时,买单或卖单才会根据bid_no或者ask_no 减去对应price的volume, 其他类型的Transaction数据不会被处理 示例代码↓:: # 案例示范 from pykungfu import wingchun as wc def pre_start(context): context.subscribe("xtp", ["600000"], "SSE") context.depth_orderbook = wc.DepthOrderbooks() context.attach_orderbooks(context.depth_orderbook) def on_entrust(context, entrust, location, dest): context.log.info('[逐笔委托 entrust] {}'.format(entrust)) bids = context.depth_orderbook.get_bids("600000", "SSE") for level in bids: context.log.warning('[entrust bids 买单信息] {}'.format(level)) asks = context.depth_orderbook.get_asks("600000", "SSE") for level in asks: context.log.warning('[entrust asks 卖单信息] {}'.format(level)) def on_transaction(context, transaction, location, dest): context.log.info('[逐笔成交 on_transaction] {}'.format(transaction)) bids = context.depth_orderbook.get_bids("600000", "SSE") for level in bids: context.log.warning('[transaction bids 买单信息] {}'.format(level)) asks = context.depth_orderbook.get_asks("600000", "SSE") for level in asks: context.log.warning('[transaction asks 卖单信息] {}'.format(level)) .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - data_time - int - 数据生成时间(交易所时间) * - price - float - 价格 * - volume - int - 数量 辅助函数 ~~~~~~~~~~~~~~~~~~~~~ context.log.info ^^^^^^^^^^^^^^^^^^^^^^^^^ **输出INFO级别 Log 信息** .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - msg - str - Log信息 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: context.log.info(msg) context.log.warning ^^^^^^^^^^^^^^^^^^^^^^^^^ **输出WARN级别Log信息** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - msg - str - Log信息 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: context.log.warning(msg) context.log.error ^^^^^^^^^^^^^^^^^^^^^^^^^ **输出ERROR级别Log信息** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - msg - str - Log信息 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: context.log.error(msg) context.strftime() ^^^^^^^^^^^^^^^^^^^^^^^^^ **时间格式转换 ： 将纳秒级时间戳时间转换成文本时间** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - msg - int - 时间戳时间 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: context.log.info(" 当前时间是 {} 纳秒".format(context.now())) # 当前时间是 1669344957395751800 纳秒 context.log.info(" 当前时间转换为 文本类型时间 ： {} ".format(context.strftime(context.now()))) # 当前时间转换为 文本类型时间 ： 2022-11-25 10:55:57.395751800 context.strptime() ^^^^^^^^^^^^^^^^^^^^^^^^^ **时间格式转换 ： 将文本时间转换成纳秒级时间戳时间** 注意 ： 文本字符串必须是 "%Y-%m-%d %H:%M:%S." 的格式，注意最后有一个英文句点（.）不要漏掉了 。 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - msg - str - 文本格式时间 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: context.log.info(" 文本时间转换为时间戳 : {} ".format(context.strptime("2022-11-25 11:04:01."))) # 文本时间转换为时间戳 : 1669345441000000000 context.add_timer ^^^^^^^^^^^^^^^^^^^^^^^^^ **注册时间回调函数** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - nano - long - 触发回调的纳秒时间戳 * - callback - object - 回调函数 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: # 通过时间回调函数，在1s后撤去订单号为order_id的报单 context.add_timer(context.now() + 1*1000000000, lambda ctx, event: cancel_order(ctx, order_id)) context.add_time_interval ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **时间间隔回调函数** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - nano - long - 触发回调的纳秒时间戳 * - callback - object - 回调函数 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: # 通过时间间隔回调函数，每过60s,调用一次func函数 context.add_time_interval(60 * 1000000000, lambda ctx, event: func(ctx)) context.clear_timer() ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **取消定时器** 参数 .. list-table:: :width: 600px * - 参数 - 类型 - 说明 * - timer_id - int - 时间回调函数ID 返回 .. list-table:: :width: 600px * - 返回 - 类型 - 说明 * - 无 - 无 - 无 范例:: # 通过时间间隔回调函数，每过60s,调用一次func函数 timer_id = context.add_time_interval(60 * 1000000000, lambda ctx, event: func(ctx)) # 取消这个时间回调函数 context.clear_timer(timer_id) context.req_deregister() ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ **关闭策略进程** 范例:: # 执行 context.req_deregister() 关闭策略进程 context.req_deregister() 枚举值(enums) ---------------- Source柜台 ~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 值 - 说明 * - CTP - “ctp“ - CTP柜台 * - XTP - “xtp“ - XTP柜台 * - SIM - “sim“ - SIM柜台 柜台使用方法:: # 案例示范 from kungfu.wingchun.constants import Source SOURCE = Source.XTP # SOURCE = "xtp" ACCOUNT = "1111111" def pre_start(context): # 添加账户柜台信息 context.add_account(SOURCE, ACCOUNT) .. _Exchange对象: Exchange交易所 ~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 值 - 说明 * - BSE - “BSE” - 北交所 (北京证券交易所) * - SSE - “SSE” - 上交所 (上海证券交易所) * - SZE - “SZE” - 深交所 (深圳证券交易所) * - SHFE - “SHFE” - 上期所 (上海期货交易所) * - DCE - “DCE” - 大商所 (大连商品交易所) * - CZCE - “CZCE” - 郑商所 (郑州商品交易所) * - CFFEX - “CFFEX” - 中金所 (中国金融期货交易所) * - INE - “INE” - 能源中心 (上海国际能源交易中心) * - GFEX - “GFEX” - 广期所（广州期货交易所） 交易所使用方法:: # 案例示范 from kungfu.wingchun.constants import Exchange tickers_sze = ['128145', '000700'] EXCHANGE_SZE = Exchange.SZE tickers_sse = ['688689', '688321'] EXCHANGE_SSE = Exchange.SSE def pre_start(context): # 订阅某些深交所股票的行情 context.subscribe(SOURCE, tickers_sze, EXCHANGE_SZE) # 订阅某些上交所股票的行情 context.subscribe(SOURCE, tickers_sse, EXCHANGE_SSE) .. _InstrumentType对象: InstrumentType 代码类型 ~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Unknown - 未知 * - Stock - 股票 * - Future - 期货 * - Bond - 债券 * - StockOption - 股票期权 * - TechStock - 科技股 * - Fund - 基金 * - Index - 指数 * - Repo - 回购 * - CryptoFuture - 数字货币期货 * - CryptoUFuture - 数字货币期货U本位 * - Crypto - 数字货币 合约类型判断方法:: # 案例示范 from kungfu.wingchun.constants import InstrumentType positions = context.get_account_book(SOURCE, ACCOUNT) for key in positions.long_positions: pos = positions.long_positions[key] if pos.instrument_type == InstrumentType.Stock: context.log.info("这个ticker的合约类型是股票类型") elif pos.instrument_type == InstrumentType.Future: context.log.info("这个ticker的合约类型是期货类型") elif pos.instrument_type == InstrumentType.Bond: context.log.info("这个ticker的合约类型是债券类型") .. _PriceType对象: PriceType 报单类型 ~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Limit - 限价,通用 * - Any - 市价，通用，对于股票上海为最优五档剩余撤销，深圳为即时成交剩余撤销 * - FakBest5 - 上海深圳最优五档即时成交剩余撤销，不需要报价 * - ForwardBest - 仅深圳本方方最优价格申报, 不需要报价 * - ReverseBest - 上海最优五档即时成交剩余转限价，深圳对手方最优价格申报，不需要报价 * - Fak - 股票（仅深圳）即时成交剩余撤销，不需要报价；期货即时成交剩余撤销，需要报价 * - Fok - 股票（仅深圳）市价全额成交或者撤销，不需要报价；期货全部或撤销，需要报价 * - EnhancedLimit - 增强限价盘-港股 * - AtAuctionLimit - 增强限价盘-港股 * - AtAuction - 竞价盘-港股 , 期货(竞价盘的价格就是开市价格) 报单类型使用方法:: # 案例示范 from kungfu.wingchun.constants import PriceType, Side, Offset context.insert_order("600000", Exchange.SSE, "xtp","acc_1", 12.0, 200, PriceType.Limit, Side.Buy, Offset.Open) # 通过xtp柜台的交易账户acc_1以12.0元的限价价格买开200股浦发银行 .. _Side对象: Side 买卖 ~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Buy - 买 * - Sell - 卖 * - Lock - 锁仓 * - Unlock - 解锁 * - Exec - 行权 * - Drop - 放弃行权 * - Purchase - 申购 * - Redemption - 赎回 * - Split - 拆分 * - Merge - 合并 * - MarginTrade - 融资买入 * - ShortSell - 融券卖出 * - RepayMargin - 卖券还款 * - RepayStock - 买券还券 * - CashRepayMargin - 现金还款 * - StockRepayStock - 现券还券 * - SurplusStockTransfer - 余券划转 * - GuaranteeStockTransferIn - 担保品转入 * - GuaranteeStockTransferOut - 担保品转出 买卖方向使用方法:: # 案例示范 from kungfu.wingchun.constants import PriceType, Side, Offset context.insert_order("600000", Exchange.SSE, "xtp","acc_1", 12.0, 200, PriceType.Limit, Side.Buy, Offset.Open) # 通过xtp柜台的交易账户acc_1以12.0元的限价价格买开200股浦发银行 .. _Offset对象: Offset 开平 ~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Open - 开 * - Close - 平 * - CloseToday - 平今 * - CloseYesterday - 平昨 买卖方向使用方法:: # 案例示范 from kungfu.wingchun.constants import PriceType, Side, Offset context.insert_order("600000", Exchange.SSE, "xtp", "acc_1", 12.0, 200, PriceType.Limit, Side.Buy, Offset.Open) # 通过xtp柜台的交易账户acc_1以12.0元的限价价格买开200股浦发银行 .. _HedgeFlag对象: HedgeFlag 投机套保标识 ~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Speculation - 投机 **注意 : Python策略中insert_order可以不写这个参数,因为已经默认是投机.c++策略中需要填写** .. _IsSwap对象: IsSwap 是否为互换单 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - true - 互换单 * - false - 不是互换单 .. _Direction对象: Direction 多空 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Long - 多 * - Short - 空 持仓方向使用方法:: # 案例示范 from kungfu.wingchun.constants import Direction positions = context.get_account_book(SOURCE, ACCOUNT) for key in positions.long_positions: pos = positions.long_positions[key] if pos.direction == Direction .Long: context.log.info("这个ticker的持仓方向 : 多") elif pos.direction == Direction .Short: context.log.info("这个ticker的持仓方向 : 空") .. _OrderStatus对象: OrderStatus 委托状态 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Unknown - 未知 * - Submitted - 已提交 * - Pending - 等待 * - Cancelled - 已撤单 * - Error - 错误 * - Filled - 已成交 * - PartialFilledNotActive - 部成部撤 * - PartialFilledActive - 部成交易中 * - Lost - 丢失 * - Cancelling - 待撤 * - Pause - 暂停 订单状态获取:: # 案例示范 from kungfu.wingchun.constants import OrderStatus def on_order(context, order): if order.status == OrderStatus.Submitted: context.log.warning("此时的订单状态为 : 已提交") elif order.status == OrderStatus.Pending: context.log.warning("此时的订单状态为 : 等待中") elif order.status == OrderStatus.Filled: context.log.warning("此时的订单状态为 : 已成交") .. _ExecType对象: ExecType 标识 ~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Unknown - 未知 * - Cancel - 撤单 * - Trade - 成交 .. _BsFlag对象: BsFlag 标识 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Unknown - 未知 * - Buy - 买 * - Sell - 卖 .. _LedgerCategory对象: LedgerCategory 标识 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Account - 账户投资组合数据 * - Strategy - 策略投资组合数据 .. _VolumeCondition对象: VolumeCondition 标识 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Any - 任何 * - Min - 最小 * - All - 所有 .. _TimeCondition对象: TimeCondition 标识 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - IOC - 立刻成交，否则撤销 * - GFD - 当日有效 * - GTC - 撤单前有效 * - GFS - 本节有效 * - GTD - 指定日期前有效 * - GFA - 集合竞价有效 * - Unknown - 未知 .. _Location对象: Location 标识 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - mode - 交易规则(目前只支持 LIVE,实时交易) * - category - 类别(TD/MD) (这条数据的来源是 td还是md) * - group - 柜台id (比如 : xtp , ctp , sim) * - name - 对于交易进程(如:on_order,on_trade)是账户名(比如: 123456, 123321 ) , 对于行情进程(如:on_quote)是柜台id (比如: xtp , sim) * - uid - mode/category/group/name 组成的字符串的哈希值 * - uname - location的整体信息 (比如 : td/sim/123/live (数据来源是td , 柜台是sim柜台 , 账号是 123 , 交易规则是实时交易) ) 例子:: def on_order(context, order, location): context.log.info( "[location] mode{}, category {}, group {}, name {}, uid{}, uname {}".format( location.mode, location.category, location.group, location.name, location.uid, location.uname)) .. _CommissionRateMode对象: CommissionRateMode 手续费模式 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - ByAmount - 交易额 * - ByVolume - 交易量 .. _BrokerState对象: BrokerState 进程连接状态 ~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Pending - 等待中 * - Idle - 无数据 * - DisConnected - 已断开 * - Connected - 已连接 * - LoggedIn - 已登录 * - LoginFailed - 登录失败 * - Ready - 就绪 注意 : Idle只有行情模块有, 连续15秒没有数据就会把前端行情状态设置为Idle, 只在前端显示不通知到策略 .. _OperatorState对象: OperatorState 连接状态 ~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Pending - 等待中 * - DisConnected - 已断开 * - ErrConnectedor - 错误连接 * - Ready - 就绪 .. _HistoryDataType对象: HistoryDataType 标识 ~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Normal - 进行 * - PageEnd - 本页结束 * - TotalEnd - 全部结束 .. _Currency对象: Currency 币种 ~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 说明 * - Unknown - 未知 * - CNY - 人民币 * - HKD - 港币 * - USD - 美元 * - JPY - 日元 * - GBP - 英镑 * - EUR - 欧元 * - CNH - 离岸人民币 * - SGD - 新加坡币 * - MYR - 马来西亚币 * - CEN - 美分 数据结构 ----------- .. _Quote对象: Quote 行情信息 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - data_time - int - 数据生成时间(交易所时间) * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - pre_close_price - float - 昨收价 * - pre_settlement_price - float - 昨结价 * - last_price - float - 最新价 * - volume - float - 数量 * - turnover - float - 成交金额 * - pre_open_interest - float - 昨持仓量 * - open_interest - float - 持仓量 * - open_price - float - 今开盘 * - high_price - float - 最高价 * - low_price - float - 最低价 * - upper_limit_price - float - 涨停板价 * - lower_limit_price - float - 跌停板价 * - close_price - float - 收盘价 * - settlement_price - float - 结算价 * - iopv - float - 基金实时参考净值 * - total_bid_volume - float - 总委托买入量 * - total_ask_volume - float - 总委托卖出量 * - total_trade_num - float - 总成交笔数 * - bid_price - list of float - 申买价 * - ask_price - list of float - 申卖价 * - bid_volume - list of float - 申买量 * - ask_volume - list of float - 申卖量 .. _Entrust对象: Entrust 逐笔委托 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - data_time - int - 数据生成时间(交易所时间) * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - price - float - 委托价格 * - volume - float - 委托量 * - side - :ref:`Side ` - 委托方向 * - price_type - :ref:`PriceType ` - 订单价格类型（市价、限价、本方最优） * - main_seq - long - 主序号 * - seq - long - 子序号 * - orig_order_no - int - 原始订单号 上海为原始订单号, 深圳为索引号 * - biz_index - int - 业务序号 .. _Transaction对象: Transaction 逐笔成交 ~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - data_time - int - 数据生成时间(交易所时间) * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - price - float - 成交价 * - volume - float - 成交量 * - bid_no - long - 买方订单号 * - ask_no - long - 卖方订单号 * - exec_type - :ref:`ExecType ` - SZ: 成交标识 * - side - :ref:`Side ` - 买卖方向 * - main_seq - long - 主序号 * - seq - long - 子序号 * - biz_index - int - 业务序号 .. _Order对象: Order 订单回报 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - order_id - int - 订单ID * - external_order_id - str - 柜台订单ID * - parent_id - int - 母单号 * - insert_time - int - 订单写入时间(功夫时间) * - update_time - int - 订单更新时间(功夫时间) * - trading_day - int - 交易日 * - restore_time - int - 恢复时间(用于重启td后恢复交易数据的时间戳) * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - contract_id - str - 两融合约唯一标识 * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - limit_price - float - 价格 * - frozen_price - float - 冻结价格（市价单冻结价格为0.0） * - volume - float - 数量 * - volume_left - float - 剩余数量 * - tax - float - 税 * - commission - float - 手续费 * - status - :ref:`OrderStatus ` - 订单状态 * - error_id - int - 错误ID * - error_msg - str - 错误信息 * - is_swap - bool - 互换单 * - side - :ref:`Side ` - 买卖方向 * - offset - :ref:`Offset ` - 开平方向 * - hedge_flag - :ref:`HedgeFlag ` - 投机套保标识 * - price_type - :ref:`PriceType ` - 价格类型 * - volume_condition - :ref:`VolumeCondition ` - 成交量类型 * - time_condition - :ref:`TimeCondition ` - 成交时间类型 .. _Trade对象: Trade 订单成交 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - trade_id - int - 成交ID * - parent_order_id - int - 母单号 * - external_order_id - str - 柜台订单ID * - external_trade_id - str - 柜台成交编号ID * - order_id - int - 订单ID * - trade_time - int - 成交时间(功夫时间) * - trading_day - int - 交易日 * - restore_time - int - 恢复时间(用于重启td后恢复交易数据的时间戳) * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - contract_id - str - 两融合约唯一标识 * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - side - :ref:`Side ` - 买卖方向 * - offset - :ref:`Offset ` - 开平方向 * - hedge_flag - :ref:`HedgeFlag ` - 投机套保标识 * - price - float - 成交价格 * - volume - float - 成交量 * - tax - float - 税 * - commission - float - 手续费 .. _HistoryOrder对象: HistoryOrder 历史订单 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - order_id - long - 订单ID * - insert_time - long - 订单写入时间(功夫时间) * - update_time - long - 订单更新时间(功夫时间) * - trading_day - int - 交易日 * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - external_order_id - str - 柜台订单ID * - contract_id - str - 两融合约唯一标识 * - is_last - bool - 是否为本次查询的最后一条记录 * - data_type - :ref:`HistoryDataType ` - 标记本数据是正常数据, 还是本页最后一条数据, 或者全部数据的最后一条 * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - limit_price - float - 价格 * - frozen_price - float - 冻结价格（市价单冻结价格为0.0） * - volume - float - 数量 * - volume_left - float - 剩余数量 * - tax - float - 税 * - commission - float - 手续费 * - status - :ref:`OrderStatus ` - 订单状态 * - error_id - int - 错误ID * - error_msg - str - 错误信息 * - is_swap - bool - 互换单 * - side - :ref:`Side ` - 买卖方向 * - offset - :ref:`Offset ` - 开平方向 * - hedge_flag - :ref:`HedgeFlag ` - 投机套保标识 * - price_type - :ref:`PriceType ` - 价格类型 * - volume_condition - :ref:`VolumeCondition ` - 成交量类型 * - time_condition - :ref:`TimeCondition ` - 成交时间类型 .. _HistoryTrade对象: HistoryTrade 历史成交 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - trade_id - long - 成交ID * - order_id - long - 订单ID * - trade_time - long - 成交时间(功夫时间) * - trading_day - int - 交易日 * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - external_order_id - str - 柜台订单ID * - contract_id - str - 两融合约唯一标识 * - external_trade_id - str - 柜台成交编号ID * - is_last - bool - 是否为本次查询的最后一条记录 * - data_type - :ref:`HistoryDataType ` - 标记本数据是正常数据, 还是本页最后一条数据, 或者全部数据的最后一条 * - is_withdraw - bool - 是否是撤单流水 * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - side - :ref:`Side ` - 买卖方向 * - offset - :ref:`Offset ` - 开平方向 * - hedge_flag - :ref:`HedgeFlag ` - 投机套保标识 * - price - float - 成交价格 * - volume - float - 成交量 * - close_today_volume - float - 平今日仓量（期货） * - tax - float - 税 * - commission - float - 手续费 * - error_id - int - 错误ID * - error_msg - str - 错误信息 .. _OrderInput对象: OrderInput 订单输出 ~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - order_id - int - 订单ID * - parent_id - int - 母单号 * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - contract_id - str - 两融合约唯一标识 * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - limit_price - float - 价格 * - frozen_price - float - 冻结价格 * - volume - float - 数量 * - is_swap - bool - 互换单 * - side - :ref:`Side ` - 买卖方向 * - offset - :ref:`Offset ` - 开平方向 * - hedge_flag - :ref:`HedgeFlag ` - 投机套保标识 * - price_type - :ref:`PriceType ` - 价格类型 * - volume_condition - :ref:`VolumeCondition ` - 成交量类型 * - time_condition - :ref:`TimeCondition ` - 成交时间类型 * - block_id - int - 大宗交易信息id, 非大宗交易则为0 * - insert_time - int - 订单写入时间(功夫时间) .. _RequestHistoryOrderError对象: RequestHistoryOrderError 历史订单查询报错信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - error_id - int - 错误ID * - error_msg - str - 错误信息 * - trigger_time - int - 写入时间 .. _RequestHistoryTradeError对象: RequestHistoryTradeError 历史成交查询报错信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - error_id - int - 错误ID * - error_msg - str - 错误信息 * - trigger_time - int - 写入时间 .. _OrderActionError对象: OrderActionError 撤单报错信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - order_id - int - 订单ID * - external_order_id - str - 撤单原委托柜台订单ID, 新生成撤单委托编号不记录 * - order_action_id - int - 订单操作ID * - error_id - int - 错误ID * - error_msg - str - 错误信息 * - insert_time - int - 写入时间 .. _SyntheticData对象: SyntheticData 订阅的算子器返回数据 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - update_time - int - 更新时间 * - key - str - 订阅的算子器发布的标识 * - value - str - 订阅的算子器发布的内容 * - tag_a - str - 占位(目前没有用到) * - tag_b - str - 占位(目前没有用到) * - tag_c - str - 占位(目前没有用到) .. _OperatorStateUpdate对象: OperatorStateUpdate 订阅的其他算子器状态变化信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - state - :ref:`OperatorState ` - 连接状态 * - update_time - int - 更新时间 * - location_uid - int - mode/category/group/name 组成的字符串的哈希值 * - value - str - 内容 * - info_a - str - 占位(目前没有用到) * - info_b - str - 占位(目前没有用到) .. _Deregister对象: Deregister 断开回调信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - mode - enums - 交易规则(目前只支持 LIVE,实时交易) * - category - enums - 类别(TD/MD) (这条数据的来源是 td还是md) * - group - str - 柜台ID (比如 : xtp , ctp) * - name - str - 对于交易进程(如:on_order,on_trade)是账户名(比如: 123456, 123321 ) , 对于行情进程(如:on_quote)是柜台ID (比如: xtp , sim) * - location_uid - int - mode/category/group/name 组成的字符串的哈希值 例子:: def on_deregister(context, deregister, location): context.log.info( '[on_deregister] {}---{}---{}---{}--{}--{}'.format(deregister, deregister.mode, deregister.category, deregister.group, deregister.name,deregister.location_uid)) .. _BrokerStateUpdate对象: BrokerStateUpdate 客户端状态变化回调信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - location_uid - int - mode/category/group/name 组成的字符串的哈希值 * - state - :ref:`BrokerState ` - 进程连接状态 例子:: def on_broker_state_change(context, broker_state_update, location): context.log.info('[on_broker_state_change] {}--{}'.format(broker_state_update, broker_state_update.state)) **注意:功夫时间在最开始会以真实时间对时，然后根据cpu震动++，是个单调递增的时间，和真实时间是有差别的。交易所时间和本机时间也会有差别** .. _asset对象: asset 投资组合资金信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - update_time - int - 更新时间(功夫时间) * - holder_uid - int - 持有人ID * - ledger_category - :ref:`LedgerCategory ` - 账户类别 * - initial_equity - float - 期初权益 * - static_equity - float - 静态权益 * - dynamic_equity - float - 动态权益 * - realized_pnl - float - 累计收益 * - unrealized_pnl - float - 未实现盈亏 * - market_value - float - 市值 * - long_market_value - float - 融资买入证券市值 * - short_market_value - float - 融券卖出证券市值 * - margin - float - 保证金占用 * - long_margin - float - 融资占用保证金 * - short_margin - float - 融券占用保证金 * - accumulated_fee - float - 累计手续费 * - intraday_fee - float - 当日手续费 * - frozen_cash - float - 冻结资金(股票: 买入挂单资金, 期货: 冻结保证金+冻结手续费) * - frozen_margin - float - 冻结保证金(期货) * - frozen_fee - float - 冻结手续费(期货) * - position_pnl - float - 持仓盈亏(期货) * - close_pnl - float - 平仓盈亏(期货) * - avail - float - 可用资金 * - long_avail - float - otc业务可用资金(多) * - short_avail - float - otc业务可用资金(空) * - total_asset - float - 总资产 * - avail_margin - float - 可用保证金 * - long_debt - float - 融资负债 * - short_cash - float - 融券卖出金额 * - margin_interest - float - 融资融券利息 * - settlement - float - 融资融券清算资金 * - credit - float - 信贷额度 * - collateral_ratio - float - 担保比例 * - total_debt - float - 总负债 * - net_assets - float - 净资产 * - long_total_debt - float - 融资总负债（融资欠款+融资利息+融资费用） * - short_total_debt - float - 融券总负债（融券市值+融券利息+融券费用） * - gage_buy_fund_available - float - 担保品买入可用资金 * - credit_buy_fund_available - float - 融资融券可用资金 * - buyredeliver_fund_available - float - 买券还券可用资金 * - directrepay_fund_available - float - 现金还款可用资金 .. _Commission对象: Commission 佣金信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - product_id - str - 产品ID (品种) * - exchange_id - str - 交易所 * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - mode - :ref:`CommissionRateMode ` - 手续费模式(按照交易额或者交易量) * - open_ratio - float - 开仓费率 * - close_ratio - float - 平仓费率 * - close_today_ratio - float - 平仓费率 * - min_commission - float - 最小手续费 .. _Instrument对象: Instrument 当日可交易标的信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - instrument_id - str - 合约ID * - exchange_id - str - 交易所 * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - product_id - int - 产品ID (品种) * - contract_multiplier - int - 合约乘数 * - price_tick - float - 最小变动价位 * - quantity_unit - float - 最小数量单位 * - open_date - str - 上市日 * - create_date - str - 创建日 * - expire_date - str - 到期日 * - delivery_year - int - 交割年份 * - delivery_month - int - 交割月 * - currency - :ref:`Currency ` - 币种 .. _InstrumentFactor对象: InstrumentFactor 账户保证金信息 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - instrument_id - str - 合约ID * - exchange_id - str - 交易所ID * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - product_id - int - 产品ID (品种) * - source_id - int - 持仓账户 * - is_trading - bool - 当前是否交易 * - long_margin_ratio - float - 多头保证金率 * - short_margin_ratio - float - 空头保证金率 * - conversion_rate - float - 担保品折扣率 * - exchange_rate - float - 汇率 .. _Position对象: Position 持仓信息 ~~~~~~~~~~~~~~~~~~~~~ 期货持仓 .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - update_time - int - 更新时间(功夫时间) * - instrument_id - str - 合约ID * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - exchange_id - str - 交易所ID * - holder_uid - int - 持有人ID * - ledger_category - :ref:`LedgerCategory ` - 账户类别 * - direction - :ref:`Direction ` - 持仓方向 * - volume - float - 数量 * - yesterday_volume - float - 昨仓数量 * - frozen_total - float - 冻结数量 * - frozen_yesterday - float - 冻结昨仓 * - static_yesterday - float - 固定昨仓数量 * - open_volume - float - 今开数量 * - last_price - float - 最新价 * - avg_open_price - float - 开仓均价 * - position_cost_price - float - 持仓成本价 * - settlement_price - float - 结算价 * - pre_settlement_price - float - 昨结价 * - margin - float - 保证金 * - position_pnl - float - 持仓盈亏 * - close_pnl - float - 平仓盈亏 * - realized_pnl - float - 已实现盈亏 * - unrealized_pnl - float - 未实现盈亏 * - source_id - int - 来源账户 * - source_op_id - int - 来源账户 xor holder_uid 股票持仓 .. list-table:: :width: 600px * - 属性 - 类型 - 说明 * - update_time - int - 更新时间(功夫时间) * - instrument_id - str - 合约ID * - instrument_type - :ref:`InstrumentType ` - 合约类型 * - exchange_id - str - 交易所ID * - holder_uid - int - 持有人ID * - ledger_category - :ref:`LedgerCategory ` - 账户类别 * - direction - :ref:`Direction ` - 持仓方向 * - volume - float - 总持仓量 * - yesterday_volume - float - 昨仓数量 * - frozen_total - float - 冻结数量 * - frozen_yesterday - float - 冻结昨仓 * - static_yesterday - float - 固定昨仓数量 * - open_volume - float - 今开数量 * - last_price - float - 最新价 * - avg_open_price - float - 开仓均价 * - position_cost_price - float - 持仓成本 * - close_price - float - 收盘价 * - pre_close_price - float - 昨收价 * - realized_pnl - float - 已实现盈亏 * - unrealized_pnl - float - 未实现盈亏 * - source_id - int - 来源账户 * - source_op_id - int - 来源账户 xor holder_uid **注意 : 对于T+0标的，当前可交易数量为volume总持仓量；对于T+1标的，当前可交易数量为yesterday_volume昨仓数量** :: - aliyun镜像源配置 name = "aliyun" url = "https://mirrors.aliyun.com/pypi/simple" default = false secondary = true :: - 依赖的第三方库及其版本 black = "~22.3.0" nuitka = "~0.9.0" pdm = "~1.15.0" poetry-core = "^1.0.0" scons = "^4.3.0" click = "^8.0.0" psutil = "^5.9.0" tabulate = "^0.8.10" numpy = "^1.22.0" pandas = "^1.4.0" scipy = ">=1.7 <1.8" statsmodels = "^0.13.2" ordered-set = "^4.0.0" pytest = "^7.1.0" conan = "^1.49.0" pyinstaller = "^5.1" -----