NIE MOŻESZ tego osiągnąć za pomocą potoku, ponieważ nigdy nie wiadomo, czy klucz istnieje, dopóki cały potok nie zostanie wykonany. Zamiast tego możesz użyć skryptów Lua do wykonania zadania:
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
Sprawdź to, aby zobaczyć, jak uruchomić skrypt Lua z redis-py. Następnie uruchom skrypt z potoku, aby zmniejszyć RTT
.
AKTUALIZUJ
Jeśli nalegasz na używanie WATCH
aby wykonać zadanie, możesz wypróbować następujący kod:
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