Memecahkan masalah dengan kueri diagnostik tingkat lanjut dengan Azure Cosmos DB untuk Apache Gremlin

Artikel
04/11/2023

BERLAKU UNTUK: Nosql MongoDB Cassandra Gremlin

Dalam artikel ini, kami akan membahas cara menulis kueri lanjutan untuk membantu memecahkan masalah dengan akun Azure Cosmos DB Anda menggunakan log diagnostik yang dikirim ke tabel Azure Diagnostics (warisan) dan khusus sumber daya (pratinjau) .

Untuk tabel Azure Diagnostics, semua data ditulis ke dalam satu tabel tunggal. Pengguna menentukan kategori mana yang ingin mereka kueri. Jika Anda ingin melihat kueri teks lengkap dari permintaan Anda, lihat Memantau data Azure Cosmos DB menggunakan pengaturan diagnostik di Azure untuk mempelajari cara mengaktifkan fitur ini.

Untuk tabel khusus sumber daya, data ditulis ke dalam tabel individual untuk setiap kategori sumber daya. Kami merekomendasikan mode ini karena:

Membuatnya lebih mudah untuk bekerja dengan data.
Memberikan penemuan skema yang lebih baik.
Meningkatkan performa di latensi penyerapan dan waktu kueri.

Kueri umum

Kueri umum ditampilkan dalam tabel khusus sumber daya dan Azure Diagnostics.

N(10) Permintaan Unit (RU) teratas yang menggunakan permintaan atau pertanyaan dalam jangka waktu tertentu

Khusus sumber daya
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

Permintaan dibatasi (statusCode = 429) dalam jangka waktu tertentu

Khusus sumber daya
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

Kueri dengan panjang respons besar (ukuran payload respons server)

Khusus sumber daya
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

Konsumsi RU berdasarkan partisi fisik (di semua replika dalam set replika)

Khusus sumber daya
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

Konsumsi RU berdasarkan partisi logis (di semua replika dalam set replika)

Khusus sumber daya
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

Langkah berikutnya

Untuk informasi selengkapnya tentang cara membuat pengaturan diagnostik untuk Azure Cosmos DB, lihat Membuat pengaturan diagnostik.
Untuk informasi mendetail tentang cara membuat pengaturan diagnostik dengan menggunakan portal Azure, Azure CLI, atau PowerShell, lihat Membuat pengaturan diagnostik untuk mengumpulkan log dan metrik platform di Azure.

Share via