python - 当有大量数据要发送时，如何在 Redis 中实现事务？

Question

我正在使用流水线来确保我的两个命令在事务中执行。

我的代码是:

with redis.pipeline() as p:
   p.delete(key)
   p.sadd(key, *many_ids)
   p.execute()

如您所见，我正在尝试以原子方式用新的一组替换一组。但这会导致写入套接字时出现 错误 32。管道损坏。 当 many_ids 变大(超过 100 万)时。

Answer 1

我认为你遇到的麻烦可能在于扩展你所有的论点。还有另一种方式可以执行此交易；分批构建您的新集合。然后使用 RENAME操作

Renames key to newkey. It returns an error when key does not exist. If newkey already exists it is overwritten, when this happens RENAME executes an implicit DEL operation, so if the deleted key contains a very big value it may cause high latency even if RENAME itself is usually a constant-time operation.