Наблюдаемость пакета SDK для Azure Cosmos DB

Помимо получения журналов диагностики для неудачных запросов, можно настроить различные пороговые значения задержки для сбора диагностика из успешных запросов. Значения по умолчанию — 100 мс для операций с точками и 500 мс для операций, не являющихся точками. Эти пороговые значения можно настроить с помощью параметров клиента.

CosmosClientOptions options = new CosmosClientOptions()
{
    CosmosClientTelemetryOptions = new CosmosClientTelemetryOptions()
    {
        DisableDistributedTracing = false,
        CosmosThresholdOptions = new CosmosThresholdOptions()
        {
            PointOperationLatencyThreshold = TimeSpan.FromMilliseconds(100),
            NonPointOperationLatencyThreshold = TimeSpan.FromMilliseconds(500)
        }
    },
};

Вы можете настроить уровень журнала для управления тем, какие диагностика журналы вы получаете.

В зависимости от среды приложения существуют различные способы настройки уровня журнала. Ниже приведен пример конфигурации в appSettings.json:

{ 
    "Logging": {​
        "LogLevel": {​
            "Azure-Cosmos-Operation-Request-Diagnostics": "Information"​
        }​
    }
}

Помимо получения журналов диагностики для неудачных запросов, можно настроить различные условия для сбора диагностика из успешных запросов. Условия включают порог задержки для операций с точками и неточечных операций, а также пороговое значение для запросов, превышающих количество единиц ЕЗ. Эти пороговые значения можно задать в клиенте Azure Cosmos DB.

    CosmosAsyncClient client = new CosmosClientBuilder()
            .endpoint("<Your account endpoint>")
            .key("<Your account key>")
            .clientTelemetryConfig(new CosmosClientTelemetryConfig()
                .diagnosticsThresholds(
                    new CosmosDiagnosticsThresholds()
                        .setPointOperationLatencyThreshold(Duration.ofMillis(100))
                        .setNonPointOperationLatencyThreshold(Duration.ofMillis(2000))
                        .setRequestChargeThreshold(100)))
            .buildAsyncClient();

Чтобы использовать OpenTelemetry с пакетом SDK для .NET Для Azure Cosmos DB, добавьте Azure.Cosmos.Operation источник в поставщик трассировки. OpenTelemetry совместим с многими экспортерами, которые могут получать данные. В следующем примере используется, Azure Monitor OpenTelemetry Exporterно вы можете настроить любой нужный экспортер. В зависимости от выбранного экспортера может появиться задержка приема данных до нескольких минут.

В этом примере показано, как настроить OpenTelemetry для консольного приложения .NET. Полный пример см. на сайте GitHub.

ResourceBuilder resource = ResourceBuilder.CreateDefault().AddService(
            serviceName: serviceName,
            serviceVersion: "1.0.0");

// Set up logging to forward logs to chosen exporter
using ILoggerFactory loggerFactory
    = LoggerFactory.Create(builder => builder
                                        .AddConfiguration(configuration.GetSection("Logging"))
                                        .AddOpenTelemetry(options =>
                                        {
                                            options.IncludeFormattedMessage = true;
                                            options.SetResourceBuilder(resource);
                                            options.AddAzureMonitorLogExporter(o => o.ConnectionString = aiConnectionString); // Set up exporter of your choice
                                        }));
/*.AddFilter(level => level == LogLevel.Error) // Filter  is irrespective of event type or event name*/

AzureEventSourceLogForwarder logforwader = new AzureEventSourceLogForwarder(loggerFactory);
logforwader.Start();

// Configure OpenTelemetry trace provider
AppContext.SetSwitch("Azure.Experimental.EnableActivitySource", true);
_traceProvider = Sdk.CreateTracerProviderBuilder()
    .AddSource("Azure.Cosmos.Operation", // Cosmos DB source for operation level telemetry
               "Sample.Application") 
    .AddAzureMonitorTraceExporter(o => o.ConnectionString = aiConnectionString) // Set up exporter of your choice
    .AddHttpClientInstrumentation() // Added to capture HTTP telemetry
    .SetResourceBuilder(resource)
    .Build();

Настройка SDK Application Insights

Существует множество различных способов настройки Application Insights в зависимости от языка, в который записывается приложение, и в вычислительной среде. Дополнительные сведения см. в документации по Application Insights. Прием данных в Application Insights может занять до нескольких минут.

В следующем примере показано, как настроить Application Insights для консольного приложения .NET. Полный пример см. на сайте GitHub.

IServiceCollection services = new ServiceCollection();
services.AddApplicationInsightsTelemetryWorkerService((ApplicationInsightsServiceOptions options) => options.ConnectionString = aiConnectionString);

IServiceProvider serviceProvider = services.BuildServiceProvider();
telemetryClient = serviceProvider.GetRequiredService<TelemetryClient>();

После приема данных трассировки в Application Insights его можно визуализировать в портал Azure, чтобы понять поток запросов в приложении. Ниже приведен пример данных трассировки из запроса между секциями в поиске транзакций в левой области навигации портал Azure.

1. Скачайте jar-файл Application Insights из каталога выпусков.
2. Наведите JVM на JAR-файл, добавив -javaagent:"path/to/applicationinsights-agent-x.x.xx.jar" в args JVM приложения.
3. Настройка переменной среды с помощью строка подключения Application Insights

   APPLICATIONINSIGHTS_CONNECTION_STRING=<Your Connection String>