Azure Cosmos DB'deki değişiklik akışı

Uygulama hedefı: MongoDB için SQL API Cassandra API gremlin API Azure Cosmos DB API 'si

Azure Cosmos DB akış değişikliği, bir kapsayıcıdaki değişikliklerin meydana gelen kalıcı bir kaydıdır. Azure Cosmos DB’de değişiklik akışı desteği, Azure Cosmos kapsayıcısında yapılan değişiklikleri dinleyerek çalışır. Ardından çıkış olarak, değiştirilen belgelerin değiştirilme zamanına göre sıralandığı bir belge listesi oluşturur. Kalıcı değişiklikler zaman uyumsuz ve artımlı olarak işlenebilir ve çıkış paralel işleme için bir veya daha fazla tüketiciye dağıtılabilir.

Değişiklik akışı tasarım desenlerihakkında daha fazla bilgi edinin.

Desteklenen API 'Ler ve istemci SDK 'Ları

bu özellik şu anda aşağıdaki Azure Cosmos DB apı 'leri ve istemci sdk 'ları tarafından desteklenmektedir.

Akışı ve farklı işlemleri değiştirme

Bugün, değişiklik akışında tüm eklemeleri ve güncelleştirmeleri görürsünüz. Belirli bir işlem türü için değişiklik akışını filtrelememe. Olası bir alternatif, güncelleştirme için öğede "geçici işaretleyici" eklemek ve değişiklik akışındaki öğeleri işlerken bunlara göre filtre uygulamak.

Şu anda değişiklik akışında silme günlüğü yok. Önceki örneğe benzer şekilde, silinmekte olan öğelere de bir yumuşak işaret ekleyebilirsiniz. Örneğin, "Deleted" adlı öğeye bir öznitelik ekleyebilir ve bunu "true" olarak ayarlayabilir ve öğe üzerinde bir TTL ayarlayabilirsiniz, böylece otomatik olarak silinebilir. Geçmiş öğeler için değişiklik akışını okuyabilir (öğeye karşılık gelen en son değişiklik, ara değişiklikleri içermez), örneğin, beş yıl önce eklenmiş olan öğeler. Değişiklik akışını kapsayıcının kaynağına kadar geri alabilirsiniz, ancak bir öğe silinirse, değişiklik akışından kaldırılır.

Değişiklik akışında öğelerin sıralama düzeni

Değişiklik akışı öğeleri değiştirme zamanının sırasıyla gelir. Bu sıralama düzeni mantıksal bölüm anahtarı başına garanti edilir.

Tutarlılık düzeyi

Değişiklik akışı nihai tutarlılık düzeyinde kullanılırken, sonraki değişiklik akışı okuma işlemleri arasında (bir okuma işleminin son olayı, sonraki ilk olarak görüntülenir) içinde yinelenen olaylar olabilir.

çok bölgeli Azure Cosmos hesaplarındaki akışı değiştirme

çok bölgeli bir Azure Cosmos hesabında, bir yazma bölgesi yük devrettikten sonra değişiklik akışı el ile yük devretme işleminde çalışır ve bitişik olur.

Akışı ve yaşam süresini (TTL) değiştirme

Bir öğede TTL (yaşam süresi) özelliği ayarlanırsa, değişiklik akışı süresiz olarak kalır. Veriler silinmediği takdirde değişiklik akışında kalır.

Akışı ve _etag _lsn veya _ts değiştirme

_Etag biçimi dahili olur ve herhangi bir zamanda değiştirebileceğinden buna bağımlılığı almanız gerekir. _ts bir değiştirme veya oluşturma zaman damgası. Kronolojik karşılaştırma için _ts kullanabilirsiniz. _lsn yalnızca değişiklik akışı için eklenen bir toplu iş KIMLIĞIDIR; işlem KIMLIĞINI temsil eder. Birçok öğe aynı _lsn sahip olabilir. FeedResponse üzerinde ETag, öğede gördüğünüz _etag 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ü belirtir, ancak ETag özelliği akışın sıralaması için kullanılır.

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

Değişiklik akışı ile aşağıdaki seçenekleri kullanarak çalışabilirsiniz:

• Azure Işlevleri ile değişiklik akışını kullanma
• Değişiklik akışı işlemcisi ile değişiklik akışını kullanma

