redis_ts

redis_ts 为 redis 包提供一个小 trait 和扩展函数，允许使用 Redis 时间序列数据，该数据可以作为 Redis 模块 安装。时间序列命令有同步和异步版本。

这个包名为 redis_ts，您可以通过 cargo 依赖它。您还需要在依赖项中包含 redis。它已在 redis 0.25.2 上测试，但应与更高版本兼容。

[dependencies]
redis = "0.25.2"
redis_ts = "0.5.4"

或者通过 git

[dependencies.redis_ts]
git = "https://github.com/tompro/redis_ts.git"

继承自 redis 包的异步功能（任选：'async-std-comp' 或 'tokio-comp')

 [dependencies]
 redis = "0.25.2"
 redis_ts = { version = "0.5.4", features = ['tokio-comp'] }

同步使用

要启用 Redis 时间序列命令，只需将 redis_ts::TsCommands 加载到作用域中。然后，所有 Redis 时间序列命令都将可在您的 Redis 连接上使用。

use redis::Commands;
use redis_ts::{TsCommands, TsOptions};

let client = redis::Client::open("redis://127.0.0.1/")?;
let mut con = client.get_connection()?;

let _:() = con.ts_create("my_ts", TsOptions::default())?;

异步使用

要启用 Redis 时间序列异步命令，只需将 redis_ts::TsAsyncCommands 加载到作用域中。然后，所有 Redis 时间序列命令都将可在您的异步 Redis 连接上使用。

use redis::AsyncCommands;
use redis_ts::{AsyncTsCommands, TsOptions};

let client = redis::Client::open("redis://127.0.0.1/")?;
let mut con = client.get_async_connection().await?;

let _:() = con.ts_create("my_ts", TsOptions::default()).await?;

兼容性说明

版本 >= 0.5 在范围查询的参数列表中包含一个破坏性变更。由于 Redis 时间序列模块的一些最近添加，ts_range、ts_revrange、ts_mrange 和 ts_mrevrange 的参数数量已增长过长。现在，所有现有和新参数都由单个 TsRangeQuery 结构体替换，该结构体还有一个构建器可用。