Ändra flödeslägen i Azure Cosmos DB

GÄLLER FÖR: NoSQL

Azure Cosmos DB erbjuder två ändringsflödeslägen. Varje läge har samma kärnfunktioner. Skillnaderna omfattar de åtgärder som samlas in i flödet, de metadata som är tillgängliga för varje ändring och kvarhållningsperioden för ändringar. Du kan använda ändringsflödet i olika lägen i flera program för samma Azure Cosmos DB-container för att passa kraven för varje arbetsbelastning. Varje enskilt ändringsflödesprogram kan bara konfigureras för att läsa ändringsflöde i ett läge. Att använda ändringsflödet i ett läge hindrar dig inte från att använda ändringsflödet i ett annat läge i ett annat program.

Kommentar

Har du någon feedback om ändringsflödeslägen? Vi vill höra det! Dela gärna feedback direkt med Azure Cosmos DB:s utvecklingsteam: cosmoschangefeed@microsoft.com.

Senaste ändringsflödesläge för version

Det senaste versionsläget är en beständig post med ändringar som gjorts i objekt från skapar och uppdateringar. Du får den senaste versionen av varje objekt i containern. Om ett objekt till exempel skapas och sedan uppdateras innan du läser ändringsflödet visas endast den uppdaterade versionen i ändringsflödet. Borttagningar registreras inte som ändringar och när ett objekt tas bort är det inte längre tillgängligt i flödet. Det senaste läget för versionsändringsflöde är aktiverat som standard och är kompatibelt med alla Azure Cosmos DB-konton förutom API:et för tabell och API:et för PostgreSQL. Det här läget var tidigare standardsättet för att använda ändringsflödet.

Alla versioner och tar bort ändringsflödesläge (förhandsversion)

Alla versioner och borttagningsläge (förhandsversion) är en beständig post med alla ändringar i objekt från åtgärder för att skapa, uppdatera och ta bort. Du får en post för varje ändring av objekt i den ordning det inträffade, inklusive mellanliggande ändringar i ett objekt mellan ändringsflödesläsningar. Om ett objekt till exempel skapas och sedan uppdateras innan du läser ändringsflödet visas både skapa- och uppdateringsversionerna av objektet i ändringsflödet. Om du vill läsa från ändringsflödet i alla versioner och borttagningsläge måste du ha kontinuerliga säkerhetskopior konfigurerade för ditt Azure Cosmos DB-konto. Om du aktiverar kontinuerliga säkerhetskopieringar skapas alla versioner och ändringsflödet tas bort. Du kan bara läsa ändringar som inträffat under den kontinuerliga säkerhetskopieringsperioden när du använder det här ändringsflödesläget. Det här läget är endast kompatibelt med Azure Cosmos DB för NoSQL-konton. Läs mer om hur du registrerar dig för förhandsversionen.

Användningsfall för ändringsflöde

Senaste versionsläge

Det senaste versionsläget är ett enkelt sätt att bearbeta både realtidsändringar och historiska ändringar av objekt i en container med möjlighet att gå tillbaka till ändringar från början av containern.

Följande är scenarier som passar bra för det här läget:

• Migreringar av en hel container till en sekundär plats.

• Möjlighet att bearbeta ändringar från början av containern.

• Realtidsbearbetning av ändringar av objekt i en container till följd av skapande- och uppdateringsåtgärder.

• Arbetsbelastningar som inte behöver samla in borttagningar eller mellanliggande ändringar mellan läsningar.

Alla versioner och borttagningsläge (förhandsversion)

Alla versioner och tar bort ändringsflödesläget möjliggör nya scenarier för ändringsflöde och förenklar andra. Du kan läsa alla ändringar som har inträffat i objekt (även i fall där flera ändringar har gjorts mellan ändringsflödesläsningar), identifiera åtgärdstypen för ändringar som bearbetas och få ändringar som blir resultatet av borttagningar.

Några vanliga scenarier som det här läget aktiverar och förbättrar är:

• Realtidsöverföring av data mellan två platser utan att implementera en mjuk borttagning.

• Utlöser logik baserat på inkrementella ändringar om flera ändringsåtgärder för ett visst objekt förväntas mellan ändringsflödesmätningar.

• Utlösa aviseringar vid borttagningsåtgärder, till exempel i granskningsscenarier.

