获取管道 API

编辑

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

请求

编辑

GET _logstash/pipeline

GET _logstash/pipeline/<pipeline_id>

先决条件

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

描述

编辑

检索一个或多个 Logstash 管道。

路径参数

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

示例

编辑

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

resp = client.logstash.get_pipeline(
    id="my_pipeline",
)
print(resp)
response = client.logstash.get_pipeline(
  id: 'my_pipeline'
)
puts response
const response = await client.logstash.getPipeline({
  id: "my_pipeline",
});
console.log(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
    }
  }
}