appdynamics, datadog, newrelic, victoriametrics

asmyasnikov · asmyasnikov · commit 8dc897cece83 · 2025-03-21T16:26:22.000+03:00
diff --git a/docs/monitoring.md b/docs/monitoring.md
@@ -71,6 +71,90 @@ TOpenTelemetryMetric metric("ydb_query_count", "1", labels);
 TMetricsContext::Instance().RecordMetric(metric);
 ```
 
+### Datadog
+
+```cpp
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <ydb-cpp-sdk/client/monitoring/impl/datadog.h>
+
+// Создаем систему мониторинга
+auto monitoringSystem = TMonitoringSystemFactory::CreateDatadog("your-api-key");
+TMetricsContext::Instance().SetMonitoringSystem(std::move(monitoringSystem));
+
+// Создаем метрику
+std::unordered_map<std::string, std::string> labels = {
+    {"operation", "query"},
+    {"status", "success"}
+};
+TDatadogMetric metric("ydb.query.count", "1", labels);
+
+// Записываем метрику
+TMetricsContext::Instance().RecordMetric(metric);
+```
+
+### New Relic
+
+```cpp
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <ydb-cpp-sdk/client/monitoring/impl/newrelic.h>
+
+// Создаем систему мониторинга
+auto monitoringSystem = TMonitoringSystemFactory::CreateNewRelic("your-license-key");
+TMetricsContext::Instance().SetMonitoringSystem(std::move(monitoringSystem));
+
+// Создаем метрику
+std::unordered_map<std::string, std::string> labels = {
+    {"operation", "query"},
+    {"status", "success"}
+};
+TNewRelicMetric metric("Custom/ydb/query_count", "1", labels);
+
+// Записываем метрику
+TMetricsContext::Instance().RecordMetric(metric);
+```
+
+### AppDynamics
+
+```cpp
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <ydb-cpp-sdk/client/monitoring/impl/appdynamics.h>
+
+// Создаем систему мониторинга
+auto monitoringSystem = TMonitoringSystemFactory::CreateAppDynamics("http://your-controller:8090");
+TMetricsContext::Instance().SetMonitoringSystem(std::move(monitoringSystem));
+
+// Создаем метрику
+std::unordered_map<std::string, std::string> labels = {
+    {"operation", "query"},
+    {"status", "success"}
+};
+TAppDynamicsMetric metric("Custom Metrics|YDB|Query Count", "1", labels);
+
+// Записываем метрику
+TMetricsContext::Instance().RecordMetric(metric);
+```
+
+### Victoria Metrics
+
+```cpp
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <ydb-cpp-sdk/client/monitoring/impl/victoriametrics.h>
+
+// Создаем систему мониторинга
+auto monitoringSystem = TMonitoringSystemFactory::CreateVictoriaMetrics("http://localhost:8428");
+TMetricsContext::Instance().SetMonitoringSystem(std::move(monitoringSystem));
+
+// Создаем метрику
+std::unordered_map<std::string, std::string> labels = {
+    {"operation", "query"},
+    {"status", "success"}
+};
+TVictoriaMetricsMetric metric("ydb_query_count", "1", labels);
+
+// Записываем метрику
+TMetricsContext::Instance().RecordMetric(metric);
+```
+
 ## Доступные метрики
 
 YDB C++ SDK собирает следующие метрики:
diff --git a/examples/monitoring/appdynamics_example.cpp b/examples/monitoring/appdynamics_example.cpp
@@ -0,0 +1,28 @@
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <ydb-cpp-sdk/client/monitoring/impl/appdynamics.h>
+#include <ydb-cpp-sdk/client/driver/driver.h>
+#include <iostream>
+
+using namespace NYdb;
+using namespace NYdb::NMonitoring;
+
+int main() {
+    // Создаем систему мониторинга AppDynamics
+    auto monitoringSystem = TMonitoringSystemFactory::CreateAppDynamics("http://your-controller:8090");
+    TMetricsContext::Instance().SetMonitoringSystem(std::move(monitoringSystem));
+
+    // Создаем метрику
+    std::unordered_map<std::string, std::string> labels = {
+        {"operation", "query"},
+        {"status", "success"}
+    };
+    TAppDynamicsMetric metric("Custom Metrics|YDB|Query Count", "1", labels);
+
+    // Записываем метрику
+    TMetricsContext::Instance().RecordMetric(metric);
+
+    // Принудительно отправляем метрики
+    TMetricsContext::Instance().Flush();
+
+    return 0;
+} 
diff --git a/examples/monitoring/datadog_example.cpp b/examples/monitoring/datadog_example.cpp
@@ -0,0 +1,28 @@
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <ydb-cpp-sdk/client/monitoring/impl/datadog.h>
+#include <ydb-cpp-sdk/client/driver/driver.h>
+#include <iostream>
+
+using namespace NYdb;
+using namespace NYdb::NMonitoring;
+
+int main() {
+    // Создаем систему мониторинга Datadog
+    auto monitoringSystem = TMonitoringSystemFactory::CreateDatadog("your-api-key");
+    TMetricsContext::Instance().SetMonitoringSystem(std::move(monitoringSystem));
+
+    // Создаем метрику
+    std::unordered_map<std::string, std::string> labels = {
+        {"operation", "query"},
+        {"status", "success"}
+    };
+    TDatadogMetric metric("ydb.query.count", "1", labels);
+
+    // Записываем метрику
+    TMetricsContext::Instance().RecordMetric(metric);
+
+    // Принудительно отправляем метрики
+    TMetricsContext::Instance().Flush();
+
+    return 0;
+} 
diff --git a/examples/monitoring/newrelic_example.cpp b/examples/monitoring/newrelic_example.cpp
@@ -0,0 +1,28 @@
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <ydb-cpp-sdk/client/monitoring/impl/newrelic.h>
+#include <ydb-cpp-sdk/client/driver/driver.h>
+#include <iostream>
+
+using namespace NYdb;
+using namespace NYdb::NMonitoring;
+
+int main() {
+    // Создаем систему мониторинга New Relic
+    auto monitoringSystem = TMonitoringSystemFactory::CreateNewRelic("your-license-key");
+    TMetricsContext::Instance().SetMonitoringSystem(std::move(monitoringSystem));
+
+    // Создаем метрику
+    std::unordered_map<std::string, std::string> labels = {
+        {"operation", "query"},
+        {"status", "success"}
+    };
+    TNewRelicMetric metric("Custom/ydb/query_count", "1", labels);
+
+    // Записываем метрику
+    TMetricsContext::Instance().RecordMetric(metric);
+
+    // Принудительно отправляем метрики
+    TMetricsContext::Instance().Flush();
+
+    return 0;
+} 
diff --git a/examples/monitoring/victoriametrics_example.cpp b/examples/monitoring/victoriametrics_example.cpp
@@ -0,0 +1,28 @@
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <ydb-cpp-sdk/client/monitoring/impl/victoriametrics.h>
+#include <ydb-cpp-sdk/client/driver/driver.h>
+#include <iostream>
+
+using namespace NYdb;
+using namespace NYdb::NMonitoring;
+
+int main() {
+    // Создаем систему мониторинга Victoria Metrics
+    auto monitoringSystem = TMonitoringSystemFactory::CreateVictoriaMetrics("http://localhost:8428");
+    TMetricsContext::Instance().SetMonitoringSystem(std::move(monitoringSystem));
+
+    // Создаем метрику
+    std::unordered_map<std::string, std::string> labels = {
+        {"operation", "query"},
+        {"status", "success"}
+    };
+    TVictoriaMetricsMetric metric("ydb_query_count", "1", labels);
+
+    // Записываем метрику
+    TMetricsContext::Instance().RecordMetric(metric);
+
+    // Принудительно отправляем метрики
+    TMetricsContext::Instance().Flush();
+
+    return 0;
+} 
diff --git a/include/ydb-cpp-sdk/client/monitoring/impl/appdynamics.h b/include/ydb-cpp-sdk/client/monitoring/impl/appdynamics.h
@@ -0,0 +1,46 @@
+#pragma once
+
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <appdynamics/appdynamics.h>
+
+namespace NYdb::NMonitoring {
+
+class TAppDynamicsMetric : public IMetric {
+public:
+    TAppDynamicsMetric(const std::string& name, const std::string& value, 
+                      const std::unordered_map<std::string, std::string>& labels)
+        : Name_(name)
+        , Value_(value)
+        , Labels_(labels)
+    {}
+
+    std::string GetName() const override { return Name_; }
+    std::string GetValue() const override { return Value_; }
+    std::unordered_map<std::string, std::string> GetLabels() const override { return Labels_; }
+    std::string GetType() const override { return "counter"; }
+
+private:
+    std::string Name_;
+    std::string Value_;
+    std::unordered_map<std::string, std::string> Labels_;
+};
+
+class TAppDynamicsMonitoringSystem : public IMonitoringSystem {
+public:
+    explicit TAppDynamicsMonitoringSystem(const std::string& controllerUrl)
+        : ControllerUrl_(controllerUrl)
+    {
+        Initialize();
+    }
+
+    void RecordMetric(const IMetric& metric) override;
+    void Flush() override;
+    std::string GetSystemName() const override { return "appdynamics"; }
+
+private:
+    void Initialize();
+    std::string ControllerUrl_;
+    AppDynamics* Agent_;
+};
+
+} // namespace NYdb::NMonitoring 
diff --git a/include/ydb-cpp-sdk/client/monitoring/impl/datadog.h b/include/ydb-cpp-sdk/client/monitoring/impl/datadog.h
@@ -0,0 +1,48 @@
+#pragma once
+
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <datadog/tracing.h>
+#include <datadog/metrics.h>
+
+namespace NYdb::NMonitoring {
+
+class TDatadogMetric : public IMetric {
+public:
+    TDatadogMetric(const std::string& name, const std::string& value, 
+                   const std::unordered_map<std::string, std::string>& labels)
+        : Name_(name)
+        , Value_(value)
+        , Labels_(labels)
+    {}
+
+    std::string GetName() const override { return Name_; }
+    std::string GetValue() const override { return Value_; }
+    std::unordered_map<std::string, std::string> GetLabels() const override { return Labels_; }
+    std::string GetType() const override { return "counter"; }
+
+private:
+    std::string Name_;
+    std::string Value_;
+    std::unordered_map<std::string, std::string> Labels_;
+};
+
+class TDatadogMonitoringSystem : public IMonitoringSystem {
+public:
+    explicit TDatadogMonitoringSystem(const std::string& apiKey)
+        : ApiKey_(apiKey)
+    {
+        Initialize();
+    }
+
+    void RecordMetric(const IMetric& metric) override;
+    void Flush() override;
+    std::string GetSystemName() const override { return "datadog"; }
+
+private:
+    void Initialize();
+    std::string ApiKey_;
+    std::shared_ptr<datadog::tracing::Tracer> Tracer_;
+    std::shared_ptr<datadog::metrics::MetricsClient> MetricsClient_;
+};
+
+} // namespace NYdb::NMonitoring 
diff --git a/include/ydb-cpp-sdk/client/monitoring/impl/newrelic.h b/include/ydb-cpp-sdk/client/monitoring/impl/newrelic.h
@@ -0,0 +1,46 @@
+#pragma once
+
+#include <ydb-cpp-sdk/client/monitoring/metrics.h>
+#include <newrelic/newrelic.h>
+
+namespace NYdb::NMonitoring {
+
+class TNewRelicMetric : public IMetric {
+public:
+    TNewRelicMetric(const std::string& name, const std::string& value, 
+                    const std::unordered_map<std::string, std::string>& labels)
+        : Name_(name)
+        , Value_(value)
+        , Labels_(labels)
+    {}
+
+    std::string GetName() const override { return Name_; }
+    std::string GetValue() const override { return Value_; }
+    std::unordered_map<std::string, std::string> GetLabels() const override { return Labels_; }
+    std::string GetType() const override { return "counter"; }
+
+private:
+    std::string Name_;
+    std::string Value_;
+    std::unordered_map<std::string, std::string> Labels_;
+};
+
+class TNewRelicMonitoringSystem : public IMonitoringSystem {
+public:
+    explicit TNewRelicMonitoringSystem(const std::string& licenseKey)
+        : LicenseKey_(licenseKey)
+    {
+        Initialize();
+    }
+
+    void RecordMetric(const IMetric& metric) override;
+    void Flush() override;
+    std::string GetSystemName() const override { return "newrelic"; }
+
+private:
+    void Initialize();
+    std::string LicenseKey_;
+    NewRelic* App_;
+};
+
+} // namespace NYdb::NMonitoring 
diff --git a/include/ydb-cpp-sdk/client/monitoring/impl/victoriametrics.h b/include/ydb-cpp-sdk/client/monitoring/impl/victoriametrics.h
