在 Redis 中，是否可以跨多个 Sorted Set 对成员进行排序？

Question

我在 Redis 中跟踪多个排序集中的成员，作为对成员进行多列索引的一种方式。例如，假设我有两个排序集，lastseen（这是纪元时间）和points，我将用户名作为成员存储在这些排序集中。

我想先按lastseen 排序，这样我就可以在最后一天或一个月内看到用户，然后我想按points 对结果成员进行排序，这样我就可以有效地看到其中的成员按点排序的最后一天或一个月。

如果我可以将调用 ZREVRANGEBYSCORE 的结果存储到新的排序集（我们将调用新的排序集temp），这将很容易，因为这样我就可以对lastseen 进行限制排序，存储结果到temp，对temp 和points 使用ZINTERSTORE，out 的权重为零（存储到result），最后在result 上再次使用ZREVRANGEBYSCORE。但是，Redis 中没有内置方法可以将 ZRANGE 的结果存储到新的 Sorted Set 中。

我研究过使用here 发布的解决方案，虽然它似乎对结果进行了正确排序，但排序集中的结果分数不能再用于根据时间准确限制结果（即只想要一个最后一天内）。

例如：

redis> ZADD lastseen 12345 "foo"
redis> ZADD lastseen 12350 "bar"
redis> ZADD lastseen 12355 "sucka"
redis> ZADD points 5 "foo"
redis> ZADD points 3 "bar"
redis> ZADD points 9 "sucka"

假设我的时间窗口在12349 和12356 之间，我想结束的是成员列表['sucka', 'bar']。

Answer 1

我能想到的解决办法是：

1) 你的愿望是ZREVRANGEBYSCORE 并以某种方式保存临时结果。相反，您可以复制 zset（可以使用 ZINTERSTORE 来完成，只有一组作为参数），然后在新副本上执行 ZREMRANGEBYSCORE 以摆脱您不感兴趣的时间，然后执行最后的ZINTERSTORE。

2) 按照 Eli 的建议，在客户端循环执行。

3) 在 Lua 脚本中做同样的事情。

这些都是潜在的昂贵操作，因此最有效的操作将取决于您的数据和用例。如果不知道更多，我个人会倾向于 Lua 解决方案。

Answer 2

对于如此复杂的查询，您希望使用另一种处理语言来补充 Redis 的内置命令。最简单的方法是从您的后端语言中调用并使用它进行处理。在 Python 中使用 redis-py 的示例是：

import redis
finish_time, start_time = 12356, 12349
r = redis.Redis(host='localhost', port=6379, db=0, password='some_pass')
entries_in_time_frame = r.zrevrangebyscore('lastseen', finish_time, start_time)
p = r.pipeline()
for entry in entries_in_time_frame:
    p.zscore('points', entry)
scores = zip(entries_in_time_frame, p.execute())
sorted_entries = [tup[0] for tup in sorted(scores, key=lambda tup: tup[1])]


>>> ['sucka', 'bar']

请注意管道，因此我们只会向 Redis 服务器发送两次调用，因此网络延迟不会让我们拖慢太多。如果您需要更快（也许如果第一个ZREVRANGEBYSCORE 返回的内容很长），您可以重写与上面as a Lua script 相同的逻辑。这是一个工作示例（注意我的 lua 已生锈，因此可以对其进行优化）：

local start_time = ARGV[1]
local finish_time = ARGV[2]
local entries_in_time_frame = redis.call('ZREVRANGEBYSCORE', KEYS[1], finish_time, start_time)

local sort_function = function (k0, k1)
   local s0 = redis.call('ZSCORE', KEYS[2], k0)
   local s1 = redis.call('ZSCORE', KEYS[2], k1)
   return (s0 > s1)
end

table.sort(entries_in_time_frame, sort_function)

return entries_in_time_frame

你可以这样称呼它：

redis-cli -a some_pass EVAL "$(cat script.lua)" 2 lastseen points 12349 12356

返回：

1) "bar"
2) "foo"