山东专业企业网站建设,票务网站开发端口,我的世界用自己皮肤做壁纸网站,长沙做网站zwnet1、前言 上篇文章介绍了nginx通过nginx_upstream_check_module模块实现后端健康检查#xff0c;这篇介绍一下如何自定义prometheus监控获取nginx的upstream指标来实时监控nginx。
2、nginx_upstream_status状态
支持以下三种方式查看nginx_upstream的状态 /status?formatht…1、前言 上篇文章介绍了nginx通过nginx_upstream_check_module模块实现后端健康检查这篇介绍一下如何自定义prometheus监控获取nginx的upstream指标来实时监控nginx。
2、nginx_upstream_status状态
支持以下三种方式查看nginx_upstream的状态 /status?formathtml /status?formatcsv /status?formatjson 【本文监控使用方式】 3、Python脚本自定义prometheus监控
# -*- coding:utf-8 -*-
import requests
import prometheus_client
import time
from prometheus_client import Counter, Gauge, Summary
from prometheus_client.core import CollectorRegistry
from flask import Flask, Response
from wsgiref.simple_server import make_serverapp Flask(__name__)class Monitor:def __init__(self):self.collector_registry CollectorRegistry(auto_describeTrue)self.ngx_uptream_status_gauge Gauge(namengx_uptream_status,documentationnginx upstream status,labelnames(env, nginxUrl, upstreamName, upstreamAddress),registryself.collector_registry)self.ngx_status_gauge Gauge(namengx_status,documentationnginx status,labelnames(env, nginxUrl),registryself.collector_registry)# 获取/metrics结果def get_prometheus_metrics_info(self):return self.collector_registrydef get_ngx_uptream_status(self):ngx_list [{ngx_env: test, ngx_status_url: http://192.168.100.210:8888/nginx_status?formatjson}]for ngx_info in ngx_list:ngxEnv ngx_info[ngx_env]ngxStatusUrl ngx_info[ngx_status_url]try:requests.get(ngxStatusUrl, timeout2)except:self.ngx_status_gauge.labels(ngxEnv, http:// ngxStatusUrl.split(/)[2]).set(0)print(time.strftime(%Y-%m-%d %H:%M:%S, time.localtime()) ngxStatusUrl 请求异常)else:self.ngx_status_gauge.labels(ngxEnv, http:// ngxStatusUrl.split(/)[2]).set(1)ngxInfo requests.get(ngxStatusUrl)ngxInfo.encoding utf-8ngxInfoJson ngxInfo.json()print(time.strftime(%Y-%m-%d %H:%M:%S, time.localtime()) ngxStatusUrl 请求数据: str(ngxInfoJson))ngxServerList ngxInfoJson[servers][server]if len(ngxServerList) 0:print(time.strftime(%Y-%m-%d %H:%M:%S, time.localtime()) ngxStatusUrl 请配置upstream检测)else:for server in ngxServerList:upstream server[upstream]upstreamAddr server[name]nginxUrl http:// ngxStatusUrl.split(/)[2]status server[status]if status up:upstreamStatus 1else:upstreamStatus 0self.ngx_uptream_status_gauge.labels(ngxEnv, nginxUrl, upstream, upstreamAddr).set(upstreamStatus)app.route(/metrics, methods[POST, GET])
def metrics():g_monitor Monitor()g_monitor.get_ngx_uptream_status()registry g_monitor.get_prometheus_metrics_info()return Response(prometheus_client.generate_latest(registry), mimetypetext/plain)if __name__ __main__:server make_server(0.0.0.0, 3200, app)server.serve_forever()
4、运行Python脚本并调用接口获取metrics Python脚本以flask服务的形式运行通过/nginx_status?formatjson接口获取到nginx_upstream的指标数据后转换为prometheus可接受的数据形式然后对接到prometheus即可监控。
