2 个版本
| 0.5.1 | 2020年2月8日 | 
|---|---|
| 0.5.0 | 2020年2月8日 | 
#12 in #orderbook
每月22次下载
用于 tectonicdb
215KB
 5.5K  SLoC
tectonicdb
| crate | docs.rs | crate.io | 
|---|---|---|
| tectonicdb | ||
| tdb-core | ||
| tdb-server-core | ||
| tdb-cli | 
tectonicdb 是一个快速、高度压缩的独立数据库和流式协议,用于订单簿的tick数据。
为什么
- 
使用简单且高效的二进制文件格式:密集tick格式(DTF) 
- 
存储订单簿tick数据的元组,形状如下: (时间戳, seq, is_trade, is_bid, price, size)。
- 
按时间戳 + seq 排序 
- 
每个订单簿事件12字节 
- 
每秒每个线程600,000次插入 
安装
安装tectonicdb有几种方法。
- 二进制文件
二进制文件可供下载。请确保将二进制文件的路径添加到您的PATH中。目前只有Linux x86_64的构建。
- Crates
cargo install tectonicdb
此命令将从crates.io下载 tdb、tdb-server、dtftools 二进制文件并本地构建。
- GitHub
要贡献,您需要在本地机器上拥有源代码的副本。
git clone https://github.com/0b01/tectonicdb
cd tectonicdb
cargo build --release
cargo run --release tdb-server
二进制文件可以在 target/release 下找到。
如何使用
设置非常简单。
./tdb-server --help
例如
./tdb-server -vv -a -i 10000
# run the server on INFO verbosity
# turn on autoflush for every 10000 inserts per orderbook
配置
为了配置Google Cloud Storage和数据收集后端集成,以下环境变量被使用
| 变量名称 | 默认值 | 描述 | 
|---|---|---|
| TDB_HOST | 0.0.0.0 | 数据库将要绑定的主机 | 
| TDB_PORT | 9001 | 数据库将要监听的路由 | 
| TDB_DTF_FOLDER | db | DTF文件存储的目录名称 | 
| TDB_AUTOFLUSH | false | 如果设置为 true,则记录的订单簿数据将每interval次插入自动刷新到DTF文件。 | 
| TDB_FLUSH_INTERVAL | 1000 | 每 interval次插入,如果启用自动刷新,DTF文件将从内存写入磁盘。 | 
| TDB_GRANULARITY | 0 | 记录历史粒度级别 | 
| TDB_LOG_FILE_NAME | tdb.log | 数据库日志文件的名称 | 
| TDB_Q_CAPACITY | 300 | 记录历史记录的环形队列容量 | 
客户端API
| 命令 | 描述 | 
|---|---|
| HELP | 打印帮助 | 
| PING | 响应 PONG | 
| INFO | 返回有关表模式的信息 | 
| PERF | 返回随时间变化的物品答案数 | 
| LOAD [orderbook] | 从磁盘将订单簿加载到内存 | 
| USE [orderbook] | 切换当前订单簿 | 
| CREATE [orderbook] | 创建订单簿 | 
| GET [n] FROM [orderbook] | 返回物品 | 
| GET [n] | 从当前订单簿返回n个物品 | 
| COUNT | 当前订单簿中物品的数量 | 
| COUNT ALL | 返回所有订单簿的总数 | 
| CLEAR | 删除当前订单簿中的所有内容 | 
| CLEAR ALL | 从内存中删除所有内容 | 
| FLUSH | 将当前订单簿刷新到硬盘上 | 
| FLUSHALL | 将内存中的所有内容刷新到硬盘 | 
| SUBSCRIBE [orderbook] | 订阅订单簿的更新 | 
| EXISTS [orderbook] | 检查订单簿是否存在 | 
| SUBSCRIBE [orderbook] | 订阅订单簿 | 
数据命令
USE [dbname]
ADD [ts], [seq], [is_trade], [is_bid], [price], [size];
INSERT 1505177459.685, 139010, t, f, 0.0703620, 7.65064240; INTO dbname
监控
TectonicDB通过定期将其使用信息发送到InfluxDB实例来支持监控/警报
    --influx-db <influx_db>                        influxdb db
    --influx-host <influx_host>                    influxdb host
    --influx-log-interval <influx_log_interval>    influxdb log interval in seconds (default is 60)
具体示例:
...
$ influx
> CREATE DATABASE market_data;
> ^D
$ tdb --influx-db market_data --influx-host http://localhost:8086 --influx-log-interval 20
...
TectonicDB将发送带有标签ob={ORDERBOOK}的值disk={COUNT_DISK},size={COUNT_MEM}到与dbname相同的测量值market_data。
此外,您可以使用INFO和PERF命令直接查询使用信息
- 
INFO报告内存和磁盘中的当前tick计数。
- 
PERF返回记录的tick计数历史,其粒度可以配置。
日志记录
默认的日志文件为tdb.log。
测试
export RUST_TEST_THREADS=1
cargo test
测试必须顺序运行,因为某些测试依赖于其他测试生成的dtf文件。
基准测试
tdb客户端附带基准测试模式。此命令将1M条记录插入到tdb中。
tdb -b 1000000
使用dtf文件
Tectonic附带一个命令行工具dtfcat,用于检查文件元数据和存储的所有事件,以JSON或CSV格式输出。
选项
USAGE:
    dtfcat [FLAGS] --input <INPUT>
FLAGS:
    -c, --csv         output csv
    -h, --help        Prints help information
    -m, --metadata    read only the metadata
    -V, --version     Prints version information
OPTIONS:
    -i, --input <INPUT>    file to read
作为库
可以在不同的应用程序中使用密集tick格式流协议/文件格式。与实现Write特质的任何缓冲区配合得很好。
要求
TectonicDB是一个独立的服务。
- 
Linux 
- 
macOS 
语言绑定
- 
TypeScript 
- 
Rust 
- 
Python 
- 
JavaScript 
附加功能
- 
类似Cloud SQL的使用统计信息 
- 
用于dtf文件格式的命令行检查工具 
- 
日志记录 
- 
按时间戳查询 
变更日志
- 0.5.0: InfluxDB监控插件和改进的命令行参数
- 0.4.0: 处理DTF文件的基于迭代器的API和各项质量改进
- 0.3.0: 重构为异步
依赖关系
~12–26MB
~389K SLoC