文章轉載自：https://elasticstack.blog.csdn.net/article/details/118145104

需要學習的是httpjson請求的寫法

使用 Filebeat 的 HTTP JSON input 來對微服務的資料進行採集。我們知道 Beats 的架構是屬於一種輕量級的部署。可以直接運用於客戶端，或者需要採集的伺服器中。

建立 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 每5秒會發送一個請求到微服務中得到天氣的資料。