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

開源監控系統 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 整合成功，以便跟蹤一切！