ElasticSearch按嵌套对象内日期字段脚本排序问题求助

映射结构 #

我的Elasticsearch索引中包含如下嵌套字段：

"attempts": {
  "type": "nested",
  "properties": {
    "type": {
      "type": "keyword"
    },
    "reason": {
      "type": "keyword"
    },
    "status": {
      "type": "keyword"
    },
    "number": {
      "type": "integer"
    },
    "date": {
      "type": "date"
    }
  }
}

需求 #

当从UI传入特定的type和number参数时，需要按照匹配到的attempts.date字段对文档进行排序。

尝试的脚本 #

我尝试用脚本实现排序，但结果不符合预期：

sort: [
  {
    _script: {
      nested: {
        path: 'attempts',
      },
      script: {
        lang  : 'painless',
        source: `if (
          doc['attempts.number'].value === params.number 
          && doc['attempts.type'].value === params.attemptType
          ) {
          return doc['attempts.date'].date.getMillis()
        }`,
        params: { attemptType, number },
      },
      order : sortType,
      type  : 'number',
    },
  },
  {
    _id: 'desc'
  }
]

问题现象 #

脚本没有报错，但每次返回的文档排序结果都不一致。

解决方案 #

问题根源 #

1. 未处理无匹配的情况：当文档中没有符合type和number条件的attempts时，脚本会返回null。Elasticsearch中null值的排序优先级不固定，多个返回null的文档会随机排序，导致结果波动。
2. 多匹配嵌套文档处理缺失：如果一个父文档包含多个符合条件的attempts，原脚本无法确定返回哪个date值，进一步导致排序逻辑混乱。

修正后的脚本 #

sort: [
  {
    _script: {
      nested: {
        path: 'attempts',
        // 先过滤出符合条件的嵌套文档，缩小脚本处理范围
        filter: {
          bool: {
            must: [
              { term: { "attempts.number": params.number } },
              { term: { "attempts.type": params.attemptType } }
            ]
          }
        }
      },
      script: {
        lang: 'painless',
        source: `
          long targetDate = 0;
          // 遍历所有符合条件的attempts，取最新的date（可根据需求改为取最早的）
          for (def attempt : params._source.attempts) {
            if (attempt.number == params.number && attempt.type == params.attemptType) {
              long currentMillis = Instant.parse(attempt.date).toEpochMilli();
              if (currentMillis > targetDate) {
                targetDate = currentMillis;
              }
            }
          }
          // 无匹配时返回固定值，避免null导致排序不稳定
          return targetDate == 0 ? (params.sortType == 'asc' ? Long.MAX_VALUE : 0) : targetDate;
        `,
        params: { attemptType, number, sortType },
      },
      order: sortType,
      type: 'number',
    },
  },
  {
    _id: 'desc'
  }
]

关键修改点 #

• 增加nested.filter：先过滤出符合条件的嵌套文档，减少脚本遍历的内容，提升性能。
• 遍历处理多匹配场景：通过循环获取所有符合条件的attempts，取其中最新的date（若需要最早的，可将>改为<）。
• 处理无匹配场景：根据排序方向返回固定值（升序返回极大值，降序返回极小值），确保无匹配文档的排序位置固定。

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