Değişiklik akışı, kapsayıcı içindeki her mantıksal bölüm anahtarı için kullanılabilir ve aşağıdaki görüntüde gösterildiği gibi paralel işleme için bir veya daha fazla tüketiciye dağıtılabilir.

Değişiklik akışı özellikleri

• değişiklik akışı, tüm Azure Cosmos hesapları için varsayılan olarak etkindir.

• Azure Cosmos veritabanınız ile ilişkili bölgelerin herhangi birinde olduğu Azure Cosmos DB gibi değişiklik akışından okumak için sağlanan aktarım hızını kullanabilirsiniz.

• Değişiklik akışı, kapsayıcı içindeki öğelere yapılan ekleme ve güncelleştirme işlemlerini içerir. Öğelerin (örneğin, belgeler) içinden silme yerine "geçici silme" bayrağını ayarlayarak silmeleri yakalayabilirsiniz. Alternatif olarak, TTL özelliğiolan öğeleriniz için sonlu bir süre sonu süresi ayarlayabilirsiniz. Örneğin, 24 saat ve silmeleri yakalamak için bu özelliğin değerini kullanın. Bu çözümle, değişiklikleri TTL süre sonu süresinden daha kısa bir zaman aralığı içinde işleyebilmeniz gerekir.

• Değişiklik günlüğüne yalnızca belirli bir öğe için en son değişiklik eklenir. Ara değişiklikler kullanılamıyor olabilir.

• Değişiklik günlüğünde bulunan her değişiklik, değişiklik akışında tam olarak bir kez görünür ve istemciler checkişaret mantığını yönetmelidir. Kontrol noktalarını yönetme karmaşıklığına engel olmak istiyorsanız, değişiklik akışı işlemcisi otomatik onay işareti ve "en az bir kez" semantiği sağlar. değişiklik akışı işlemcisi ile değişiklik akışını kullanma.

• Değişiklik akışı, her mantıksal bölüm anahtarı değeri içindeki değiştirilme sırasına göre sıralanır. Bölüm anahtarı değerleri arasında garantili bir sıra yok.

• Değişiklikler herhangi bir noktadan eşitlenebilir, bu, değişikliklerin kullanılabildiği sabit veri saklama süresi değildir.

• değişiklikler, bir Azure Cosmos kapsayıcısının tüm mantıksal bölüm anahtarları için paralel olarak kullanılabilir. Bu yetenek, büyük kapsayıcılardaki değişikliklerin birden çok tüketici tarafından paralel olarak işlenmesine izin verir.

• Uygulamalar aynı kapsayıcıda aynı anda birden fazla değişiklik akışı talep edebilir. Changefeedoçen. StartTime, ilk başlangıç noktası sağlamak için kullanılabilir. Örneğin, belirli bir saat saatine karşılık gelen devamlılık belirtecini bulmak için. Bu, belirtilmişse, StartTime ve Startfromstarted değerlerinin üzerine gelir. Changefeedo,. StartTime duyarlık değeri ~ 5 saniye.

Cassandra ve MongoDB API 'Lerinde akışı değiştirme

Değişiklik akışı işlevselliği, MongoDB API 'sinde değişiklik akışı olarak ve Cassandra API ' de koşul ile sorgulama olarak ortaya çıkmış. mongodb apı 'si için uygulama ayrıntıları hakkında daha fazla bilgi edinmek için bkz. mongodb için Azure Cosmos DB apı 'sindeki akışları değiştirme.

Native Apache Cassandra değişiklik verilerini yakalama (CDC), belirli tabloları arşivleme için bayrakla işaretleme ve CDC günlüğü için yapılandırılabilir bir diske ulaşıldığında bu tablolara yazmaları reddetme mekanizması sağlar. cassandra için Azure Cosmos DB apı 'sindeki akış değiştirme özelliği, değişiklikleri cql aracılığıyla koşullu olarak sorgulama yeteneğini geliştirir. uygulama ayrıntıları hakkında daha fazla bilgi edinmek için bkz. cassandra için Azure Cosmos DB apı 'sindeki akışı değiştirme.

Sonraki adımlar

Aşağıdaki makalelerde değişiklik akışı hakkında daha fazla bilgi edinmek için devam edebilirsiniz:

• Değişiklik akışını okuma seçenekleri
• Azure Işlevleri ile değişiklik akışını kullanma
• Değişiklik akışı işlemcisini kullanma