redisで一括処理するパイプラインを使用する（Pythonの例）

Question

pythonクライアントを使用して、redisで実装されたパイプラインの概念をクリアしようとしています。次の例を参照してください。

my_server = redis.Redis(connection_pool=POOL) 
for obj_id in list_of_obj_ids: 
    hash_name="n:"+str(obj_id) 
    sorted_set = "s:"+str(obj_id) 
    if my_server.exists(hash_name): 
     my_server.hset(hash_name,'val',0) 
    if my_server.zcard(sorted_set): 
     my_server.zadd(sorted_set, hash_name, time.time()) 

Ie. forループを繰り返して複数のハッシュを更新しています。この種の一括更新をパイプライン処理でどのように達成できますか？私が読んだことから、次のことが私の頭に浮かぶものです：

my_server = redis.Redis(connection_pool=POOL) 
p = my_server.pipeline() 
for obj_id in list_of_obj_ids: 
    hash_name="n:"+str(obj_id) 
    sorted_set="s:"+str(obj_id) 
    if p.exists(hash_name): 
     p.hset(hash_name,'val',0) 
    if p.zcard(sorted_set): 
     p.zadd(sorted_set, hash_name, time.time()) 
p.execute() 

これは間違いありませんか？

Answer 1

pipeliningは/ doesで、これがうまくいかない理由を理解しておいてください。executeパイプラインまで、それに含まれるコマンドはどれもサーバーに送られません。それはあなたの条件文があなたが念頭に置いていた目的を逃すことになります。