具有 Python 的 Redis 时间序列管道

Question

我希望使用管道将数据插入到 redis 时间序列中，但找不到通过管道 ts.add 的方法。

我可以用 get / set 做基本的例子：

导入redis

进口json

redis_client = redis.Redis(主机='xxx.xxx.xxx.xxx', 端口='xxxxx', 密码='xxxx')

管道=redis_client.pipeline()

pipe.set(1,'apple')

pipe.set(2,'orange')

pipe.execute()

我找不到插入时间序列的方法:

导入redis

进口json

redis_client = redis.Redis(主机='xxx.xxx.xxx.xxx', 端口='xxxxx', 密码='xxxx')

管道=redis_client.pipeline()

pipe.ts.add(TS1,1652683016,55) #<----- 这就是我想要做的！

pipe.ts.add(TS1,1652683017,59) #<----- 这就是我想要做的！

pipe.execute()

Answer 1

截至撰写本文时（redis-py 4.3.1）时间序列 class 本身存在另一个管道对象。以下将起作用：

import redis

r = redis.Redis()
pipe = r.ts().pipeline()
pipe.add("TS1", 1, 123123123123)
pipe.add("TS1", 2, 123123123451)
...
pipe.add("TS1", 15, 123123126957)
pipe.execute()

具有 Python 的 Redis 时间序列管道

Redis Timeseries Pipeline with Python

python

redis

pipeline