Rozwiązywanie problemów z zaawansowanymi zapytaniami diagnostycznymi w usłudze Azure Cosmos DB dla języka Apache Gremlin

DOTYCZY: NoSQL MongoDB Kasandra Gremlin

• Interfejs API dla noSQL
• Interfejs API dla usługi MongoDB
• Interfejs API dla systemu Apache Cassandra
• Interfejs API dla języka Apache Gremlin

W tym artykule omówimy 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.

N(10) Jednostka żądań (RU) zużywających żądania lub zapytania w określonym przedziale czasu

Specyficzne dla zasobu

CDBGremlinRequests
| project PIICommandText, ActivityId, DatabaseName , CollectionName
| join kind=inner topRequestsByRUcharge on ActivityId
| project DatabaseName , CollectionName , PIICommandText , RequestCharge, TimeGenerated
| order by RequestCharge desc
| take 10

Diagnostyka Azure

AzureDiagnostics
| where Category == "GremlinRequests"
| project piiCommandText_s, activityId_g, databasename_s , collectionname_s
| join kind=inner topRequestsByRUcharge on activityId_g
| project databasename_s , collectionname_s , piiCommandText_s , requestCharge_s, TimeGenerated
| order by requestCharge_s desc
| take 10

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

Specyficzne dla zasobu

CDBGremlinRequests
| project PIICommandText, ActivityId, DatabaseName , CollectionName
| join kind=inner throttledRequests on ActivityId
| project DatabaseName , CollectionName , PIICommandText , OperationName, TimeGenerated

Diagnostyka Azure

AzureDiagnostics
| where Category == "GremlinRequests"
| project piiCommandText_s, activityId_g, databasename_s , collectionname_s
| join kind=inner throttledRequests on activityId_g
| project databasename_s , collectionname_s , piiCommandText_s , OperationName, TimeGenerated

Zapytania o dużej długości odpowiedzi (rozmiar ładunku odpowiedzi serwera)

Specyficzne dla zasobu

CDBGremlinRequests
//specify collection and database
 //| where DatabaseName == "DB NAME" and CollectionName == "COLLECTIONNAME"
| join kind=inner operationsbyUserAgent on ActivityId
| summarize max(ResponseLength) by PIICommandText
| order by max_ResponseLength desc

Diagnostyka Azure

AzureDiagnostics
| where Category == "GremlinRequests"
//| where databasename_s == "DB NAME" and collectioname_s == "COLLECTIONNAME"
| join kind=inner operationsbyUserAgent on activityId_g
| summarize max(responseLength_s1) by piiCommandText_s
| order by max_responseLength_s1 desc

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

Specyficzne dla zasobu

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

Diagnostyka Azure

AzureDiagnostics
| where TimeGenerated >= now(-1d)
| where Category == 'PartitionKeyRUConsumption'
//specify collection and database
//| where databasename_s == "DB NAME" 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

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

Diagnostyka Azure

AzureDiagnostics
| where TimeGenerated >= now(-1d)
| where Category == 'PartitionKeyRUConsumption'
//specify collection and database
//| where databasename_s == "DB NAME" 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 witryny 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.