转发输入插件

简介

input_forward 插件用于接收来自其他系统的数据转发请求，目前支持LoongSuite协议。该插件可以作为数据转发的接收端，通过配置的匹配规则来处理接收到的数据。源代码

版本

Stable

版本说明

• 推荐版本：LoongCollector v2.0.0 及以上

配置参数

参数	类型，默认值	说明
Type	String，无默认值（必填）	插件类型，固定为input_forward。
Protocol	String，无默认值（必填）	转发协议类型。目前支持：LoongSuite。
Endpoint	String，无默认值（必填）	监听地址和端口，格式为IP:PORT，例如0.0.0.0:7899。或者本地通信socket，例如/root/loongcollector.sock。

转发规则

LoongSuite

LoongCollector 根据请求中的采集配置名进行转发，如果没有匹配的路由规则，则返回错误状态码。

GRPC

metadata 中配置 key 为 X-Loongsuite-Apm-Configname，value 为采集配置名。
返回状态码：

• OK：转发成功
• NOT_FOUND：没有匹配的采集配置
• INVALID_ARGUMENT：请求参数错误
• UNAVAILABLE：转发阻塞，请重试

样例

接收LoongSuite协议数据

• 采集配置

enable: true
inputs:
  - Type: input_forward
    Protocol: LoongSuite
    Endpoint: 0.0.0.0:7899
flushers:
  - Type: flusher_sls
    Project: "your-project"
    Logstore: "your-logstore"
    Region: cn-shanghai
    Endpoint: cn-shanghai.log.aliyuncs.com

• 输入

通过gRPC客户端发送LoongSuite协议的转发请求，请求需要在metadata中包含x-loongsuite-apm-configname: <采集配置名>字段，数据内容在请求的data字段中，为 PipelineEventGroup PB 序列化的结果。

• 输出

以下为示意：实际字段取决于上游 PB 解析后的事件内容及下游 Flusher 序列化方式。

{
    "content": "接收到的原始数据内容",
    "__time__": "1642502400"
}