ActiveMQ 和 Thanos 集成

输入和输出集成概述

ActiveMQ 输入插件通过其控制台 API 从 ActiveMQ 消息代理收集指标，从而深入了解消息队列、主题和订阅者的性能和状态。

此插件使用 Prometheus 远程写入协议通过 HTTP 将指标从 Telegraf 发送到 Thanos，从而可以高效且可扩展地摄取到 Thanos Receive 组件中。

集成详情

ActiveMQ

ActiveMQ 输入插件与 ActiveMQ 控制台 API 接口，以收集与队列、主题和订阅者相关的指标。 ActiveMQ 是一种广泛使用的开源消息代理，支持各种消息协议，并提供强大的 Web 控制台用于管理和监控。 此插件允许用户跟踪关键指标，包括队列大小、消费者计数和不同 ActiveMQ 实体中的消息计数，从而增强消息传递系统内的可观察性。 用户可以配置各种参数，例如 WebConsole URL 和基本身份验证凭据，以根据其环境定制插件。 收集的指标可用于监控消息传递应用程序的运行状况和性能，从而促进主动管理和故障排除。

Thanos

Telegraf 的 HTTP 插件可以通过其 Remote Write 兼容的 Receive 组件将指标直接发送到 Thanos。 通过将数据格式设置为 prometheusremotewrite，Telegraf 可以将指标序列化为本机 Prometheus 客户端使用的相同基于 protobuf 的格式。 此设置实现了高吞吐量、低延迟的指标摄取到 Thanos 中，从而促进了大规模的集中式可观察性。 这在混合环境中尤其有用，在这些环境中，Telegraf 从 Prometheus 本机范围之外的系统（例如 SNMP 设备、Windows 主机或自定义应用程序）收集指标，并将它们直接流式传输到 Thanos 以进行长期存储和全局查询。

配置

ActiveMQ

[[inputs.activemq]]
  ## ActiveMQ WebConsole URL
  url = "http://127.0.0.1:8161"

  ## Required ActiveMQ Endpoint
  ##   deprecated in 1.11; use the url option
  # server = "192.168.50.10"
  # port = 8161

  ## Credentials for basic HTTP authentication
  # username = "admin"
  # password = "admin"

  ## Required ActiveMQ webadmin root path
  # webadmin = "admin"

  ## Maximum time to receive response.
  # response_timeout = "5s"

  ## Optional TLS Config
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"
  ## Use TLS but skip chain & host verification
  # insecure_skip_verify = false

Thanos

[[outputs.http]]
  ## Thanos Receive endpoint for remote write
  url = "http://thanos-receive.example.com/api/v1/receive"

  ## HTTP method
  method = "POST"

  ## Data format set to Prometheus remote write
  data_format = "prometheusremotewrite"

  ## Optional headers (authorization, etc.)
  # [outputs.http.headers]
  #   Authorization = "Bearer YOUR_TOKEN"

  ## Optional TLS configuration
  # tls_ca = "/path/to/ca.pem"
  # tls_cert = "/path/to/cert.pem"
  # tls_key = "/path/to/key.pem"
  # insecure_skip_verify = false

  ## Request timeout
  timeout = "10s"

输入和输出集成示例

ActiveMQ

1. 主动队列监控：使用 ActiveMQ 插件实时监控高容量交易应用程序的队列大小。 此实现允许团队在队列大小超过特定阈值时接收警报，从而对积压造成的潜在停机做出快速响应，从而确保交易操作的持续可用性。

2. 性能基线和异常检测：将此插件与机器学习框架集成，以建立消息吞吐量的性能基线。 通过分析通过此插件收集的历史数据，团队可以标记处理速率中的异常，从而更快地识别影响服务可靠性和性能的问题。

3. 跨消息传递系统分析：将来自 ActiveMQ 的指标与来自集中式仪表板中其他消息传递系统的指标结合起来。 用户可以可视化和比较性能数据（例如入队和出队速率），从而深入了解整体消息传递架构，并帮助优化不同代理之间的消息流。

4. 订阅者性能洞察：利用此插件收集的订阅者指标来分析行为模式并优化消费者应用程序的配置。 了解诸如已调度的队列大小和计数器值之类的指标可以指导调整，以提高处理效率和资源分配。

Thanos

1. 无代理云监控：在云虚拟机上部署 Telegraf 代理以收集系统和应用程序指标，然后使用 Remote Write 将它们直接流式传输到 Thanos。 这提供了集中式可观察性，而无需在每个位置都部署 Prometheus 节点。

2. 可扩展的 Windows 主机监控：在 Windows 计算机上使用 Telegraf 收集操作系统级别指标，并通过 Remote Write 将它们发送到 Thanos Receive。 这实现了跨异构环境的可观察性，而本机 Prometheus 仅在 Linux 上受支持。

3. 跨区域指标联合：多个地理区域中的 Telegraf 代理可以使用此插件将数据推送到区域本地 Thanos Receivers。 从那里，Thanos 可以全局去重和查询指标，从而减少延迟和网络出口成本。

4. 将第三方数据集成到 Thanos 中：使用 Telegraf 输入从自定义遥测源（例如 REST API 或专有日志）收集指标，并通过 Remote Write 将它们转发到 Thanos。 这将非原生数据带入与 Prometheus 兼容的长期分析管道中。

反馈

感谢您成为我们社区的一份子！ 如果您有任何一般反馈或在这些页面上发现任何错误，我们欢迎并鼓励您提出意见。 请在InfluxDB 社区 Slack中提交您的反馈。