パイプライン全体が実行されるまでキーが存在するかどうかわからないため、パイプラインではこれを実現できません。代わりに、Luaスクリプトを使用して作業を行うことができます:
local key = KEYS[1]
local field = ARGV[1]
local value = ARGV[2]
local ttl = ARGV[3]
local exist = redis.call('exists', key)
redis.call('hset', key, field, value)
if exist == 0 then
redis.call('expire', key, ttl)
end
これをチェックして、redis-pyでLuaスクリプトを実行する方法を確認してください。次に、パイプラインを使用してスクリプトを実行し、RTT
を減らします。 。
更新
WATCH
の使用を主張する場合 仕事をするために、あなたは次のコードを試すことができます:
with r.pipeline() as pipe:
while 1:
try:
pipe.watch(hkey)
exist = pipe.exists(hkey)
pipe.multi()
if not exist:
pipe.hset(hkey, v, v)
pipe.expire(hkey, 3600)
else:
pipe.hset(hkey, v, v)
pipe.execute()
break;
except WatchError:
continue