Rozwiązywanie problemów z zaawansowanymi zapytaniami diagnostycznymi za pomocą usługi Azure Cosmos DB for NoSQL

Artykuł
06/01/2023

DOTYCZY: NoSQL

W tym artykule omówiono sposób pisania bardziej zaawansowanych zapytań, aby ułatwić rozwiązywanie problemów z kontem usługi Azure Cosmos DB przy użyciu dzienników diagnostycznych wysyłanych do tabel Diagnostyka Azure (starsza wersja) i specyficznych dla zasobów (wersja zapoznawcza).

W przypadku tabel Diagnostyka Azure wszystkie dane są zapisywane w jednej tabeli. Użytkownicy określają kategorię, którą mają wykonywać zapytania. Jeśli chcesz wyświetlić zapytanie pełnotekstowe żądania, zobacz Monitorowanie danych usługi Azure Cosmos DB przy użyciu ustawień diagnostycznych na platformie Azure , aby dowiedzieć się, jak włączyć tę funkcję.

W przypadku tabel specyficznych dla zasobów dane są zapisywane w poszczególnych tabelach dla każdej kategorii zasobu. Zalecamy ten tryb, ponieważ:

Ułatwia pracę z danymi.
Zapewnia lepszą możliwość odnajdywania schematów.
Zwiększa wydajność zarówno opóźnienia pozyskiwania, jak i czasu wykonywania zapytań.

Typowe zapytania

Typowe zapytania są wyświetlane w tabelach specyficznych dla zasobów i Diagnostyka Azure.

Pierwsze zapytania N(10) uporządkowane według użycia jednostek żądań (RU) w określonym przedziale czasu

Specyficzne dla zasobu
Diagnostyka Azure

let topRequestsByRUcharge = CDBDataPlaneRequests 
| where TimeGenerated > ago(24h)
| project  RequestCharge , TimeGenerated, ActivityId;
CDBQueryRuntimeStatistics
| project QueryText, ActivityId, DatabaseName , CollectionName
| join kind=inner topRequestsByRUcharge on ActivityId
| project DatabaseName , CollectionName , QueryText , RequestCharge, TimeGenerated
| order by RequestCharge desc
| take 10

let topRequestsByRUcharge = AzureDiagnostics
| where Category == "DataPlaneRequests" and TimeGenerated > ago(24h)
| project  requestCharge_s , TimeGenerated, activityId_g;
AzureDiagnostics
| where Category == "QueryRuntimeStatistics"
| project querytext_s, activityId_g, databasename_s , collectionname_s
| join kind=inner topRequestsByRUcharge on activityId_g
| project databasename_s , collectionname_s , querytext_s , requestCharge_s, TimeGenerated
| order by requestCharge_s desc
| take 10

Żądania ograniczone (statusCode = 429) w określonym przedziale czasu

Specyficzne dla zasobu
Diagnostyka Azure

let throttledRequests = CDBDataPlaneRequests
| where StatusCode == "429"
| project  OperationName , TimeGenerated, ActivityId;
CDBQueryRuntimeStatistics
| project QueryText, ActivityId, DatabaseName , CollectionName
| join kind=inner throttledRequests on ActivityId
| project DatabaseName , CollectionName , QueryText , OperationName, TimeGenerated

let throttledRequests = AzureDiagnostics
| where Category == "DataPlaneRequests" and statusCode_s == "429"
| project  OperationName , TimeGenerated, activityId_g;
AzureDiagnostics
| where Category == "QueryRuntimeStatistics"
| project querytext_s, activityId_g, databasename_s , collectionname_s
| join kind=inner throttledRequests on activityId_g
| project databasename_s , collectionname_s , querytext_s , OperationName, TimeGenerated

Zapytania o największej długości odpowiedzi (rozmiar ładunku odpowiedzi serwera)

Specyficzne dla zasobu
Diagnostyka Azure

let operationsbyUserAgent = CDBDataPlaneRequests
| project OperationName, DurationMs, RequestCharge, ResponseLength, ActivityId;
CDBQueryRuntimeStatistics
//specify collection and database
//| where DatabaseName == "DBNAME" and CollectionName == "COLLECTIONNAME"
| join kind=inner operationsbyUserAgent on ActivityId
| summarize max(ResponseLength) by QueryText
| order by max_ResponseLength desc

let operationsbyUserAgent = AzureDiagnostics
| where Category=="DataPlaneRequests"
| project OperationName, duration_s, requestCharge_s, responseLength_s, activityId_g;
AzureDiagnostics
| where Category == "QueryRuntimeStatistics"
//specify collection and database
//| where databasename_s == "DBNAME" and collectioname_s == "COLLECTIONNAME"
| join kind=inner operationsbyUserAgent on activityId_g
| summarize max(responseLength_s1) by querytext_s
| order by max_responseLength_s1 desc

Użycie jednostek RU przez partycję fizyczną (we wszystkich replikach w zestawie replik)

Specyficzne dla zasobu
Diagnostyka Azure

CDBPartitionKeyRUConsumption
| where TimeGenerated >= now(-1d)
//specify collection and database
//| where DatabaseName == "DBNAME" and CollectionName == "COLLECTIONNAME"
// filter by operation type
//| where operationType_s == 'Create'
| summarize sum(todouble(RequestCharge)) by toint(PartitionKeyRangeId)
| render columnchart

AzureDiagnostics
| where TimeGenerated >= now(-1d)
| where Category == 'PartitionKeyRUConsumption'
//specify collection and database
//| where databasename_s == "DBNAME" and collectioname_s == "COLLECTIONNAME"
// filter by operation type
//| where operationType_s == 'Create'
| summarize sum(todouble(requestCharge_s)) by toint(partitionKeyRangeId_s)
| render columnchart

Użycie jednostek RU przez partycję logiczną (we wszystkich replikach w zestawie replik)

Specyficzne dla zasobu
Diagnostyka Azure

CDBPartitionKeyRUConsumption
| where TimeGenerated >= now(-1d)
//specify collection and database
//| where DatabaseName == "DBNAME" and CollectionName == "COLLECTIONNAME"
// filter by operation type
//| where operationType_s == 'Create'
| summarize sum(todouble(RequestCharge)) by PartitionKey, PartitionKeyRangeId
| render columnchart

AzureDiagnostics
| where TimeGenerated >= now(-1d)
| where Category == 'PartitionKeyRUConsumption'
//specify collection and database
//| where databasename_s == "DBNAME" and collectioname_s == "COLLECTIONNAME"
// filter by operation type
//| where operationType_s == 'Create'
| summarize sum(todouble(requestCharge_s)) by partitionKey_s, partitionKeyRangeId_s
| render columnchart

Następne kroki

Aby uzyskać więcej informacji na temat tworzenia ustawień diagnostycznych dla usługi Azure Cosmos DB, zobacz Tworzenie ustawień diagnostycznych.
Aby uzyskać szczegółowe informacje na temat tworzenia ustawienia diagnostycznego przy użyciu Azure Portal, interfejsu wiersza polecenia platformy Azure lub programu PowerShell, zobacz Tworzenie ustawień diagnostycznych w celu zbierania dzienników platformy i metryk na platformie Azure.

Share via