ActiveMQ 和 Loki 集成

输入和输出集成概述

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

Loki 插件允许用户将日志发送到 Loki 进行聚合和查询，从而利用 Loki 高效的存储能力。

集成详情

ActiveMQ

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

Loki

此 Loki 插件与 Grafana Loki 集成，Grafana Loki 是一个强大的日志聚合系统。 通过以与 Loki 兼容的格式发送日志，此插件可以高效地存储和查询日志。 每个日志条目都以键值格式结构化，其中键表示字段名称，值表示相应的日志信息。 按时间戳对日志进行排序可确保日志流在通过 Loki 查询时保持时间顺序。 此插件对密钥的支持使其更容易安全地管理身份验证参数，而 HTTP 标头、gzip 编码和 TLS 配置选项增强了日志传输的适应性和安全性，从而满足各种部署需求。

配置

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

Loki

[[outputs.loki]]
  ## The domain of Loki
  domain = "https://loki.domain.tld"

  ## Endpoint to write api
  # endpoint = "/loki/api/v1/push"

  ## Connection timeout, defaults to "5s" if not set.
  # timeout = "5s"

  ## Basic auth credential
  # username = "loki"
  # password = "pass"

  ## Additional HTTP headers
  # http_headers = {"X-Scope-OrgID" = "1"}

  ## If the request must be gzip encoded
  # gzip_request = false

  ## Optional TLS Config
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"

  ## Sanitize Tag Names
  ## If true, all tag names will have invalid characters replaced with
  ## underscores that do not match the regex: ^[a-zA-Z_:][a-zA-Z0-9_:]*.
  # sanitize_label_names = false

  ## Metric Name Label
  ## Label to use for the metric name to when sending metrics. If set to an
  ## empty string, this will not add the label. This is NOT suggested as there
  ## is no way to differentiate between multiple metrics.
  # metric_name_label = "__name"

输入和输出集成示例

ActiveMQ

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

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

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

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

Loki

1. 微服务的集中式日志记录：利用 Loki 插件从 Kubernetes 集群中运行的多个微服务收集日志。 通过将日志定向到集中的 Loki 实例，开发人员可以在一个位置监控、搜索和分析来自所有服务的日志，从而更轻松地进行故障排除和性能监控。 此设置简化了操作，并支持对分布式应用程序中出现的问题做出快速响应。

2. 实时日志异常检测：将 Loki 与监控工具结合使用，以实时分析日志输出中可能表明系统错误或安全威胁的异常模式。 在日志流上实施异常检测使团队能够主动识别和响应事件，从而提高系统可靠性并增强安全态势。

3. 通过 Gzip 压缩增强日志处理：配置 Loki 插件以使用 gzip 压缩进行日志传输。 这种方法可以减少带宽使用并提高传输速度，这在网络带宽可能受到限制的环境中尤其有利。 它对于高容量日志记录应用程序尤其有用，在这些应用程序中，每个字节都很重要，并且性能至关重要。

4. 使用自定义标头进行多租户支持：利用添加自定义 HTTP 标头的功能来隔离多租户应用程序环境中的不同租户的日志。 通过使用 Loki 插件为每个租户发送不同的标头，运营商可以确保正确的日志管理并遵守数据隔离要求，使其成为 SaaS 应用程序的通用解决方案。

反馈

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