Řešení potíží s pokročilými diagnostickými dotazy ve službě Azure Cosmos DB pro Apache Gremlin

Článek
08/15/2024

PLATÍ PRO: NoSQL MongoDB Cassandra Skřítek

V tomto článku se budeme zabývat tím, jak napsat pokročilejší dotazy, které vám pomůžou řešit problémy s účtem služby Azure Cosmos DB pomocí diagnostických protokolů odesílaných do tabulek Azure Diagnostics (starší verze) a tabulek specifických pro prostředky (Preview).

V případě tabulek Azure Diagnostics se všechna data zapisuje do jedné tabulky. Uživatelé určují, do které kategorie se mají dotazovat. Pokud chcete zobrazit fulltextový dotaz požadavku, přečtěte si téma Monitorování dat služby Azure Cosmos DB pomocí nastavení diagnostiky v Azure a zjistěte, jak tuto funkci povolit.

U tabulek specifických pro prostředky se data zapisují do jednotlivých tabulek pro každou kategorii prostředku. Tento režim doporučujeme, protože:

Usnadňuje práci s daty.
Poskytuje lepší zjistitelnost schémat.
Zlepšuje výkon v době latence příjmu dat i dotazů.

Běžné dotazy

Běžné dotazy se zobrazují v tabulkách specifických pro prostředky a Azure Diagnostics.

Prvních N(10) jednotek žádostí (RU) využívající požadavky nebo dotazy v určitém časovém rámci

Specifické pro prostředky
Diagnostika Azure

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

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

Omezení požadavků (statusCode = 429) v určitém časovém intervalu

Specifické pro prostředky
Diagnostika Azure

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

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

Dotazy s velkými délkami odpovědí (velikost datové části odpovědi serveru)

Specifické pro prostředky
Diagnostika Azure

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

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

Spotřeba RU podle fyzického oddílu (napříč všemi replikami v sadě replik)

Specifické pro prostředky
Diagnostika Azure

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

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

Spotřeba RU podle logického oddílu (napříč všemi replikami v sadě replik)

Specifické pro prostředky
Diagnostika Azure

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

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

Další kroky

Další informace o tom, jak vytvořit nastavení diagnostiky pro službu Azure Cosmos DB, najdete v tématu Vytvoření nastavení diagnostiky.
Podrobné informace o tom, jak vytvořit nastavení diagnostiky pomocí webu Azure Portal, Azure CLI nebo PowerShellu, najdete v tématu Vytvoření nastavení diagnostiky pro shromažďování protokolů platformy a metrik v Azure.

Sdílet prostřednictvím