mishasel/prometheus_amqp_proxy

Prometheus AMQP代理镜像

镜像概述

该镜像提供一个代理服务，用于将Prometheus抓取请求转发至AMQP RPC源（如RabbitMQ），并将获取到的监控数据返回给Prometheus，实现从消息队列中采集监控指标的功能。

核心功能

1. 作为Prometheus与AMQP服务之间的中间代理，处理数据转发；
2. 支持通过参数配置AMQP连接URL和交换器；
3. 接收Prometheus的HTTP请求，向指定AMQP队列发送RPC请求并返回数据；
4. 兼容Prometheus的relabel配置，方便集成到现有监控体系。

使用场景

• 微服务架构中，需要从AMQP消息队列获取分布式服务的监控指标；
• 监控系统需要通过RPC方式从消息队列中采集非直接暴露HTTP接口的服务指标；
• 希望将AMQP源的监控数据统一纳入Prometheus的监控体系。

配置说明

构建与运行（使用Bazel）

bash
bazel run //proxy:proxy -- -amqp_url=amqp://my_rabbitmq_url/ -amqp_exchange=my_prometheus_exchange

启动后，访问http://localhost:8200/proxy?target=prometheus会向my_prometheus_exchange交换器中的prometheus队列发送AMQP RPC请求，并返回数据。

Docker部署示例

bash
docker run -d -p 8200:8200 mishasel/prometheus_amqp_proxy --amqp_url=amqp://rabbitmq_host:5672/ --amqp_exchange=prometheus_exchange

Prometheus配置示例

在Prometheus配置文件中添加以下 scrape 配置：

yaml
scrape_configs:
  - job_name: 'amqp_proxy'
    metrics_path: '/proxy'
    target_groups:
      - targets: ['queue1', 'queue2']  # 替换为实际的AMQP队列名称
    relabel_configs:
      - source_labels: [__address__]
        regex: (.*)
        target_label: __param_target
        replacement: ${1}
      - source_labels: [__param_target]
        regex: (.*)
        target_label: instance
        replacement: ${1}
      - source_labels: []
        regex: .*
        target_label: __address__
        replacement: localhost:8200  # 替换为AMQP代理服务的地址和端口