A változáscsatorna becslőjének használata
A KÖVETKEZŐKRE VONATKOZIK: NoSQL
Ez a cikk azt ismerteti, hogyan figyelheti a változáscsatorna feldolgozópéldányainak állapotát a változáscsatorna olvasása közben.
Miért fontos az előrehaladás monitorozása?
A változáscsatorna feldolgozója olyan mutatóként működik, amely előrehalad a változáscsatornán , és a módosításokat egy delegált implementációnak továbbítja.
A változáscsatorna feldolgozójának üzembe helyezése a rendelkezésre álló erőforrások, például a processzor, a memória, a hálózat stb. alapján képes feldolgozni a módosításokat.
Ha ez a sebesség lassabb, mint az Azure Cosmos DB-tárolóban végrehajtott módosítások gyakorisága, a processzor késéssel fog elindulni.
Ennek a forgatókönyvnek a azonosítása segít megérteni, hogy skáláznunk kell-e a változáscsatorna feldolgozójának üzembe helyezését.
A változáscsatorna-becslő implementálása
Leküldéses modellként az automatikus értesítésekhez
A változáscsatorna-feldolgozóhoz hasonlóan a változáscsatorna-becslő leküldéses modellként is működhet. A becslő méri az utolsó feldolgozott elem (a bérlettároló állapota által meghatározott) és a tároló legutóbbi változása közötti különbséget, és leküldi ezt az értéket egy meghatalmazottnak. A mérés időköze az alapértelmezett 5 másodperces értékkel is testre szabható.
Ha például a változáscsatorna feldolgozója a következőképpen van definiálva:
Container leaseContainer = client.GetContainer(databaseId, Program.leasesContainer);
Container monitoredContainer = client.GetContainer(databaseId, Program.monitoredContainer);
ChangeFeedProcessor changeFeedProcessor = monitoredContainer
.GetChangeFeedProcessorBuilder<ToDoItem>("changeFeedEstimator", Program.HandleChangesAsync)
.WithInstanceName("consoleHost")
.WithLeaseContainer(leaseContainer)
.Build();
A becslő inicializálásának helyes módja annak mérésére, hogy a processzor a következőképpen fog-e használni GetChangeFeedEstimatorBuilder
:
ChangeFeedProcessor changeFeedEstimator = monitoredContainer
.GetChangeFeedEstimatorBuilder("changeFeedEstimator", Program.HandleEstimationAsync, TimeSpan.FromMilliseconds(1000))
.WithLeaseContainer(leaseContainer)
.Build();
Ahol a feldolgozó és a becslő is ugyanazt leaseContainer
a nevet használja.
A másik két paraméter a delegált, amely egy számot kap, amely azt jelzi, hogy a processzor hány módosítást vár olvasásra , és azt az időtartamot, amikor a mérést el szeretné végezni.
Példa a becslést fogadó meghatalmazottra:
static async Task HandleEstimationAsync(long estimation, CancellationToken cancellationToken)
{
if (estimation > 0)
{
Console.WriteLine($"\tEstimator detected {estimation} items pending to be read by the Processor.");
}
await Task.Delay(0);
}
Ezt a becslést elküldheti a monitorozási megoldásnak, és segítségével megértheti, hogyan alakul az előrehaladás az idő múlásával.
Igény szerinti részletes becslésként
A leküldéses modellel ellentétben van egy alternatíva, amellyel igény szerinti becslést kaphat. Ez a modell részletesebb információkat is nyújt:
- A becsült késés bérletenként.
- Az egyes bérletek tulajdonosa és feldolgozó példánya, így megállapíthatja, hogy van-e probléma egy példányon.
Ha a változáscsatorna feldolgozója a következőképpen van definiálva:
Container leaseContainer = client.GetContainer(databaseId, Program.leasesContainer);
Container monitoredContainer = client.GetContainer(databaseId, Program.monitoredContainer);
ChangeFeedProcessor changeFeedProcessor = monitoredContainer
.GetChangeFeedProcessorBuilder<ToDoItem>("changeFeedEstimator", Program.HandleChangesAsync)
.WithInstanceName("consoleHost")
.WithLeaseContainer(leaseContainer)
.Build();
A becslőt ugyanazzal a bérletkonfigurációval hozhatja létre:
ChangeFeedEstimator changeFeedEstimator = monitoredContainer
.GetChangeFeedEstimator("changeFeedEstimator", leaseContainer);
És amikor csak szeretné, a szükséges gyakorisággal lekérte a részletes becslést:
Console.WriteLine("Checking estimation...");
using FeedIterator<ChangeFeedProcessorState> estimatorIterator = changeFeedEstimator.GetCurrentStateIterator();
while (estimatorIterator.HasMoreResults)
{
FeedResponse<ChangeFeedProcessorState> states = await estimatorIterator.ReadNextAsync();
foreach (ChangeFeedProcessorState leaseState in states)
{
string host = leaseState.InstanceName == null ? $"not owned by any host currently" : $"owned by host {leaseState.InstanceName}";
Console.WriteLine($"Lease [{leaseState.LeaseToken}] {host} reports {leaseState.EstimatedLag} as estimated lag.");
}
}
Mindegyik ChangeFeedProcessorState
tartalmazza a bérlet és a késés adatait, valamint azt is, hogy ki az aktuális példány tulajdonosa.
Becslő üzembe helyezése
A változáscsatorna-becslőt nem kell a változáscsatorna feldolgozójának részeként üzembe helyezni, és nem kell ugyanahhoz a projekthez tartoznia. Javasoljuk, hogy helyezze üzembe a becslőt a processzoroktól független és teljesen eltérő példányon. Egyetlen becslő példány nyomon követheti a változáscsatorna feldolgozójának üzembe helyezésében lévő összes bérlet és példány előrehaladását.
Minden becslés felhasználja a figyelt és a bérlettárolókból származó kérelemegységeket. A kettő közötti 1 perces gyakoriság jó kiindulási pont, minél alacsonyabb a gyakoriság, annál nagyobb a felhasznált kérelemegységek száma.
További források
- Azure Cosmos DB SDK
- Használati minták a GitHubon (.NET)
- Használati minták a GitHubon (Java)
- További minták a GitHubon
Következő lépések
A változáscsatorna feldolgozójáról az alábbi cikkekben tudhat meg többet: