LoongCollector

1758
下载
LoongCollector 源自阿里云可观测性团队所开源的 iLogtail 项目,在继承了 iLogtail 强大的日志采集与处理能力的基础上,进行了全面的功能升级与扩展。从原来单一日志场景,逐步扩展为可观测数据采集、本地计算、服务发现的统一体。 LoongCollector 是一款集卓越性能、超强稳定性和灵活可编程性于一身的数据采集器,专为构建下一代可观测 Pipeline 设计。愿景是:打造业界领先的“统一可观测 Agent(Unified Observability Agent)”与“端到端可观

增加新的日志协议


如果iLogtail暂时不支持您所需的日志协议,您可以为iLogtail增加该协议并添加相应的协议转换函数,具体步骤如下:

  1. 如果您的协议支持Protobuf或其它可通过模式定义生成相应内存结构的编码方式,您需要首先在./pkg/protocol目录下新建一个以协议名为命名的文件夹,然后在该文件夹中增加一个以编码方式为命名的子文件夹,在该文件中存放相应的模式定义文件,然后将由代码生成工具生成的与该模式定义文件相对应的Go代码文件放置在父目录中。目录组织结构如下:
./pkg/protocol/
├── <protocol_name>
│ ├── <encoding>
│ └── 模式定义文件
│ └── 代码生成工具生成的Go文件
└── converter
├── converter.go
├── <protocol>_log.go
└── 测试文件
  1. ./pkg/protocol/converter目录下新建一个以<protocol>_log.go命名的文件,并在该文件中实现下列函数:
func (c *Converter) ConvertToXXXProtocolLogs(logGroup *sls.LogGroup, targetFields []string) (logs interface{}, values [][]string, err error)
func (c *Converter) ConvertToXXXProtocolStream(logGroup *sls.LogGroup, targetFields []string) (stream interface{}, values [][]string, err error)

其中,函数名中的“XXX”为协议名(可缩写),参数中的logGroup为sls日志组,targetFields为需要提取值的字段名,返回值中的logs为与协议对应的数据结构组成的数组,stream为代表该日志组的字节流,values为每条日志或日志组tag中targetFields字段对应的值,err为返回的错误。 该函数必须支持以下功能:

为了完成上述第2和第3点,iLogtail提供了下列帮助函数:

func convertLogToMap(log *sls.Log, logTags []*sls.LogTag, src, topic string, tagKeyRenameMap map[string]string) (contents map[string]string, tags map[string]string)
func findTargetValues(targetFields []string, contents, tags, tagKeyRenameMap map[string]string) (values map[string]string, err error)

各函数的用途如下:

1. 对输入日志进行相应的转换
2. 能够根据`c.TagKeyRenameMap`重命名sls协议中LogTag字段的Key
3. 能够根据`targetFields`找到对应字段的值
4. 对于部分编码格式,能够根据`c.ProtocolKeyRenameMap`重命名协议字段的Key
- `convertLogToMap`:将符合sls协议的日志以及对应logGroup中的其他元信息转换成以map形式存储的`contents`和`tags`,同时根据`tagKeyRenameMap`重命名sls协议中LogTag字段的Key。
- `findTargetValues`:在`convertLogToMap`获得的`contents`和`tags`中寻找`targetFields`字段对应的值,如果`targetFields`中包含被更名的默认tag键,则寻找过程还需要借助`tagKeyRenameMap`。
  1. ./pkg/protocol/converter/converter.go中,依次做出如下改变:
    • 新增protocolXXX常量,“XXX”为协议名,常量的值也为协议名
    • 如果协议支持新的编码方式,则新增encodingXXX常量,“XXX”为编码方式,常量的值也为编码方式
    • supportedEncodingMap中,增加该协议支持的编码类型
    • c.DoWithSelectedFields方法的switch语句中新增一个case子句,case名为协议名,子句内容为return c.ConvertToXXXProtocolLogs(logGroup, targetFields),其中涉及的函数即为第2步中编写的函数
    • c.ToByteStreamWithSelectedFields方法的switch语句中新增一个case子句,case名为协议名,子句内容为return c.ConvertToXXXProtocolStream(logGroup, targetFields),其中涉及的函数即为第2步中编写的函数
  2. ./doc/cn/developer-guide/log-protocol/converter.md的附录、README.md中增加协议相关内容,并在./doc/cn/developer-guide/log-protocol/protocol-spec文件夹下新增<protocol>.md文件描述具体的协议形式。

observability.cn Authors 2024 | Documentation Distributed under CC-BY-4.0
Copyright © 2017-2024, Alibaba. All rights reserved. Alibaba has registered trademarks and uses trademarks.
浙ICP备2021005855号-32