创建管道 #

使用创建管道 API 操作在 Easysearch 中创建或更新管道。请注意，该管道要求您至少定义一个处理器来指定如何更改文档。

创建路径 #

将替换为您的管道 ID：

PUT _ingest/pipeline/<pipeline-id>

下面是一个 JSON 格式的示例，它创建了一个包含两个 set 处理器和一个 uppercase 处理器的采集管道。第一个 set 处理器将 grad_year 设置为 2023 ，第二个 set 处理器将 graduated 为 true 。 uppercase 处理器将 name 字段转换为大写。

PUT _ingest/pipeline/my-pipeline
{
  "description": "This pipeline processes student data",
  "processors": [
    {
      "set": {
        "description": "Sets the graduation year to 2023",
        "field": "grad_year",
        "value": 2023
      }
    },
    {
      "set": {
        "description": "Sets graduated to true",
        "field": "graduated",
        "value": true
      }
    },
    {
      "uppercase": {
        "field": "name"
      }
    }
  ]
}

请求内容字段 #

下表列出了用于创建或更新管道的请求内容字段。

参数	是否必需	类型	描述
`processors`	必需的	数组对象	一组处理器，每个处理器都会转换文档。处理器按指定的顺序依次运行。
`description`	可选	字符串	摄取管道的描述。

路径参数 #

参数	是否必需	类型	描述
`pipeline-id`	必需的	字符串	分配给摄取管道的唯一标识符或管道 ID。

查询参数 #

参数	是否必需	类型	描述
`cluster_manager_timeout`	可选	时长	等待连接到集群管理器节点的时间。默认为 30 秒。
`timeout`	可选	时长	等待响应的时间。默认为 30 秒。

模版使用 #

部分处理器参数支持 Mustache 模板代码片段。要获取字段值，请将字段名称括在三个花括号中，例如 {{{field-name}}} 。

示例：使用 Mustache 模板片段 set 采集处理器 #

以下示例将字段 {{{role}}} 设置为值 {{{tenure}}} ：

PUT _ingest/pipeline/my-pipeline
{
 "processors": [
    {
      "set": {
        "field": "{{{role}}}",
        "value": "{{{tenure}}}"
         }
    }
  ]
}