Graylog 显示Geo IP

Benny小土豆

1 年前

文章目录[显示]

Graylog基础配置、收集docker日志

这篇文章在 2023年04月21日17:20:34 更新了哦~

几周前不知道为什么，yyets的内存使用率暴涨，直接给我机器弄没了。

内核的OOM机制都没起作用，猜测可能是dockerd的默认的OOM score是-500，导致没人敢杀吧。最近这几天配置上了Graylog来收集日志，下次再出现问题可以看日志了，大概这样：

Graylog基础配置、收集docker日志

配置Graylog倒是很容易，docker-compose一把梭，docker也恰巧支持GELF协议。Graylog装好之后，配置一个GELF的input，如下图所示

小提示，如果你的Graylog是用docker起的，那么在publish port时要额外注意，docker默认只publish TCP，所以要 -p 127.0.0.1:12201:12201/udp

确认运行起来之后，可以开一个容器试试看，注意这里要写127.0.0.1，写localhost的话，dockerd可能会给搞很多幺蛾子~~(解析到IPv6给你颜色看看）~~。

docker run --log-driver gelf --log-opt gelf-address=udp://127.0.0.1:12201 alpine echo hello world

也可以选择用nc发一条消息看看

echo -n '{ "version": "1.1", "host": "example.org", "short_message": "A short message again", "level": 5, "_some_info": "foo" }' | nc -w1 -u localhost 12201

配置无误的话就应该已经能在搜索页面看到日志了

配置GeoIP

Graylog带有GeoIP的支持，可以自动通过MaxMind的数据库显示访客的IP地址。配置起来比较麻烦，并且文档非常模糊不清🤣

启用Geo-Location Processor

首先要启用这个模块，在System - Configurations最下面可以看到。需要自己去下载数据库

懒得注册账号的可以去这里下载

https://github.com/P3TERX/GeoLite.mmdb

这里的City库比较新

https://github.com/wp-statistics/GeoLite2-City

下载好之后放到某个目录，确保Graylog有权限访问，确认就行了，我就直接丢到了宿主机的volume的目录

调整处理顺序

System- Configurations，最上面看 Message Processors Configuration 确保GeoIP Resolve而已经启用，并且顺序正确，至少要放到pipeline后，我给放到最后了

Lookup Table – Adapters

要创建Adapters，路径是 System- Lookup Tables- Data Adapters，Data Adapter Type选择 GeoIP的那个

Lookup Table – Cache

中间的那个标签页，创建一个cache

Lookup Tables

终于可以创建Lookup Tables了，最左侧的标签页，选择刚刚创建好的adapter和cache。这个Name是唯一的，下一步要用，记下来哦。

创建Pipelines

😓还没完，还要创建pipeline去调用Lookup Table

创建pipeline rules

System - Pipelines - Manage rules - Create rule

rule source是核心，定义了怎么取IP、解析后怎样呈现数据。拿我的一行log为例：

如果你的IP地址是单独的一个字段中，比如上面的source、container_name这种单独的一行，那么就很容易了，比如说你的字段叫 src_ip

rule "GeoIP lookup"
when
    has_field("src_ip")
then
    let geo = lookup("geoip", $message.src_ip);
    set_field("src_ip_geo_location", geo["coordinates"]);
    set_field("src_ip_geo_country", geo["country"].iso_code);
    set_field("src_ip_geo_city", geo["city"].names.en);
end

很好理解，如果src_ip 字段存在，就用geoip这个Lookup Table查询，还记得吧，这个geoip是上一步Lookup Table的Name。

如果你的日志是像我这种，IP记录在message中，那就这样，先用grok去提取IP地址，然后再进行查询

rule "GeoIP lookup"
when
    has_field("message")
then
    let ipObj = grok(pattern: "(%{IP})", value: to_string($message.message));
    // ipObj.IP 就是真正的IP地址，可能是IPv4 也可能是IPv6
    let geo = lookup("geoip", ipObj.IP); 
    set_field("src_ip_geo_location", geo["coordinates"]);
    set_field("src_ip_geo_country", geo["country"].iso_code);
    set_field("src_ip_geo_city", geo["city"].names.en);
end

但是这样还不是很完美，仔细观察，我的log的IP是在()包围中的，有些时候我也会用logging.info去记录IP，那么这样子就会重复了。想当然的，这东西看起来是正则表达式的样子，那么(\(%{IP}\))😎辣鸡Graylog会直接给你报错，无法保存

这个时候要做的事情是创建一个新的 Grok规则，然后去应用，如图所示，Pattern为 \(%{IP}\)名字随便起一个