• Möjligheten att bearbeta objekt skapar, uppdaterar och tar bort på olika sätt baserat på åtgärdstyp.

Funktioner i varje läge

Förutom de vanliga funktionerna i alla ändringsflödeslägen har varje ändringsflödesläge följande egenskaper:

Senaste versionsläge

• Ändringsflödet innehåller infognings- och uppdateringsåtgärder som görs för objekt i containern.

• Det här läget för ändringsflöde loggar inte borttagna. Du kan samla in borttagningar genom att ange en flagga för mjuk borttagning i dina objekt i stället för att ta bort dem direkt. Du kan till exempel lägga till ett attribut i objektet som heter deleted med värdet trueoch sedan ange TTL (Time to Live) för objektet. Ändringsflödet avbildar det som en uppdatering och objektet tas bort automatiskt när TTL upphör att gälla. Du kan också ange en begränsad förfalloperiod för dina objekt med hjälp av TTL-funktionen. Med den här lösningen måste du bearbeta ändringarna inom ett kortare tidsintervall än TTL-förfalloperioden.

• Endast den senaste ändringen för ett visst objekt ingår i ändringsflödet. Mellanliggande ändringar kanske inte är tillgängliga.

• När ett objekt tas bort är det inte längre tillgängligt i ändringsflödet.

• Ändringar kan synkroniseras från vilken tidpunkt som helst och det finns ingen fast kvarhållningsperiod för data som ändringar är tillgängliga för.

• Du kan inte filtrera ändringsflödet för en viss typ av åtgärd. Ett möjligt alternativ är att lägga till en "mjuk markör" för objektet för uppdateringar och filter baserat på markören när du bearbetar objekt i ändringsflödet.

• Startpunkten för att läsa ändringsflödet kan vara från början av containern, från en tidpunkt, från "nu" eller från en specifik kontrollpunkt. Starttidens precision är cirka fem sekunder.

Alla versioner och borttagningsläge (förhandsversion)

• Ändringsflödet innehåller åtgärder för att infoga, uppdatera och ta bort objekt i containern. Borttagningar från TTL-förfallodatum registreras också.

• Metadata tillhandahålls för att fastställa ändringstypen, inklusive om en borttagning berodde på en TTL-förfallotid.

• Ändringsflödesobjekt kommer i ordning efter ändringstiden. Borttagningar från TTL-förfallodatum är inte garanterade att visas i flödet omedelbart efter att objektet har upphört att gälla. De visas när objektet rensas från containern.

• Alla ändringar som har inträffat i kvarhållningsfönstret som har angetts för kontinuerliga säkerhetskopior på kontot kan läsas. Försök att läsa ändringar som inträffade utanför kvarhållningsfönstret resulterar i ett fel. Om containern till exempel skapades för åtta dagar sedan och kvarhållningsperioden för kontinuerlig säkerhetskopiering är sju dagar kan du bara läsa ändringar från de senaste sju dagarna.

• Startpunkten för ändringsflödet kan vara från "nu" eller från en specifik kontrollpunkt inom kvarhållningsperioden. Du kan inte läsa ändringar från början av containern eller från en viss tidpunkt med hjälp av det här läget.

Arbeta med ändringsflödet

Varje läge är kompatibelt med olika metoder för att läsa ändringsflödet för varje språk.

Senaste versionsläge

Du kan använda följande sätt att använda ändringar från ändringsflödet i det senaste versionsläget:

Metod för att läsa ändringsfeed	.NET	Java	Python	Node.js
Pull-modell för ändringsflöde	Ja	Ja	Ja	Ja
Ändringsflödesprocessor	Ja	Ja	Nej	Nej
Azure Functions-utlösare	Ja	Ja	Ja	Ja

Parsa svarsobjektet

I det senaste versionsläget är standardsvarsobjektet en matris med objekt som har ändrats. Varje objekt innehåller standardmetadata för alla Azure Cosmos DB-objekt, inklusive _etag och _ts, med tillägg av en ny egenskap, _lsn.

Formatet _etag är internt och du bör inte vara beroende av det eftersom det kan ändras när som helst. _ts är en ändring eller en tidsstämpel för skapande. Du kan använda _ts för kronologisk jämförelse. _lsn är ett batch-ID som endast läggs till för ändringsflöde som representerar transaktions-ID:t. Många objekt kan ha samma _lsn.

