base package

Submodules

base.BackTestSimulator Module

Classes

BackTestSimulator(callbacks, Callable])
Callable(*args, **kwds)	Callable type; Callable[[int], str] is a function of (int) -> str.
DATA_TYPE	alias of Dict[str, Dict[str, numpy.ndarray]]
Dict(*args, **kwds)
List(*args, **kwds)
PUSHED_DATA_TYPE	alias of List[Union[Dict, List]]
SimulatedAccount()
SimulatedDataHandler(sim_flag, cn_flag)
SimulatedTrader()
Tuple(*args, **kwds)	Tuple type; Tuple[X, Y] is the cross-product type of X and Y.

base.DataHandler Module

DataHandler 模块包含了处理实际实时数据的代码

Classes

DataHandler(sim_flag, cn_flag)	数据读取, 保存, 转换的处理中心.
DataProcessor()	处理具体数据转换格式任务的类.

base.DBHandler Module

DBHandler负责处理各类与数据库相关的事务.

Classes

DatabaseHandler(host, user, password, sim_flag)

处理数据库事务的基本类

base.MarketConnection Module

连接市场的接口, 负责高层级的市场相关api(价格数据收发, 交易请求等)

Classes

PublicDataConnection(url, msg_consumer, …)	通过Websocket获取公共数据的接口
PrivateWSConnection(url, credentials, …)	建立一个私有的Websocket连接, 从而传递交易数据, 个人信息等私密信息
PrivateRESTConnection(credentials[, …])	通过REST api向市场发出请求
Account(url, credentials, callbacks, …)	账户类. 在建立连接后维护一个<balance>字典保存账户余额等信息, 维护<orders>字典保存订单信息, 维护<position>字典保存仓位信息. :param url: 连接的url, 通常为WS_PRIVATE_API_URL, 或WS_PRIVATE_API_URL_CN :param credentials: 字典, 包含了<api_key>, <api_secret_key>, <passphrase> :param callbacks: 字典, 包含了各类事件触发函数: - on_balance_update(hist_balance, balance) - on_position_update(hist_position, position) - on_orders_update(hist_orders, orders).
Trader(url, credentials[, use_server_time, …])	主要负责交易的地方

base.NetworkHandler Module

Classes

WebsocketHandler(url, callbacks, …)	WebsocketHandler, 用于处理最底层的websocket请求
RESTHandler(credentials[, use_server_time, …])	处理通过REST api的数据的请求的底层类.

base.SimulatedComponents Module

Classes

SimulatedTrader()
SimulatedAccount()
SimulatedDataHandler(sim_flag, cn_flag)

base.Strategy Module

参考一个策略里应该完成哪些动作.

Classes

Strategy(endpoint, tick_size, credentials)

策略基类.

base.const Module

包含了各类常用的constant