› › ›

获取管道 API

返回有关一个或多个摄取管道的信息。此 API 返回管道的本地引用。

resp = client.ingest.get_pipeline(
    id="my-pipeline-id",
)
print(resp)

response = client.ingest.get_pipeline(
  id: 'my-pipeline-id'
)
puts response

const response = await client.ingest.getPipeline({
  id: "my-pipeline-id",
});
console.log(response);

GET /_ingest/pipeline/my-pipeline-id

请求

编辑

GET /_ingest/pipeline/<pipeline>

GET /_ingest/pipeline

先决条件

编辑

如果启用了 Elasticsearch 安全功能，则您必须拥有 read_pipeline、manage_pipeline、manage_ingest_pipelines 或 manage 集群权限才能使用此 API。

路径参数

编辑

<pipeline>

(可选，字符串) 要检索的管道 ID 的逗号分隔列表。支持通配符 (*) 表达式。

要获取所有摄取管道，请省略此参数或使用 *。

查询参数

编辑

master_timeout: (可选，时间单位) 等待主节点的时长。如果在超时时间到期前主节点不可用，则请求失败并返回错误。默认为 30s。也可以设置为 -1 以指示请求永远不会超时。

示例

编辑

获取特定摄取管道的信息

编辑

resp = client.ingest.get_pipeline(
    id="my-pipeline-id",
)
print(resp)

response = client.ingest.get_pipeline(
  id: 'my-pipeline-id'
)
puts response

const response = await client.ingest.getPipeline({
  id: "my-pipeline-id",
});
console.log(response);

GET /_ingest/pipeline/my-pipeline-id

API 返回以下响应

{
  "my-pipeline-id" : {
    "description" : "describe pipeline",
    "version" : 123,
    "processors" : [
      {
        "set" : {
          "field" : "foo",
          "value" : "bar"
        }
      }
    ]
  }
}

« 创建或更新管道 API 删除管道 API »