【发布时间】:2017-08-29 17:00:09
【问题描述】:
我创建了一个包含 30 个实例(15 个主节点/15 个节点)的 Redis 集群。使用 python 代码连接到这些实例,我找到了主人,然后我想为它们添加一些键。
def settomasters(port, host):
r = redis.Redis( host=host, port=port )
r.set("key"+port,"value")
错误:
redis.exceptions.ResponseError: MOVED 12539 127.0.0.1:30012
如果我尝试从redis-cli -c -p portofmyinstance 设置密钥,有时我会收到一条重定向消息,告诉我密钥的存储位置。
我知道,例如,在获取请求的情况下,需要智能客户端才能将请求重定向到正确的节点(持有密钥的节点),否则会发生移动错误。是不是一样的情况?我需要捕获 redis.exceptions.ResponseError 并尝试重新设置?
while True:
try:
r.set("key","value")
break
except:
print "error"
pass
我的第一次尝试是上面的代码,但没有解决方案。设置操作永远不会成功。
另一方面,javascript中的以下代码不会引发错误,我无法弄清楚原因:
var redis = require('redis-stream'),
client = new redis(30001, '127.0.0.1');
// Open stream
var stream = client.stream();
// Example of setting 200 records
for(var record = 0; record <200; record++) {
var command = ['set', 'qwerty' + record, 'QWERTYUIOP'];
stream.redis.write( redis.parse(command) );
}
stream.on('close', function () {
console.log('Completed!');
});
// Close the stream after batch insert
stream.end();
任何帮助将不胜感激,谢谢。
【问题讨论】:
标签: javascript python redis