redis-py手錶哈希鍵

Question

我正在使用redis-py通過python與redis進行接口。我處於這種情況，我需要自動更新散列鍵，但首先需要檢索該鍵的值，然後才能更新它。通過文檔查看，我可以使用管道和WATCH命令來確定密鑰何時發生更改。無論如何要看一個哈希密鑰？或者這隻適用於單數鍵？

Answer 1

如何使用MULTI？那麼你不需要擔心看到哈希中的一個鍵（這個WATCH看起來不支持，正如你所建議的那樣）。

Answer 2

您不能直接觀看哈希鍵，目前Redis不支持這種方式。但是你可以使用額外的「鎖定」字符串鍵，並定義了合同，由任何人，誰修改您的哈希值，應遵循以下任何散列鍵K的過程：

1. WATCH lock:K
2. HGETķ ，保存當前值
3. 啓動MULTI。
4. SET lock:K 「」
5. HSETķupdated_value
6. EXEC

這將保證更新的散列值不同時覆蓋。

雖然這是一個Python的問題，我公司提供的NodeJS功能實現上述合同（只顯示一個想法）：

/** 
* Concurrently updates Redis string and hash value under the specified key. 
* 
* @param redisCli Redis client. 
* @param hashName Hash name. 
* @param objId Object ID. 
* @param transFun Cache object transformation function (i.e. a modification that we need to apply). 
* @param cbFun Callback function, to which a modified object is passed in case of success. 
*/ 
exports.redisUpdateHashConcurrently = function(redisCli, hashName, objId, transFun, cbFun) { 
    var lockKey = hashName + ':' + objId + ':lock'; 

    redisCli.watch(lockKey); // Step 1. 

    redisCli.hget(hashName, objId, function(err, obj) { // Step 2. 
     if (err) { 
      redisCli.unwatch(); 

      cbFun && cbFun(undefined, err); 

      return; 
     } 

     if (obj) { 
      var modObj = transFun(JSON.parse(obj)); 
      var value = JSON.stringify(modObj); 

      redisCli.multi() // Step 3. 
       .set(lockKey, '') // Step 4. 
       .expire(lockKey, 3) 
       .hset(hashName, objId, value) // Step 5. 
       .exec(function(err, replies) { // Step 6. 
        if (!replies) { // Object was modified by someone else, retry. 
         exports.redisUpdateHashConcurrently(redisCli, hashName, objId, transFun, cbFun); 
        } 
        else { // We have succeeded. 
         cbFun && cbFun(modObj, undefined); 
        } 
       }); 
     } 
     else { 
      redisCli.unwatch(); 
     } 
    }); 
}; 

請注意，您可以爲「鎖定」鍵指定TTL，以便它們最終被移除。