ETag på FeedResponse skiljer sig från du _etag ser på objektet. _etag är en intern identifierare och används för samtidighetskontroll. Egenskapen _etag representerar objektets version, medan egenskapen ETag används för att sekvensera flödet.

Alla versioner och borttagningsläge (förhandsversion)

Under förhandsversionen är följande metoder för att läsa ändringsflödet tillgängliga för varje klient-SDK:

Metod för att läsa ändringsfeed	.NET	Java	Python	Node.js
Pull-modell för ändringsflöde	>= 3.32.0-preview	>= 4.42.0	Nej	>= 4.1.0
Ändringsflödesprocessor	Nej	>= 4.42.0	Nej	Nej
Azure Functions-utlösare	Nej	Nej	Nej	Nej

Kommentar

Oavsett det anslutningsläge som har konfigurerats i ditt program använder alla begäranden som görs med alla versioner och tar bort ändringsflöde gatewayläge.

Kom igång

Om du vill komma igång med alla versioner och ta bort ändringsflödesläget registrerar du dig i förhandsversionen via sidan Förhandsgranskningsfunktioner på översiktssidan för Azure-prenumerationen. Sök efter funktionen AllVersionsAndDeletesChangeFeed och välj Registrera.

Innan du skickar din begäran kontrollerar du att du har minst ett Azure Cosmos DB-konto i prenumerationen. Det här kontot kan vara ett befintligt konto eller ett nytt konto som du har skapat för att testa förhandsgranskningsfunktionen. Om du inte har några konton i prenumerationen när Azure Cosmos DB-teamet tar emot din begäran avvisas begäran eftersom det inte finns några konton att tillämpa funktionen på.

Azure Cosmos DB-teamet granskar din begäran och kontaktar dig via e-post för att bekräfta vilka Azure Cosmos DB-konton i prenumerationen som du vill registrera i förhandsversionen. Om du vill använda förhandsversionen måste du ha kontinuerliga säkerhetskopior konfigurerade för ditt Azure Cosmos DB-konto. Kontinuerliga säkerhetskopior kan aktiveras antingen före eller efter att de har lagts till i förhandsversionen, men kontinuerliga säkerhetskopior måste aktiveras innan du försöker läsa från ändringsflödet i alla versioner och tar bort läget.

Parsa svarsobjektet

Svarsobjektet är en matris med objekt som representerar varje ändring. Matrisen ser ut som i följande exempel:

[
    {  
        "current": { 
            <The current version of the item that changed. All the properties of your item will appear here. This will be empty for delete operations.>
         },  
        "previous" : { 
            <The previous version of the item that changed. If the change was a delete operation, the item that was deleted will appear here. This will be empty for create and replace operations.>
         },  
        "metadata": {
            "lsn": <A number that represents the batch ID. Many items can have the same lsn.>, 
            "operationType": <The type of change, either 'create', 'replace', or 'delete'.>, 
            "previousImageLSN" : <A number that represents the batch ID of the change prior to this one.>, 
            "timeToLiveExpired" : <For delete changes, it will be 'true' if it was deleted due to a TTL expiration and 'false' if it wasn't.>, 
            "crts": <A number that represents the Conflict Resolved Timestamp. It has the same format as _ts.> 
        } 
    }
]

Begränsningar

• Stöds för Azure Cosmos DB för NoSQL-konton. Andra Azure Cosmos DB-kontotyper stöds inte.

• Kontinuerliga säkerhetskopior krävs för att använda det här ändringsflödesläget. Begränsningarna för att använda kontinuerlig säkerhetskopiering finns i dokumentationen.

• Det går inte att läsa ändringar i en container som fanns innan kontinuerliga säkerhetskopieringar aktiverades på kontot.

• Möjligheten att börja läsa ändringsflödet från början eller välja en starttid baserat på en tidigare tidsstämpel stöds inte för närvarande. Du kan antingen starta från "nu" eller från ett tidigare lån eller en fortsättningstoken.

• Det är för närvarande inte tillgängligt att ta emot den tidigare versionen av objekt som har uppdaterats.

• Konton som har aktiverat sammanslagning av partitioner stöds inte.

Nästa steg

Läs mer om ändringsflöde i följande artiklar:

• Översikt över ändringsflöde
• Designmönster för ändringsflöde
• Alternativ för att läsa ändringsfeed