Az Apache Gremlinhez készült Azure Cosmos DB speciális diagnosztikai lekérdezéseivel kapcsolatos problémák elhárítása

Cikk
08/15/2024

A KÖVETKEZŐKRE VONATKOZIK: NoSQL MongoDB Cassandra Gremlin

Ebben a cikkben részletesebb lekérdezéseket írunk az Azure Cosmos DB-fiók problémáinak elhárításához az Azure Diagnostics (örökölt) és erőforrás-specifikus (előzetes verzió) tábláknak küldött diagnosztikai naplók használatával.

Az Azure Diagnostics-táblák esetében a rendszer minden adatot egyetlen táblába ír. A felhasználók megadják, hogy melyik kategóriát szeretnék lekérdezni. Ha meg szeretné tekinteni a kérés teljes szöveges lekérdezését, tekintse meg az Azure Cosmos DB-adatok monitorozását az Azure diagnosztikai beállításaival, és ismerje meg, hogyan engedélyezheti ezt a funkciót.

Erőforrás-specifikus táblák esetében az adatok az erőforrás egyes kategóriáinak egyes tábláiba lesznek beírva. Ezt a módot javasoljuk, mert:

Sokkal egyszerűbbé teszi az adatokkal való munkát.
A sémák jobb felderíthetőségét biztosítja.
Javítja a teljesítményt mind a betöltési késés, mind a lekérdezési idő tekintetében.

Gyakori lekérdezések

A gyakori lekérdezések az erőforrás-specifikus és az Azure Diagnostics-táblákban jelennek meg.

A kéréseket vagy lekérdezéseket egy adott időkeretben használó felső N(10) kérelemegység (RU)

Erőforrás-specifikus
Azure Diagnostics

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

A kérelmek szabályozottak (statusCode = 429) egy adott időablakban

Erőforrás-specifikus
Azure Diagnostics

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

Nagy válaszhosszúságú lekérdezések (a kiszolgáló válaszának hasznos adatmérete)

Erőforrás-specifikus
Azure Diagnostics

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

Ru-felhasználás fizikai partíció szerint (a replikakészlet összes replikájában)

Erőforrás-specifikus
Azure Diagnostics

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

RU-használat logikai partíció szerint (a replikakészlet összes replikájában)

Erőforrás-specifikus
Azure Diagnostics

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

Következő lépések

További információ az Azure Cosmos DB diagnosztikai beállításainak létrehozásáról: Diagnosztikai beállítások létrehozása.
Az Azure Portal, az Azure CLI vagy a PowerShell használatával történő diagnosztikai beállítások létrehozásáról a platformnaplók és metrikák Azure-beli gyűjtéséhez készült diagnosztikai beállítások létrehozása című témakörben olvashat.

Megosztás a következőn keresztül: