Prometheus监控
概述
实现全面的Prometheus监控基础设施,用于收集、存储和查询来自应用程序和基础设施的时间序列指标。
何时使用
- 设置指标收集
- 创建自定义应用程序指标
- 配置抓取目标
- 实施服务发现
- 构建监控基础设施
指南
1. Prometheus配置
# /etc/prometheus/prometheus.yml
global:
scrape_interval: 15s
evaluation_interval: 15s
external_labels:
cluster: production
alerting:
alertmanagers:
- static_configs:
- targets: ['localhost:9093']
rule_files:
- '/etc/prometheus/alert_rules.yml'
scrape_configs:
- job_name: 'prometheus'
static_configs:
- targets: ['localhost:9090']
- job_name: 'node'
static_configs:
- targets: ['localhost:9100']
- job_name: 'api-service'
static_configs:
- targets: ['localhost:8080/metrics']
scrape_interval: 10s
- job_name: 'kubernetes-pods'
kubernetes_sd_configs:
- role: pod
relabel_configs:
- source_labels: [__meta_kubernetes_pod_annotation_prometheus_io_scrape]
action: keep
regex: 'true'
- source_labels: [__meta_kubernetes_pod_annotation_prometheus_io_path]
action: replace
target_label: __metrics_path__
2. Node.js指标实现
// metrics.js
const promClient = require('prom-client');
const register = new promClient.Registry();
promClient.collectDefaultMetrics({ register });
const httpRequestDuration = new promClient.Histogram({
name: 'http_request_duration_seconds',
help: 'HTTP请求持续时间',
labelNames: ['method', 'route', 'status_code'],
buckets: [0.1, 0.5, 1, 2, 5],
registers: [register]
});
const requestsTotal = new promClient.Counter({
name: 'requests_total',
help: '总请求数',
labelNames: ['method', 'route', 'status_code'],
registers: [register]
});
// Express中间件
const express = require('express');
const app = express();
app.get('/metrics', (req, res) => {
res.set('Content-Type', register.contentType);
res.end(register.metrics());
});
app.use((req, res, next) => {
const start = Date.now();
res.on('finish', () => {
const duration = (Date.now() - start) / 1000;
httpRequestDuration
.labels(req.method, req.path, res.statusCode)
.observe(duration);
requestsTotal
.labels(req.method, req.path, res.statusCode)
.inc();
});
next();
});
module.exports = { register, httpRequestDuration, requestsTotal };
3. Python Prometheus集成
from prometheus_client import Counter, Histogram, start_http_server
from flask import Flask, request
import time
app = Flask(__name__)
request_count = Counter('requests_total', '总请求数', ['method', 'endpoint'])
request_duration = Histogram('request_duration_seconds', '请求持续时间', ['method', 'endpoint'])
@app.before_request
def before():
request.start_time = time.time()
@app.after_request
def after(response):
duration = time.time() - request.start_time
request_count.labels(request.method, request.path).inc()
request_duration.labels(request.method, request.path).observe(duration)
return response
if __name__ == '__main__':
start_http_server(8000)
app.run(port=5000)
4. 告警规则
# /etc/prometheus/alert_rules.yml
groups:
- name: application
rules:
- alert: HighErrorRate
expr: rate(requests_total{status_code=~"5.."}[5m]) > 0.05
for: 5m
labels:
severity: critical
annotations:
summary: "高错误率: {{ $value }}"
- alert: HighLatency
expr: histogram_quantile(0.95, request_duration_seconds) > 1
for: 10m
labels:
severity: warning
annotations:
summary: "p95延迟: {{ $value }}s"
- alert: HighMemoryUsage
expr: node_memory_MemAvailable_bytes / node_memory_MemTotal_bytes < 0.1
for: 5m
labels:
severity: warning
annotations:
summary: "低内存: {{ $value }}"
5. Docker Compose设置
version: '3.8'
services:
prometheus:
image: prom/prometheus:latest
ports:
- "9090:9090"
volumes:
- ./prometheus.yml:/etc/prometheus/prometheus.yml
- ./alert_rules.yml:/etc/prometheus/alert_rules.yml
- prometheus_data:/prometheus
command:
- '--config.file=/etc/prometheus/prometheus.yml'
- '--storage.tsdb.path=/prometheus'
- '--storage.tsdb.retention.time=30d'
node-exporter:
image: prom/node-exporter:latest
ports:
- "9100:9100"
volumes:
prometheus_data:
最佳实践
✅ 应该做
- 使用一致的指标命名约定
- 添加全面的标签用于过滤
- 设置适当的抓取间隔(10-60s)
- 实施保留策略
- 监控Prometheus本身
- 在部署前测试告警规则
- 文档化指标含义
❌ 不应该做
- 添加无限制基数的标签
- 抓取太频繁(< 10s)
- 忽略指标命名约定
- 没有运行手册就创建告警
- 在Prometheus中存储原始事件数据
- 使用计数器作为类似仪表的值
关键Prometheus查询
rate(requests_total[5m]) # 请求率
histogram_quantile(0.95, request_duration_seconds) # p95延迟
rate(requests_total{status_code=~"5.."}[5m]) # 错误率