Webhooks 和 Cortex 集成

输入和输出集成概述

Webhooks 插件允许 Telegraf 通过 Webhooks 接收和处理来自各种外部服务的 HTTP 请求。此插件使用户能够收集实时指标和事件，并将它们集成到他们的监控解决方案中。

此插件使 Telegraf 能够使用 Prometheus remote write 协议将指标发送到 Cortex，从而实现无缝摄取到 Cortex 的可扩展、多租户时间序列存储中。

集成详情

Webhooks

此 Telegraf 插件旨在通过启动一个 HTTP 服务器来充当 webhook 监听器，该服务器注册多个 webhook 端点。它提供了一种通过捕获发送到已定义路径的 HTTP 请求来收集来自各种服务的事件的方法。每个服务都可以配置其特定的身份验证详细信息和请求处理选项。该插件的突出之处在于允许与任何 Telegraf 输出插件集成，使其成为事件驱动型架构的通用工具。通过实现高效的事件接收，它为实时监控和响应系统开辟了可能性，这对于需要即时事件处理和处理的现代应用程序至关重要。

Cortex

借助 Telegraf 的 HTTP 输出插件和 prometheusremotewrite 数据格式，您可以将指标直接发送到 Cortex，Cortex 是 Prometheus 的水平可扩展、长期存储后端。Cortex 支持多租户，并使用 Prometheus protobuf 格式接受远程写入请求。通过使用 Telegraf 作为收集代理和 Remote Write 作为传输机制，组织可以将可观测性扩展到 Prometheus 本身不支持的来源（例如 Windows 主机、启用 SNMP 的设备或自定义应用程序指标），同时利用 Cortex 的高可用性和长期保留能力。

配置

Webhooks

[[inputs.webhooks]]
  ## Address and port to host Webhook listener on
  service_address = ":1619"

  ## Maximum duration before timing out read of the request
  # read_timeout = "10s"
  ## Maximum duration before timing out write of the response
  # write_timeout = "10s"

  [inputs.webhooks.filestack]
    path = "/filestack"

    ## HTTP basic auth
    #username = ""
    #password = ""

  [inputs.webhooks.github]
    path = "/github"
    # secret = ""

    ## HTTP basic auth
    #username = ""
    #password = ""

  [inputs.webhooks.mandrill]
    path = "/mandrill"

    ## HTTP basic auth
    #username = ""
    #password = ""

  [inputs.webhooks.rollbar]
    path = "/rollbar"

    ## HTTP basic auth
    #username = ""
    #password = ""

  [inputs.webhooks.papertrail]
    path = "/papertrail"

    ## HTTP basic auth
    #username = ""
    #password = ""

  [inputs.webhooks.particle]
    path = "/particle"

    ## HTTP basic auth
    #username = ""
    #password = ""

  [inputs.webhooks.artifactory]
    path = "/artifactory"

Cortex

[[outputs.http]]
  ## Cortex Remote Write endpoint
  url = "http://cortex.example.com/api/v1/push"

  ## Use POST to send data
  method = "POST"

  ## Send metrics using Prometheus remote write format
  data_format = "prometheusremotewrite"

  ## Optional HTTP headers for authentication
  # [outputs.http.headers]
  #   X-Scope-OrgID = "your-tenant-id"
  #   Authorization = "Bearer YOUR_API_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"

输入和输出集成示例

Webhooks

1. 来自 Github 的实时通知：将 Webhooks 输入插件与 Github 集成，以接收有关事件（例如拉取请求、提交和问题）的实时通知。这使开发团队能够立即监控其存储库中的关键更改和更新，从而改善协作和响应时间。

2. 使用 Rollbar 进行自动化警报：使用此插件来监听从 Rollbar 报告的错误，使团队能够快速响应生产中的错误和问题。通过将这些警报转发到集中式监控系统，团队可以根据严重性确定响应的优先级，并防止停机时间升级。

3. 来自 Filestack 的性能监控：捕获来自 Filestack 的事件，以跟踪文件上传、转换和错误。此设置有助于企业了解用户与文件管理流程的交互，优化工作流程，并确保文件服务的高可用性。

4. 使用 Papertrail 进行集中式日志记录：通过 Webhooks 将发送到 Papertrail 的所有日志关联起来，从而使您可以巩固日志记录策略。借助实时日志转发，团队可以高效地分析趋势和异常，确保他们保持对关键操作的可见性。

Cortex

1. 统一的多租户监控：使用 Telegraf 从不同的团队或环境收集指标，并将它们与单独的 X-Scope-OrgID 标头推送到 Cortex。这实现了每个租户的隔离数据摄取和查询，非常适合托管服务和平台团队。

2. 将 Prometheus 覆盖范围扩展到边缘设备：在边缘或物联网设备上部署 Telegraf 以收集系统指标，并将它们发送到集中式 Cortex 集群。即使对于没有本地 Prometheus 抓取器的环境，这种方法也能确保一致的可观测性。

3. 具有联邦租户的全球服务可观测性：通过配置 Telegraf 代理将数据推送到区域 Cortex 集群（每个集群都标记有租户标识符）来聚合来自全球基础设施的指标。Cortex 处理跨区域的重复数据删除和集中式访问。

4. 自定义应用遥测管道：通过 Telegraf 的 exec 或 http 输入插件收集特定于应用的遥测数据，并将其转发到 Cortex。这使 DevOps 团队能够以可扩展、查询高效的格式监控特定于应用的关键绩效指标，同时保持指标按租户或服务逻辑分组。

反馈

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