Redis, разрешить операцию только для существующих ключей

Question

Я использую пакет python (redis-py) для работы с базой данных redis. У меня есть куча клиентов, которые устанавливают ключи и значения хэша в redis. Я хочу, чтобы они устанавливали ключи и значения только тогда, когда существует хэш. Если хеш не существует, установка ключей и значений создаст хеш, чего я не хочу делать.

На странице redis-py (https://github.com/andymccurdy/redis-py) автор предложил способ выполнять атомарную операцию на стороне клиента. Таким образом, я написал аналогичную функцию:

with r.pipeline() as pipe: 
     while True: 
      try: 
       pipe.watch("a_hash") 
       if pipe.exists("a_hash"): 
        pipe.hset("a_hash", "key", "value")     
       break 
      except redis.WatchError: 
       continue 
      finally: 
       pipe.reset() 

Однако, похоже, это не работает. После того, как я удаляю хэш из другого клиента, этот хэш по-прежнему создается с помощью этой части кода, поэтому я предполагаю, что этот фрагмент кода не является атомарной. Может ли кто-нибудь помочь мне определить, в чем проблема с этим кодом? Или лучше ли достичь этой цели?

Цените свою помощь!

Answer 1

Я бы предложил прочитать определение блока WATCH/MULTI/EXEC, как описано в Redis documentation.

В таком блоке только команды между MULTI и EXEC фактически обрабатываются атомарно (и условно, с семантикой «все или ничего» в зависимости от часов).

В вашем примере команды EXISTS и HSET не выполняются атомарно. На самом деле вам не нужна эта атомарность: вы хотите это условное исполнение.

Это должно работать лучше:

with r.pipeline() as pipe: 
    while True: 
     try: 
      pipe.watch("a_hash") 
      if pipe.exists("a_hash"): 
       pipe.multi() 
       pipe.hset("a_hash", "key", "value") 
       pipe.execute() 
      break 
     except redis.WatchError: 
      continue 
     finally: 
      pipe.reset() 

Если ключ будет удален после того, как СУЩЕСТВУЕТ, но до MULTI, то не будет H Установите быть выполнена, благодаря часам.

С Redis 2.6, Lua server-side script, вероятно, легче писать и более эффективно.