Azure Cosmos DB'de akış modlarını değiştirme

UYGULANANLAR: NoSQL

Azure Cosmos DB iki değişiklik akışı modu sunar. Her mod aynı çekirdek işlevselliği sunar. Farklar arasında akışta yakalanan işlemler, her değişiklik için kullanılabilen meta veriler ve değişikliklerin saklama süresi yer alır. Değişiklik akışını, her iş yükünün gereksinimlerine uyacak şekilde aynı Azure Cosmos DB kapsayıcısı için birden çok uygulamada farklı modlarda kullanabilirsiniz. Her değişiklik akışı uygulaması, değişiklik akışını yalnızca bir modda okuyacak şekilde yapılandırılabilir. Değişiklik akışının tek bir modda tüketilmesi, değişiklik akışını farklı bir uygulamada başka bir modda kullanmanıza engel olmaz.

Not

Değişiklik akışı modları hakkında geri bildiriminiz var mı? Duymak istiyoruz! Geri bildiriminizi doğrudan Azure Cosmos DB mühendislik ekibiyle paylaşmaktan çekinmeyin: cosmoschangefeed@microsoft.com.

En son sürüm değişiklik akışı modu

En son sürüm modu, oluşturma ve güncelleştirmelerden öğelerde yapılan değişikliklerin kalıcı bir kaydıdır. Kapsayıcıdaki her öğenin en son sürümünü alırsınız. Örneğin, değişiklik akışını okumadan önce bir öğe oluşturulur ve sonra güncelleştirilirse, değişiklik akışında yalnızca güncelleştirilmiş sürüm görüntülenir. Silme işlemleri değişiklik olarak yakalanmaz ve bir öğe silindiğinde artık akışta kullanılamaz. En son sürüm değişiklik akışı modu varsayılan olarak etkindir ve Tablo API'si ve PostgreSQL IÇIN API dışındaki tüm Azure Cosmos DB hesaplarıyla uyumludur. Bu mod daha önce değişiklik akışını kullanmanın varsayılan yoluydu.

Tüm sürümler ve silmeler değişiklik akışı modu (önizleme)

Tüm sürümler ve silmeler modu (önizleme), oluşturma, güncelleştirme ve silme işlemlerinden öğelerde yapılan tüm değişikliklerin kalıcı bir kaydıdır. Değişiklik akışı okumaları arasında bir öğede yapılan ara değişiklikler de dahil olmak üzere, öğelerde yapılan her değişikliğin gerçekleştiği sırayla bir kaydı alırsınız. Örneğin, değişiklik akışını okumadan önce bir öğe oluşturulur ve sonra güncelleştirilirse, öğenin hem oluşturma hem de güncelleştirme sürümleri değişiklik akışında görünür. Tüm sürümler ve silmeler modunda değişiklik akışından okumak için Azure Cosmos DB hesabınız için sürekli yedeklemelerin yapılandırılmış olması gerekir. Sürekli yedeklemeler etkinleştirildiğinde tüm sürümler oluşturulur ve değişiklik akışı silinir. Bu değişiklik akışı modunu kullanırken yalnızca sürekli yedekleme dönemi içinde gerçekleşen değişiklikleri okuyabilirsiniz. Bu mod yalnızca NoSQL hesapları için Azure Cosmos DB ile uyumludur. Önizlemeye kaydolma hakkında daha fazla bilgi edinin.

Değişiklik akışı kullanım örnekleri

En son sürüm modu

En son sürüm modu, kapsayıcının başından itibaren değişikliklere geri dönebilme özelliğiyle bir kapsayıcıdaki öğelerde hem gerçek zamanlı hem de geçmişe dönük değişiklikleri işlemek için kolay bir yol sağlar.

Bu moda uygun senaryolar şunlardır:

• Kapsayıcının tamamının ikincil bir konuma geçişleri.

• Kapsayıcının başından itibaren değişiklikleri yeniden işleme olanağı.

• Oluşturma ve güncelleştirme işlemlerinden kaynaklanan kapsayıcıdaki öğelerde yapılan değişikliklerin gerçek zamanlı işlenmesi.

• Okumalar arasındaki silmeleri veya ara değişiklikleri yakalaması gerekmeyen iş yükleri.

Tüm sürümler ve silmeler modu (önizleme)

Tüm sürümler ve silmeler değişiklik akışı modu, değişiklik akışı için yeni senaryolar sağlar ve diğerlerini basitleştirir. Öğelerde gerçekleşen her değişikliği okuyabilir (değişiklik akışı okumaları arasında birden çok değişiklik gerçekleştiği durumlarda bile), işlenen değişikliklerin işlem türünü tanımlayabilir ve silmelerden kaynaklanan değişiklikleri alabilirsiniz.

