python を用いて Redis のクラスターに接続する方法

Redisクラスタに接続するには、RedisのPythonクライアントライブラリであるredis-py-clusterを使用できます。次に、Redisクラスタに接続するためのコード例を示します。

from rediscluster import RedisCluster

# Redis集群节点的配置
startup_nodes = [
    {"host": "127.0.0.1", "port": "7000"},
    {"host": "127.0.0.1", "port": "7001"},
    {"host": "127.0.0.1", "port": "7002"},
    # 添加其他节点...
]

# 创建Redis集群对象
cluster = RedisCluster(startup_nodes=startup_nodes, decode_responses=True)

# 使用Redis集群进行操作
cluster.set("key", "value")
value = cluster.get("key")

print(value)

在上面的代码中，通过rediscluster.RedisCluster类创建了一个Redis集群对象cluster，并通过startup_nodes参数传入了Redis集群的节点配置。你需要根据实际的Redis集群节点地址和端口号进行配置。

そして、clusterオブジェクトを使って、単一のRedisインスタンス上と同様に、各種Redis操作を実行できる。上記の例示では、setメソッドを使ってキーバリューペアを設定し、getメソッドを使って対応する値を取得している。

decode_responses=Trueパラメータは、戻り値を自動的にバイト文字列から文字列にデコードし、文字列型の値を簡単に処理できるように注意してください。

最後に、取得した値をprint関数で出力しました。

クラスタオブジェクトを使用すれば、実際のニーズに応じて、他の Redis 操作を実行できます。