📦 Logstash — Logstash集成

Logstash是一个数据处理管道，用于从各种来源获取数据，对其进行转换，然后将其发送到指定的存储库（如Elasticsearch）。它通常被DevOps工程师和系统管理员用于日志管理、安全信息和事件管理（SIEM）以及一般数据分析。

官方文档：https://www.elastic.co/guide/en/logstash/current/index.html

Logstash概述

• 管道
• 管道配置
• 设置
• 节点
• 插件

使用Logstash

该技能使用Membrane CLI与Logstash交互。Membrane自动处理身份验证和凭据刷新——因此你可以专注于集成逻辑，而不是身份验证流程。

安装CLI

安装Membrane CLI，以便你可以从终端运行membrane：

npm install -g @membranehq/cli

首次设置

membrane login --tenant

浏览器窗口将打开进行身份验证。

无头环境： 运行命令，打印URL供用户在浏览器中打开，然后使用membrane login complete 完成。

连接到Logstash

• 创建新连接：

membrane search logstash --elementType=connector --json

从output.items[0].element?.id获取连接器ID，然后：

membrane connect --connectorId=CONNECTOR_ID --json

用户在浏览器中完成身份验证。输出包含新的连接ID。

获取现有连接列表

当你不确定连接是否已存在时：

• 检查现有连接：

membrane connection list --json

如果存在Logstash连接，请记下其connectionId

搜索操作

当你知道想要做什么但不知道确切的操作ID时：

membrane action list --intent=QUERY --connectionId=CONNECTION_ID --json

这将返回包含id和inputSchema的操作对象，因此你将知道如何运行它。

热门操作

使用npx @membranehq/cli@latest action list --intent=QUERY --connectionId=CONNECTION_ID --json来发现可用的操作。

运行操作

membrane action run --connectionId=CONNECTION_ID ACTION_ID --json

传递JSON参数：

membrane action run --connectionId=CONNECTION_ID ACTION_ID --json --input "{ \"key\": \"value\" }"

代理请求

当可用的操作不满足你的用例时，你可以通过Membrane的代理直接向Logstash API发送请求。Membrane会自动将基础URL附加到你提供的路径，并注入正确的认证头——包括凭据过期时的透明刷新。

membrane request CONNECTION_ID /path/to/endpoint

常用选项：