示例介绍
本示例是一个基于实践场景下的用例。该场景包括了日志收集、解析、入多个库、监控,上面是该用例的示意图。

- wpgen定期向文件、fluent-bit TCP、Kafka发送数据,模拟日志来源。
- fluent-bit收集文件日志、监听5170端口,将日志转发到wparse做解析。
- wparse监听TCP和Kafka,将接收各类日志进行解析和分类,并根据日志类型(目前只有nginx)转发到不同的输出源,如kafka、文件、vlogs。
部署结构

可以使用vlogs进行查看:各类日志Vlog地址
查询kafka输入的日志
查询TCP输入的日志

监控
本例子使用Victoria-metrics对fluent-bit、kafka、以及wparse几个关键组件的监控。外部可以使用grafana进行监控:相关链接

wp-monitor监控
wp-monitor是我司自研的一款基于系统结构的指标展示组件,链接:http://106.55.164.250:25816/wp-monitor。

grafana监控
账号:
- grafana账号:admin
- grafana密码:admin
目前我们提供了kafka和wparse的仪表盘
项目使用
前置条件:可以拉取docker-copmose中的镜像,并且镜像的CPU架构一致
方式1 手工启动(MAC推荐)
-
进入工作目录:
cd wp-examples/extensions/practice -
将fluent-bit.yml中输出地址信息改为实际的wparse地址:

-
启动docker相关组件:
docker compose up -d -
进入wparse工作目录:
cd parse-work -
启动wparse:
wparse daemon --stat 10 -p> data/logs/wparse-info.log 2>&1 & -
启动发送相关工具:
wpgen sample -c wpgen-kafka.toml --stat 10 -p > data/logs/wpgen-kafka.log 2>&1 &wpgen sample -c wpgen-tcp.toml --stat 10 -p > data/logs/wpgen-tcp.log 2>&1 &wpgen sample -c wpgen-file.toml --stat 10 -p > data/logs/wpgen-file.log 2>&1 &
方式二 一键化启动脚本
脚本依赖于nohup,一般linux会带此工具
- 进入工作目录:
cd wp-examples/extensions/practice - 将fluent-bit.yml中输出地址信息改为实际的wparse地址:

- 启动docker相关组件:
docker compose up -d - 执行:
./run.sh - 停止:
./stop.sh

