Keyboard shortcuts

Press or to navigate between chapters

Press S or / to search in the book

Press ? to show this help

Press Esc to hide this help

示例介绍

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

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

部署结构

1767163018145

可以使用vlogs进行查看:各类日志Vlog地址

查询kafka输入的日志 1767163283607 查询TCP输入的日志 1767163217471

监控

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

wp-monitor监控

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

grafana监控

账号:

  • grafana账号:admin
  • grafana密码:admin

目前我们提供了kafka和wparse的仪表盘

项目使用

前置条件:可以拉取docker-copmose中的镜像,并且镜像的CPU架构一致

方式1 手工启动(MAC推荐)

  • 进入工作目录:cd wp-examples/extensions/practice

  • 将fluent-bit.yml中输出地址信息改为实际的wparse地址: 1767163583267

  • 启动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地址: 1767163583267
  • 启动docker相关组件:docker compose up -d
  • 执行:./run.sh
  • 停止:./stop.sh