进行时间序列数据库的索引同步
easymirror
使用Redis作为消息转发。- 本地使用
easymirror
的mirror.Mirror
做基类,进一步开发供各种数据录入程序的接口。参考easymirror.vnpy.py
文件。 - 多个相同的行情录入程序可以在盘中(未实现)、盘后对齐缺失的 ticker 数据。
将仓库clone
到本地后,运行以下命令安装:
pip install -e .
主要的配置文件是conf/conf.json
。
- 这里
Redis
使用的端口是23002,对应的Redis
配置文件是23002.conf
。 - 基本上只需要简单地配置一下端口号和异地访问密码即可。
- 生产环境下,在公网部署部署该`
- 实盘中对齐
- 盘后对齐
- 二次开发
- demo见
debug.py
文件。 - 在子进程中建立服务后,通过
api.pushTickerIndex
接口推入Ticker数据。 - 代码基于
python3.5
的协程来实现。如果实盘数据录入不是python3.5
以上,那么只能使用盘后对齐
的功能
- demo见
makeup.py
文件。 - 先从数据库中加载 ticker 数据,并缓存。
- 开始广播前,所有在线的节点都需要在本地做好缓存。
- 通过调用
api.pushTickerIndex
接口开始广播。 - 使用的
python3.5
的协程来实现并发。
参考easymirror.vnpy.py
,通过继承easymirro.mirror.Mirror
来重写部分接口。