歡迎光臨
每天分享高質量文章

使用 Python 和 Prometheus 跟蹤天氣 | Linux 中國

創建自定義 Prometheus 集成以跟蹤最大的雲端提供商:地球母親。

— Moshe Zadka

 

開源監控系統 Prometheus 集成了跟蹤多種型別的時間序列資料,但如果沒有集成你想要的資料,那麼很容易構建一個。一個經常使用的例子使用雲端提供商的自定義集成,它使用提供商的 API 抓取特定的指標。但是,在這個例子中,我們將與最大雲端提供商集成:地球。

幸運的是,美國政府已經測量了天氣併為集成提供了一個簡單的 API。獲取紅帽總部下一個小時的天氣預報很簡單。

  1. import requests
  2. HOURLY_RED_HAT = ""
  3. def get_temperature():
  4. result = requests.get(HOURLY_RED_HAT)
  5. return result.json()["properties"]["periods"][0]["temperature"]

現在我們已經完成了與地球的集成,現在是確保 Prometheus 能夠理解我們想要內容的時候了。我們可以使用 Prometheus Python 庫中的 gauge 創建一個註冊項:紅帽總部的溫度。

  1. from prometheus_client import CollectorRegistry, Gauge
  2. def prometheus_temperature(num):
  3. registry = CollectorRegistry()
  4. g = Gauge("red_hat_temp", "Temperature at Red Hat HQ", registry=registry)
  5. g.set(num)
  6. return registry

最後,我們需要以某種方式將它連接到 Prometheus。這有點依賴 Prometheus 的網絡拓撲:是 Prometheus 與我們的服務通信更容易,還是反向更容易。

第一種是通常建議的情況,如果可能的話,我們需要構建一個公開註冊入口的 Web 服務器,並配置 Prometheus 收刮(scrape)它。

我們可以使用 Pyramid 構建一個簡單的 Web 服務器。

  1. from pyramid.config import Configurator
  2. from pyramid.response import Response
  3. from prometheus_client import generate_latest, CONTENT_TYPE_LATEST
  4. def metrics_web(request):
  5. registry = prometheus_temperature(get_temperature())
  6. return Response(generate_latest(registry),
  7. content_type=CONTENT_TYPE_LATEST)
  8. config = Configurator()
  9. config.add_route('metrics', '/metrics')
  10. config.add_view(metrics_web, route_name='metrics')
  11. app = config.make_wsgi_app()

這可以使用任何 Web 網關接口(WSGI)服務器運行。例如,假設我們將代碼放在 earth.py中,我們可以使用 python -m twisted web --wsgi earth.app 來運行它。

或者,如果我們的代碼連接到 Prometheus 更容易,我們可以定期將其推送到 Prometheus 的推送網關

  1. import time
  2. from prometheus_client import push_to_gateway
  3. def push_temperature(url):
  4. while True:
  5. registry = prometheus_temperature(get_temperature())
  6. push_to_gateway(url, "temperature collector", registry)
  7. time.sleep(60*60)

這裡的 URL 是推送網關的 URL。它通常以 :9091 結尾。

祝你構建自定義 Prometheus 集成成功,以便跟蹤一切!

已同步到看一看
赞(0)

分享創造快樂