将 Flink 与 Datadog 集成

Integrating Flink with Datadog

我有几个关于 Flink 和 Datadog 集成的问题。首先，问题是 Datadog 使用 dogstatsD 而不是 Flink 文档中未包含的 statsD

另一个问题是，如果您转到 Datadog 的 Integrations 页面，则缺少 Flink 集成。我已经尝试安装 Graphite，但由于 python 3.6，我也遇到了一些问题，我也尝试了 virtualenv，但想到了 datadog，这也让我很困难。

两种可能有效的方法：

  1. 看起来 flink 有一个 HTTP connector 来向 Datadog 发送指标，乍一看它发送的是 Datadog 指标 API 而不是 dogstatsd。

  2. Dogstatsd 在其他方面与 statsd 没有太大区别，因此通常很容易修改 statsd 库以使其适用于 dogstatsd。 This project on GitHub好像是这样的项目，说不定能派上用场。