redis5.0 新特性 Stream 数据食用方法（ Python ）

转载自： https://blog.csdn.net/copyangle/article/details/81975975

7 月份 redis5.0 隆重推出重量级新特性 Stream ！各位码农是不是早就磨拳擦掌跃跃欲试呢。下面介绍如何在 python 中使用 Stream 新特性。

Stream 的命令行使用方法参考：Redis5.0 重量级特性 Stream 尝鲜

用到的包：redis-py-cloud

通常使用的操作 redis 集群包 redis-py-cluster 现在并不支持 Stream 数据，所以 redis-py-cloud 就是在 redis-py-cluster 基础上实现的针对 Stream 数据类型的 python 包。

TPS:redis-py-cloud 可以在 python 2.7.5 版本使用，但是推荐 3.0 以上版本，其他版本未测试。

python 中首先安装 redis-py-cloud 包。git 地址如下：

git 安装：

https://github.com/ChinaGoldBear/redis-py-cloud

下载完成， 执行 python setup.py install 安装。

pip 安装：

pip install redis-py-cloud 然后就可以用了！配置集群机器：

from rediscluster import RedisCluster

'''连接集群''' startup_nodes = [{"host": "ip3", "port": "7000"}, {"host": "ip2", "port": "7000"}, {"host": "ip1", "port": "7000"}, ]

REDIS_CLUSTER = RedisCluster(startup_nodes=startup_nodes, decode_responses=True) 测试：

REDIS_CLUSTER.xadd(STREAM_NAME, "*", 100,{"name": "data"}) OK，大功告成！

详细教程参考：使用 redis-py-cloud 操作 redis5 stream 数据 https://blog.csdn.net/copyangle/article/details/81975975