问题描述
我正在使用 redis-py-cluster
连接我在 AWS 中的缓存,我将只执行读取操作
下面是我的代码示例
from rediscluster import RedisCluster
def redis_multi_get(rc: RedisCluster,keys: list):
pipe = rc.pipeline()
[pipe.get(k) for k in keys]
return pipe.execute()
if __name__ == '__main__':
rc = RedisCluster(startup_nodes=[{"host": host,"port": port}],decode_responses=True,skip_full_coverage_check=True)
keys = rc.keys(PREFIX + '*')
cache_hit = redis_multi_get(rc,keys)
我在 redis-py-cluster
中使用管道的内部实现。
目前只有 1 个分片,但未来可能会改变。
我想确认的是,如果 -
- 将来有多个分片使用
- 将来会使用多节点
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)