redis-py-cloudを使用してredis 5 streamデータを操作する

redis-py-cloudはredis-py-clusterに基づいて開発されたredisクラスタパッケージであり、特にredis 5.0のstreamの新しい特性をサポートしている.現在サポートされているコマンドは xadd,xread,xreadgroup,xackなど.
 
パッケージのダウンロード先:
https://github.com/ChinaGoldBear/redis-py-cloud
またはpip install:

pip install redis-py-cloud

 
基本操作:
1.クラスタの接続

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)

 
2.xadd

REDIS_CLUSTER.xadd("mystream", "*", 100,{"name": "data"})

 
3.xread

REDIS_CLUSTER.xread("mystream","*",1) #          

REDIS_CLUSTER.xread("mystream","*",1，0) #         

REDIS_CLUSTER.xread("mystream","*",10，0) #       10 

REDIS_CLUSTER.xread("mystream","1527849629172-0",1，0) #         

4. xrange

REDIS_CLUSTER.xrange("mystream","-","+") # -     , +     

REDIS_CLUSTER.xrange("mystream","1527849629172-0","+") #       ID   

REDIS_CLUSTER.xrange("mystream","-","1527849629172-0") #       ID   

 
 5.xreadgroup

REDIS_CLUSTER.xreadgroup("group_name","consumer_name","mystream",">",0) #      ，0      

REDIS_CLUSTER.xreadgroup("group_name","consumer_name","mystream",">") #      ，     

REDIS_CLUSTER.xreadgroup("group_name","consumer_name","mystream","1527849629172-0") #          ，     

 
6.xack

REDIS_CLUSTER.xack("mystream","counsumer_name","1527849629172-0")  # ack     

 
 
その他のstreamコマンドは、次のように参照してください.
https://blog.csdn.net/enmotech/article/details/81230531