启动主引擎

注册事件处理函数监听

停止引擎

动态加载策略 :param names: 策略名列表，元素为策略的 name 属性

下次激活时间 :return:

now 时间戳统一接口 :return:

所有策略要监听的事件都绑定到这里 :param strategy: Strategy() :param _type: "listen" OR "unlisten" :return:

注销事件处理函数

注册默认的时钟事件 :return:

绑定事件

:param now_time: datetime.datetime :return: >>> import datetime >>> get_next_trade_date(datetime.date(2016, 5, 5)) datetime.date(

:return:

动态加载策略 :param names: 策略名列表，元素为策略的 name 属性

优先使用在此自定义 log 句柄, 否则返回None, 并使用主引擎日志句柄 :return: log_handler or None

关闭进程前调用该函数 :return:

引擎启动

停止

:param event event.data 为所有股票的信息，结构如下 {'162411': {'ask1': '0.493', 'ask1_volume': '75500', 'ask2': '0.494',

移除事件

初始化事件 / 行情 引擎并启动事件引擎

初始化事件引擎

Log对象 :param name: log 名字 :param :logtype: 'stdout' 输出到屏幕, 'file' 输出到指定文件 :param :filename: log 文件名 :param :loglevel:

@:param strategy 策略

:param interval: float(minute) :param trading: 在交易阶段才触发 :return:

:param clock_type: :param moment: datetime.time :param is_trading_date: bool(是否只有在交易日触发) :param makeup: 注册时,如果已经过了触发时

:param event_engine: :param event_engine: tzinfo :return:

事件处理

启动引擎

启动进程

处理时间

处理事件

关闭进程前的处理 :return:

在交易时间会定时推送 clock 事件 :param event: event.data.clock_event 为 [0.5, 1, 3, 5, 15, 30, 60] 单位为分钟, ['open', 'close'] 为开市、收市 event.data.

:return: