Beats：运用 Filebeat 来对微服务 API 进行分析

Posted 2021-06-29 Elastic 中国社区官方博客

在之前的文章 “Logstash：使用 ELK 堆栈进行 API 分析”，我展示了如何使用 Logstash 的 http_poller input plugin 来对微服务的 API 数据进行分析。如果我们只是为了对微服务的数据采集使用 Logstash，感觉有些 Logstash 有些大材小用了，比较 Logstash 的部署还是蛮耗资源的。相比较而言，我们可以使用 Filebeat 的 HTTP JSON input 来对微服务的数据进行采集。我们知道 Beats 的架构是属于一种轻量级的部署。可以直接运用于客户端，或者需要采集的服务器中。

 

创建 Filebeat 配置文件

首先，我们创建一个如下的 Filebeat 配置文件：

filebeat.yml

filebeat.inputs:
# Fetch your public IP every minute.
- type: httpjson
  config_version: 2
  interval: 5s
  request.url: http://api.openweathermap.org/data/2.5/weather?q=London,uk&APPID=7dbe7341764f682c2242e744c4f167b0&units=metric
  processors:
    - decode_json_fields:
        fields: ["message"]
        target: "json"

output.elasticsearch:
    hosts: ["localhost:9200"]

在上面，我们的配资非常简单直接。我们使用 httpjson input 来读取一个 HTTP 的 JSON 负载，并使用 decode_json_fields 来对它进行解析。在上面我们使用了一个微服务的 API 接口：http://api.openweathermap.org/data/2.5/weather?q=London,uk&APPID=7dbe7341764f682c2242e744c4f167b0&units=metric。它可以得到一个城市的天气情况。

我们把上面的配置文件置于 Filebeat 的安装根目录中，并使用如下的命令来对它进行启动：

./filebeat -e

从上面，我们可以看到 Filebeat 每5秒会发送一个请求到微服务中得到天气的数据。

我们回到 Kibana 中 进行查看：

我们可以看到被采集的数据。它们的间隔是5秒：

展开数据，我们可以看到被采集的数据。我们可以针对温度，湿度，风向等等进行数据分析。