Bu modun etkinleştirip geliştirmeleri için birkaç yaygın senaryo şunlardır:

• Geçici silme uygulamadan iki konum arasında gerçek zamanlı veri aktarımı.

• Değişiklik akışı yoklamaları arasında belirli bir öğe için birden çok değişiklik işlemi bekleniyorsa artımlı değişiklikleri temel alan mantığı tetikleme.

• Denetim senaryolarında olduğu gibi silme işlemleriyle ilgili uyarıları tetikleme.

• Öğe oluşturma, güncelleştirme ve silme işlemlerini işlem türüne göre farklı şekilde işleyebilme özelliği.

Her modun özellikleri

Tüm değişiklik akışı modlarındaki ortak özelliklere ek olarak, her değişiklik akışı modu aşağıdaki özelliklere sahiptir:

En son sürüm modu

• Değişiklik akışı, kapsayıcıdaki öğelere yapılan ekleme ve güncelleştirme işlemlerini içerir.

• Bu değişiklik akışı modu silmeleri günlüğe kaydetmez. Doğrudan silmek yerine öğelerinizin içinde "geçici silme" bayrağı ayarlayarak silmeleri yakalayabilirsiniz. Örneğin, adlı deleted öğeye değeriyle truebir öznitelik ekleyebilir ve sonra öğede Yaşam Süresi (TTL) ayarlayabilirsiniz. Değişiklik akışı bunu bir güncelleştirme olarak yakalar ve TTL'nin süresi dolduğunda öğe otomatik olarak silinir. Alternatif olarak, TTL özelliğini kullanarak öğeleriniz için sonlu bir süre sonu ayarlayabilirsiniz. Bu çözümle, değişiklikleri TTL sona erme süresinden daha kısa bir zaman aralığı içinde işlemeniz gerekir.

• Değişiklik akışına yalnızca belirli bir öğe için en son değişiklik eklenir. Ara değişiklikler kullanılamayabilir.

• Bir öğe silindiğinde, artık değişiklik akışında kullanılamaz.

• Değişiklikler herhangi bir zaman noktasından eşitlenebilir ve değişikliklerin kullanılabildiği sabit veri saklama süresi yoktur.

• Değişiklik akışını belirli bir işlem türü için filtreleyemezsiniz. Olası bir alternatif, güncelleştirmeler için öğeye bir "geçici işaretçi" eklemek ve değişiklik akışındaki öğeleri işlerken işaretçiye göre filtrelemektir.

• Değişiklik akışının okunacağı başlangıç noktası kapsayıcının başından, belirli bir noktadan, "şimdi" veya belirli bir denetim noktasından olabilir. Başlangıç zamanının duyarlığı yaklaşık beş saniyedir.

Tüm sürümler ve silmeler modu (önizleme)

• Değişiklik akışı kapsayıcı içindeki öğelere yapılan ekleme, güncelleştirme ve silme işlemlerini içerir. TTL süre sonu silme işlemleri de yakalanır.

• Silme işleminin TTL süre sonu nedeniyle olup olmadığı da dahil olmak üzere değişiklik türünü belirlemek için meta veriler sağlanır.

• Değişiklik akışı öğeleri, değişiklik zamanlarının sırasına göre gelir. TTL süre sonu silmelerinin, öğenin süresi dolduktan hemen sonra akışta görünmesi garanti değildir. Öğe kapsayıcıdan temizlendiğinde görüntülenir.

• Hesaptaki sürekli yedeklemeler için ayarlanan bekletme penceresinde gerçekleşen tüm değişiklikler okunabilir. Bekletme penceresinin dışında gerçekleşen değişiklikleri okumaya çalışmak hatayla sonuçlanır. Örneğin, kapsayıcınız sekiz gün önce oluşturulduysa ve sürekli yedekleme süresi saklama süreniz yedi günse, yalnızca son yedi güne ait değişiklikleri okuyabilirsiniz.

• Değişiklik akışı başlangıç noktası "şimdi" veya saklama döneminizdeki belirli bir denetim noktasından olabilir. Bu modu kullanarak kapsayıcının başından veya belirli bir noktadan değişiklikleri okuyamazsınız.

Değişiklik akışıyla çalışma

Her mod, her dilin değişiklik akışını okumak için farklı yöntemlerle uyumludur.

En son sürüm modu

Değişiklik akışındaki değişiklikleri en son sürüm modunda kullanmak için aşağıdaki yolları kullanabilirsiniz:

Değişiklik akışını okuma yöntemi	.NET	Java	Python	Node.js
Akış çekme modelini değiştirme	Yes	Evet	Evet	Yes
Akış işlemcisini değiştirme	Yes	Evet	Hayır	Hayır
Azure İşlevleri tetikleyicisi	Yes	Evet	Evet	Yes

Yanıt nesnesini ayrıştırma

