Redis 流水线

Question

我想在填充数据库时利用客户端流水线。如何使用perl Redis client 实现这一目标？

use Redis;

my $redis = Redis->new or die "No redis server";

$redis->multi;
for my $i (1 .. 20000) {

  $redis->set("key.$i" => "foo" x500);
}
$redis->exec;

Answer 1

documentation 表示您需要添加一个 coderef 作为set 的第三个参数。

要使用流水线，请将 coderef 参数添加为命令方法调用的最后一个参数

这会把你的例子变成：

for my $i (1 .. 20000) {
  $redis->set("key.$i" => "foo" x500, sub {});
}

您实际上可以对回复做一些事情，而不是空子：

您提供给流水线命令方法的 coderef 被调用一次 响应可用。它需要两个参数，$reply 和 $error。 如果定义了 $error，则它包含由发送的错误回复的文本 Redis 服务器。否则，$reply 是非错误回复。几乎 所有命令，这意味着它是 undef，或已定义但非引用 标量，或其中任何一个的数组引用；但请参阅“密钥”、“信息”和 “执行”。

它还在文档的transaction handling 部分说：

警告：这些命令与流水线结合时的行为仍在讨论中，您现在不应该同时使用它们。