Elasticsearch：如何在响应中返回Runtime映射的priceNode对象？

问题核心 #

你在runtime_mappings里定义的priceNode是仅用于查询阶段的临时字段，默认不会被包含在搜索响应中；同时script_fields无法直接引用runtime字段，因为它是查询时动态生成的，不属于索引的静态映射。

解决方案 #

1. 显式指定返回Runtime字段 #

在查询请求中添加fields参数，直接指定要返回的priceNode字段——这是最直接的方式，无需额外重复编写脚本：

{
  "runtime_mappings": {
    "priceNode": {
      "type": "object",
      "script": {
        "source": """
          def prices = doc['prices'];
          if (prices.size() > 0) {
            emit([current: prices[0].value.current, original: prices[0].value.original]);
          } else {
            emit(null);
          }
        """
      }
    }
  },
  "query": {
    "term": {
      "priceNode.current": {
        "value": 100
      }
    }
  },
  "fields": ["priceNode"] // 显式要求返回该runtime字段
}

2. 用script_fields重新计算字段（替代直接引用） #

如果必须使用script_fields，不要直接引用priceNode，而是将runtime_mappings中的脚本逻辑复制到script_fields里重新计算：

{
  "runtime_mappings": {
    "priceNode": {
      "type": "object",
      "script": {
        "source": """
          def prices = doc['prices'];
          if (prices.size() > 0) {
            emit([current: prices[0].value.current, original: prices[0].value.original]);
          } else {
            emit(null);
          }
        """
      }
    }
  },
  "query": {
    "term": {
      "priceNode.current": {
        "value": 100
      }
    }
  },
  "script_fields": {
    "priceNode": {
      "script": {
        "source": """
          def prices = doc['prices'];
          if (prices.size() > 0) {
            return [current: prices[0].value.current, original: prices[0].value.original];
          } else {
            return null;
          }
        """
      }
    }
  }
}

3. 持久化Runtime字段（频繁使用场景） #

如果这个字段需要频繁查询和返回，可以将其添加到索引的静态映射中，后续无需重复定义脚本：

PUT /your_index/_mapping
{
  "runtime": {
    "priceNode": {
      "type": "object",
      "script": {
        "source": """
          def prices = doc['prices'];
          if (prices.size() > 0) {
            emit([current: prices[0].value.current, original: prices[0].value.original]);
          } else {
            emit(null);
          }
        """
      }
    }
  }
}

之后查询时只需添加fields: ["priceNode"]即可直接返回该字段。

后续扩展提示 #

添加销售渠道逻辑时，直接在脚本中加入条件判断即可，比如：

def prices = doc['prices'];
def targetChannel = params.channel; // 可通过查询参数传入
def matchedPrice = prices.stream().filter(p -> p.value.channel == targetChannel).findFirst();
if (matchedPrice.isPresent()) {
  emit([current: matchedPrice.get().value.current, original: matchedPrice.get().value.original]);
} else {
  emit(null);
}

内容的提问来源于stack exchange，提问作者Batuhan GÜNGÖR