flume plugin haproxyHAProxy日志解析与Flume序列化器配置

HAProxyLogAvroEventSerializer 用于解析 HAProxy HTTP日志 的 Flume序列化器，解析过程通过 正则表达式 完成，因此可以轻松适应不同的日志格式。日志行的各个部分被拆分为不同的 Avro字段，方便后续的查询和分析。

构建并打包插件使用以下命令：

```bash

$ mvn clean package

```

将生成的文件放入 Flume库目录 或者添加到 Flume类路径 中。以下是一个示例配置：

```properties

agent.sinks.hdfssink.type=hdfs

agent.sinks.hdfssink.channel=memChannel

agent.sinks.hdfssink.hdfs.path=/user/cloudera/ymd=%Y%m%d/hour=%H

agent.sinks.hdfssink.hdfs.fileType=DataStream

agent.sinks.hdfssink.serializer=nl.te

```

该配置将 HAProxy 日志通过 Flume 存储到 HDFS 中，路径根据日期和小时动态生成。

HAProxy日志解析 的关键是灵活调整正则表达式以适应不同的日志格式，从而确保数据可以顺利流入后端存储或分析系统。