OpenSearch技术问题：如何在搜索查询中使用计算字段？

你遇到的问题核心是：script_fields定义的计算字段仅在结果返回阶段生成，无法在查询过滤阶段被引用，所以直接用它做range查询会返回空结果。下面提供几种可行的解决方法：

方法1：直接使用脚本查询（Script Query） #

把计算逻辑直接写入查询条件中，让Elasticsearch在过滤阶段就执行计算并判断：

POST /process-instance/_search
{
  "query": {
    "bool": {
      "filter": [
        {
          "script": {
            "script": {
              "source": """
                doc['completedAt'].value.toInstant().toEpochMilli() - doc['createdAt'].value.toInstant().toEpochMilli() >= 1000
              """,
              "lang": "painless"
            }
          }
        }
      ]
    }
  },
  "script_fields": {
    "duration": {
      "script": {
        "source": """
          doc['completedAt'].value.toInstant().toEpochMilli() - doc['createdAt'].value.toInstant().toEpochMilli()
        """,
        "lang": "painless"
      }
    }
  }
}

这样既会过滤出符合条件的文档，也会在结果中返回计算好的duration字段。

方法2：使用运行时字段（Runtime Fields） #

如果需要多次复用这个计算逻辑，可以定义运行时字段，它会在查询阶段动态计算，既可以被查询条件引用，也能返回给结果：

POST /process-instance/_search
{
  "runtime_mappings": {
    "duration": {
      "type": "long",
      "script": {
        "source": """
          emit(doc['completedAt'].value.toInstant().toEpochMilli() - doc['createdAt'].value.toInstant().toEpochMilli())
        """,
        "lang": "painless"
      }
    }
  },
  "query": {
    "range": {
      "duration": {
        "gte": 1000
      }
    }
  },
  "fields": ["duration"]
}

运行时字段无需提前修改索引mapping，适合临时或复用性高的计算场景。

方法3：索引阶段预计算字段 #

如果对查询性能要求较高，建议在索引文档时就预计算好duration字段，存入索引中：

方式A：修改mapping并重新索引 #

先更新索引mapping：

PUT /process-instance/_mapping
{
  "properties": {
    "duration": {
      "type": "long"
    }
  }
}

然后通过更新脚本批量计算并写入字段：

POST /process-instance/_update_by_query
{
  "script": {
    "source": """
      ctx._source.duration = doc['completedAt'].value.toInstant().toEpochMilli() - doc['createdAt'].value.toInstant().toEpochMilli()
    """,
    "lang": "painless"
  }
}

之后就可以用普通的range查询：

POST /process-instance/_search
{
  "query": {
    "range": {
      "duration": {
        "gte": 1000
      }
    }
  }
}

方式B：使用Ingest Pipeline #

新建一个处理管道，在文档索引前自动计算duration：

PUT /_ingest/pipeline/calculate-duration
{
  "processors": [
    {
      "script": {
        "source": """
          ctx.duration = ctx.completedAt.toInstant().toEpochMilli() - ctx.createdAt.toInstant().toEpochMilli()
        """,
        "lang": "painless"
      }
    }
  ]
}

之后索引文档时指定管道：

POST /process-instance/_doc?pipeline=calculate-duration
{
  "createdAt": "...",
  "completedAt": "...",
  // 其他字段
}

内容的提问来源于stack exchange，提问作者Вячеслав Чернышов