Elasticsearch：如何将评级关键字映射为子字段的离散整数值？

现有Elasticsearch索引包含rating关键字字段（值如A、A+等），需要把这些值映射成子字段rating.value（整数类型），方便后续应用衰减函数，示例如下：

rating: A
rating.value: 1

下面对比你提到的两种方案，给出最优实现建议：

方案一：用分析器实现 #

这种方式靠自定义分析器+字段映射，把评级字符串转成对应数值：

• 创建索引时定义自定义分析器，用字符替换过滤器把"A"换成"1"、"A+"换成"2"这类（具体数值按你的评级权重定）
• 给rating字段设置多字段映射，value子字段使用这个自定义分析器，类型设为integer

但这个方案有明显局限：

• 分析器本来是用于文本处理的，若评级规则复杂（比如新增B-、S级），维护替换规则会很繁琐
• 只能处理新写入的文档，存量数据得重新索引才能生效

方案二：用摄入管道实现 #

摄入管道是Elasticsearch专门做文档预处理的工具，用script处理器能灵活编写映射逻辑：

1. 先创建摄入管道，写好评级到数值的映射脚本，比如：

if (ctx.rating == 'A') {
  ctx.rating = ['keyword': ctx.rating, 'value': 1];
} else if (ctx.rating == 'A+') {
  ctx.rating = ['keyword': ctx.rating, 'value': 2];
}
// 新增评级直接在这里补充判断逻辑即可

2. 新文档写入时指定这个管道，存量数据可以用_update_by_query结合管道完成批量更新

这个方案优势很明显：

• 逻辑直白易懂，维护和扩展都简单，加新评级改脚本就行
• 既能处理新数据，也能更新存量数据，无需重新索引
• 本身就是专门做数据预处理的，比用分析器更贴合这类字段转换场景

最优选择 #

优先选摄入管道方案，原因很直接：

• 更适配数据转换的需求，维护成本更低
• 覆盖新数据写入和存量数据更新的全场景
• 脚本的灵活性能轻松应对复杂的评级规则变化

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