PaginatedJsonQueryElasticsearch

该 Processor 适用于 Elasticsearch JSON DSL 与 Elasticsearch 5.X 及以上 版本。它的设计目标是能够接收一个 JSON 查询（例如来自 Kibana），并 以分页方式原样对 Elasticsearch 集群执行。与 "restapi" bundle 中的所有 Processor 一样，它使用官方 Elastic 客户端 API，因此支持 leader 检测。

要执行的查询 JSON 可以在 Query 配置属性中提供，也可以通过 FlowFile 内容提供。如果配置了 Query Attribute 属性，已执行的 查询 JSON 会被放入该属性指定的 Attribute 中。

查询通过可用的方法之一在 Elasticsearch 中分页——"Scroll" 或 "Search After"（对于启用 XPack 的 Elasticsearch 7.10+，可以可选地 配合 "Point in Time"）。每页结果数量可以通过查询 JSON 中的 size 参数控制。对于 Search After 功能，查询 JSON 中必须 包含 sort 参数。

搜索结果和聚合结果可以拆分为多个 FlowFile。聚合结果只在顶层 拆分，因为嵌套聚合如果与父聚合分离，就会失去上下文（从而失去 其价值）。此外，所有页的结果可以合并为单个 FlowFile（但 Processor 在任何时刻都只把当前页的数据加载到内存）。

以下是可接受的查询示例：

{
  "query": {
    "size": 10000,
    "sort": {
      "product": "desc"
    },
    "match": {
      "restaurant.keyword": "Local Pizzaz FTW Inc"
    }
  },
  "aggs": {
    "weekly_sales": {
      "date_histogram": {
        "field": "date",
        "interval": "week"
      },
      "aggs": {
        "items": {
          "terms": {
            "field": "product",
            "size": 10
          }
        }
      }
    }
  }
}