自定义 WebSocket 输入

WebSocket 输入集成允许从 WebSocket 服务器摄取实时数据。WebSocket 通过单个长连接提供全双工通信通道，这使其适用于需要低延迟数据传输的场景。

此输入类型连接到 WebSocket URL，侦听服务器发送的消息，并在消息到达时处理这些消息。然后将数据发布到 Elasticsearch，使其可以近乎实时地搜索和分析。

有关配置 WebSocket 输入的完整文档，请参见此处。

要配置 WebSocket 输入，请指定连接 URL 和其他可选参数，例如用于身份验证或协议版本的标头。可以在“高级选项”部分中配置连接处理的高级选项，例如超时和子协议。

以下是如何配置 WebSocket 输入的基本示例

此配置建立与 ws://127.0.0.1:443/v1/stream 的 WebSocket 连接，并使用基本身份验证。

WebSocket 输入将从服务器接收传输的消息。这些消息应采用 Filebeat 可以处理的格式，例如 JSON。如果消息格式不同，您可能需要定义一个处理器来解析数据并在将其发送到 Elasticsearch 之前对其进行结构化。

WebSocket 输入管理与 WebSocket 服务器的连接，包括在连接丢失时自动重新连接。输入不会在重启之间维护任何状态，因此如果服务器发送历史数据，则会在重新连接时重新摄取这些数据。