Redis Stack Lettuce管道中能否传递查询结果至后续ft.aggregate/ft.search？

首先明确结论：Redis管道本身不支持直接将前一个查询的结果作为后一个查询的输入。原因是管道的工作机制是客户端一次性把所有命令打包发送到服务器，服务器按顺序执行，但执行每个命令时无法获取之前命令的结果来动态生成后续命令——所有命令在发送到服务器前就已经固定了。

要实现“用前一个查询结果作为后一个输入”且减少Redis往返次数，有两个可行方案：

方案1：使用Lua脚本 #

Redis允许在Lua脚本内串联执行多个命令，脚本里可以直接获取前一个命令的执行结果，再动态构造后续命令的参数，整个脚本只需一次Redis往返。

举个实际场景的示例（先通过FT.SEARCH获取目标文档ID，再用这些ID作为条件执行FT.AGGREGATE）：

-- 第一步：执行搜索获取文档ID集合
local search_result = redis.call('FT.SEARCH', 'article_index', '@tag:redis', 'LIMIT', 0, 20)
-- 提取SEARCH结果中的文档ID（FT.SEARCH结果的偶数位为文档ID）
local target_ids = {}
for i = 2, #search_result, 2 do
    table.insert(target_ids, search_result[i])
end
-- 第二步：用获取的ID作为过滤条件执行聚合查询
return redis.call('FT.AGGREGATE', 'article_index', '@id:[' .. table.concat(target_ids, ' ') .. ']', 'GROUPBY', 1, '@author', 'REDUCE', 'COUNT', 0, 'AS', 'article_count')

使用时通过EVAL命令执行该脚本即可，全程仅需一次Redis交互。

方案2：客户端分两次处理（结合轻量管道） #

如果不想用Lua脚本，可以先通过单次请求或管道执行第一个查询，拿到结果后在本地客户端构造第二个查询的参数，再发送第二个请求。虽然是两次往返，但比多次单独请求的效率更高（尤其当第一个查询的结果集不大时）。

需要注意：绝对不要尝试在同一个管道中放入依赖前序结果的命令，因为管道内的命令是预定义好的，服务器不会在执行过程中动态调整后续命令的参数。

内容的提问来源于stack exchange，提问作者adamzrk