redistimeseries-py

弃用通知

自redis-py 4.0.0起，此库已被弃用。其功能已合并到redis-py中。请从pypy 安装或从仓库安装。

redistimeseries-py是一个包，它使开发者能够轻松访问RedisTimeSeries模块。该包通过RedisTimeSeries的API扩展了redis-py的接口。

安装

$ pip install redistimeseries

开发

1. 创建一个virtualenv来管理您的python依赖项，并确保它是活动的。virtualenv -v venv
2. 安装pypoetry来管理您的依赖项。pip install poetry
3. 安装依赖项。poetry install

tox默认目标运行所有测试。运行tox将运行单元测试。请确保redis正在运行，并且已加载模块。

API

RedisTimeSeries的命令完整文档可以在RedisTimeSeries的网站上找到。

使用示例

# Simple example
from redistimeseries.client import Client
rts = Client()
rts.create('test', labels={'Time':'Series'})
rts.add('test', 1, 1.12)
rts.add('test', 2, 1.12)
rts.get('test')
rts.incrby('test',1)
rts.range('test', 0, -1)
rts.range('test', 0, -1, aggregation_type='avg', bucket_size_msec=10)
rts.range('test', 0, -1, aggregation_type='sum', bucket_size_msec=10)
rts.info('test').__dict__

# Example with rules
rts.create('source', retention_msecs=40)
rts.create('sumRule')
rts.create('avgRule')
rts.createrule('source', 'sumRule', 'sum', 20)
rts.createrule('source', 'avgRule', 'avg', 15)
rts.add('source', '*', 1)
rts.add('source', '*', 2)
rts.add('source', '*', 3)
rts.get('sumRule')
rts.get('avgRule')
rts.info('sumRule').__dict__

关于回补时间序列的更多说明

自RedisTimeSeries 1.4版本起，我们添加了回补时间序列的功能，并支持不同的重复策略。

默认行为是阻止相同时间戳的更新，您可以通过duplicate_policy参数来控制它。您可以在重复策略文档中详细了解。

以下是一个LAST重复策略的示例，其中我们用最新值覆盖重复的时间戳

from redistimeseries.client import Client
rts = Client()
rts.create('last-upsert', labels={'Time':'Series'}, duplicate_policy='last')
rts.add('last-upsert', 1, 10.0)
rts.add('last-upsert', 1, 5.0)
# should output [(1, 5.0)]
print(rts.range('last-upsert', 0, -1))

许可证

BSD 3-Clause