获取管道 API编辑

此 API 用于检索用于 Logstash 集中管理 的管道。

请求编辑

GET _logstash/pipeline

GET _logstash/pipeline/<pipeline_id>

先决条件编辑

  • 如果启用了 Elasticsearch 安全功能,则您必须具有 manage_logstash_pipelines 集群权限才能使用此 API。

描述编辑

检索一个或多个 Logstash 管道。

路径参数编辑

<pipeline_id>
(可选,字符串) 用逗号分隔的管道标识符列表。

示例编辑

以下示例检索名为 my_pipeline 的管道

response = client.logstash.get_pipeline(
  id: 'my_pipeline'
)
puts response
GET _logstash/pipeline/my_pipeline

如果请求成功,响应主体将包含管道定义

{
  "my_pipeline": {
    "description": "Sample pipeline for illustration purposes",
    "last_modified": "2021-01-02T02:50:51.250Z",
    "pipeline_metadata": {
      "type": "logstash_pipeline",
      "version": "1"
    },
    "username": "elastic",
    "pipeline": "input {}\n filter { grok {} }\n output {}",
    "pipeline_settings": {
      "pipeline.workers": 1,
      "pipeline.batch.size": 125,
      "pipeline.batch.delay": 50,
      "queue.type": "memory",
      "queue.max_bytes": "1gb",
      "queue.checkpoint.writes": 1024
    }
  }
}