En son sürüm modunda, varsayılan yanıt nesnesi değiştirilmiş bir öğe dizisidir. Her öğe ve dahil olmak üzere _etag _tstüm Azure Cosmos DB öğeleri için standart meta verileri içerir ve yeni bir özellik _lsneklenir.

Biçim _etag dahilidir ve istediğiniz zaman değişebileceğinden bu biçime bağımlılık almamalısınız. _ts bir değişiklik veya oluşturma zaman damgasıdır. Kronolojik karşılaştırma için kullanabilirsiniz _ts . _lsn , yalnızca işlem kimliğini temsil eden değişiklik akışı için eklenen bir toplu iş kimliğidir. Birçok öğe aynı _lsnolabilir.

ETag on FeedResponse , öğede _etag gördüğünüzden farklıdır. _etag bir iç tanımlayıcıdır ve eşzamanlılık denetimi için kullanılır. _etag özelliği öğenin sürümünü temsil ederkenETag, akışı sıralamak için özelliği kullanılır.

Tüm sürümler ve silmeler modu (önizleme)

Önizleme sırasında, her istemci SDK'sı için değişiklik akışını okumak için aşağıdaki yöntemler kullanılabilir:

Değişiklik akışını okuma yöntemi	.NET	Java	Python	Node.js
Akış çekme modelini değiştirme	>= 3.32.0-önizleme	>= 4.42.0	Hayır	>= 4.1.0
Akış işlemcisini değiştirme	Hayır	>= 4.42.0	Hayır	Hayır
Azure İşlevleri tetikleyicisi	Hayır	Hayır	Hayır	No.

Not

Uygulamanızda yapılandırılan bağlantı modundan bağımsız olarak, tüm sürümler ve silmeler değişiklik akışıyla yapılan tüm istekler Ağ Geçidi modunu kullanır.

Kullanmaya başlayın

Tüm sürümleri kullanmaya başlamak ve değişiklik akışı modunu silmek için Azure Aboneliği genel bakış sayfanızdaki Önizleme Özellikleri sayfası aracılığıyla önizlemeye kaydolabilirsiniz. AllVersionsAndDeletesChangeFeed özelliğini arayın ve Kaydet'i seçin.

İsteğinizi göndermeden önce abonelikte en az bir Azure Cosmos DB hesabınızın olduğundan emin olun. Bu hesap, önizleme özelliğini denemek için oluşturduğunuz mevcut bir hesap veya yeni bir hesap olabilir. Azure Cosmos DB ekibi isteğinizi aldığında abonelikte hesabınız yoksa, özelliğin uygulanacağı hesap olmadığından istek reddedilir.

Azure Cosmos DB ekibi, aboneliğinizdeki hangi Azure Cosmos DB hesaplarını önizlemeye kaydetmek istediğinizi onaylamak için isteğinizi ve sizinle e-posta yoluyla iletişim kurar. Önizlemeyi kullanmak için Azure Cosmos DB hesabınız için yapılandırılmış sürekli yedeklemeleriniz olmalıdır. Sürekli yedeklemeler önizlemeye kabul edilmeden önce veya sonra etkinleştirilebilir, ancak tüm sürümlerde ve silme modunda değişiklik akışından okumaya çalışmadan önce sürekli yedeklemelerin etkinleştirilmesi gerekir.

Yanıt nesnesini ayrıştırma

Yanıt nesnesi, her değişikliği temsil eden bir öğe dizisidir. Dizi aşağıdaki örneğe benzer:

[
    {  
        "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.> 
        } 
    }
]

Sınırlamalar

• NoSQL hesapları için Azure Cosmos DB için desteklenir. Diğer Azure Cosmos DB hesap türleri desteklenmez.

• Bu değişiklik akışı modunu kullanmak için sürekli yedeklemeler gerekir. Sürekli yedekleme kullanmanın sınırlamaları belgelerde bulunabilir.

• Hesapta sürekli yedeklemeler etkinleştirilmeden önce var olan bir kapsayıcıda yapılan değişikliklerin okunması desteklenmez.

• Değişiklik akışını baştan okumaya başlama veya geçmiş zaman damgasını temel alan bir başlangıç saati seçme özelliği şu anda desteklenmemaktadır. "Şimdi" ile veya önceki bir kira veya devamlılık belirtecinden başlayabilirsiniz.

• Güncelleştirilmiş öğelerin önceki sürümünü almak şu anda kullanılamıyor.

• Bölümleri birleştirmeyi etkinleştiren hesaplar desteklenmez.

Sonraki adımlar

Aşağıdaki makalelerde değişiklik akışı hakkında daha fazla bilgi edinin:

• Değişiklik akışına genel bakış
• Akış tasarım desenlerini değiştirme
• Değişiklik akışını okuma seçenekleri