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

Azure Cosmos DB, iki değişim akışı modu sunar. Her mod aynı temel işlevselliği sunar. Farklılıklar, beslemede yakalanan operasyonlar, her değişiklik için mevcut olan meta veriler ve değişikliklerin saklama süresi gibi unsurları içerir. Aynı Azure Cosmos DB kapsayıcısı için değişiklik akışını, her iş yükünün gereksinimlerini karşılamak üzere birden fazla uygulamada farklı modlarda tüketebilirsiniz. Her bir değişiklik akışı uygulaması, yalnızca tek bir modda değişiklik akışını okumak üzere yapılandırılabilir. Değişiklik akışını bir modda tüketmek, farklı bir uygulamada başka bir modda değişiklik akışını tüketmenizi engellemez.

Note

Değişiklik akışı modları hakkında herhangi bir geri bildiriminiz var mı? Bunu duymak istiyoruz! Görüşlerinizi doğrudan Azure Cosmos DB mühendislik ekibiyle paylaşmaktan çekinmeyin: cosmoschangefeed@microsoft.com.

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. Kap içindeki her öğenin en son sürümünü alırsınız. Örneğin, bir öğe oluşturulup değişiklik akışını okumadan önce güncellenirse, değişiklik akışında yalnızca güncellenmiş sürüm görünür. Silmeler değişiklik olarak kaydedilmez ve bir öğe silindiğinde, artık akışta bulunamaz. Varsayılan olarak etkinleştirilen son sürüm değişiklik akışı modu, Tablo API'si ve PostgreSQL API'si hariç olmak üzere tüm Azure Cosmos DB hesaplarıyla uyumludur. Bu mod daha önce değişiklik akışını tüketmenin varsayılan yolu olarak kullanılıyordu.

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

Tüm sürümler ve silmeler modu (ön izleme), oluşturma, güncelleme ve silme işlemlerinden kaynaklanan öğelerdeki 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, bir öğe oluşturulur ve ardından değişiklik akışını okumadan önce güncellenirse, hem oluşturma hem de güncelleme sürümleri değişiklik akışında görünür. Tüm sürümler ve silme modu için değişiklik akışından okumak istiyorsanız, Azure Cosmos DB hesabınızda sürekli yedeklemelerin yapılandırılmış olması gerekmektedir. Sürekli yedeklemeler etkinleştirildiğinde tüm sürümler oluşturulur ve değişiklik akışı silinir. Yalnızca bu değişiklik akış modu kullanılırken sürekli yedekleme dönemi içinde meydana gelen 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, bir kaptaki öğelerin hem gerçek zamanlı hem de geçmiş değişikliklerini işlemeyi kolaylaştırır ve kabın başlangıcından itibaren değişikliklere geri dönme yeteneği sağlar.

Aşağıdakiler, bu moda uygun senaryolardır:

• Bir konteynerin tamamının ikincil bir konuma taşınması.

• Konteynerin başlangıcından itibaren değişiklikleri yeniden işleme yeteneği.

• 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ında silmeleri veya ara değişiklikleri yakalamaya ihtiyaç duymayan iş yükleri.

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

"Tüm sürümler ve silmeler değişim besleme modu, değişim besleme için yeni senaryoları etkinleştirir ve diğerlerini basitleştirir." Öğelerde meydana gelen her değişikliği okuyabilirsiniz (değişiklik akışı okumaları arasında birden fazla değişiklik meydana gelmiş olsa bile), işlenmekte olan değişikliklerin işlem türünü tanımlayabilir ve silmelerden kaynaklanan değişiklikleri elde edebilirsiniz.

Bu modu etkinleştiren ve geliştiren birkaç yaygın senaryo şunlardır:

• İki konum arasında gerçek zamanlı veri aktarımı, yumuşak silme uygulaması olmadan yapılır.

• Değişim beslemeleri arasında belirli bir öğe için birden fazla değişim işlemi bekleniyorsa, artımlı değişikliklere dayanan tetikleyici mantık.

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

• İşlem türüne bağlı olarak öğe oluşturma, güncelleme ve silme işlemlerini farklı şekilde işleme yeteneği.

Her bir modun özellikleri

Tüm değişiklik yayını modları için ortak özelliklerin yanı sıra, her bir değişiklik yayını modunun aşağıdaki özellikleri bulunmaktadır:

En son sürüm modu

• Değişiklik akışı, konteynerdeki öğelere yapılan ekleme ve güncelleme işlemlerini içerir.

• Bu değişim akışı modu silmeleri kaydetmez. Silinmeleri doğrudan silmek yerine öğeleriniz içinde bir "yumuşak silme" bayrağı ayarlayarak yakalayabilirsiniz. Örneğin, deleted adında bir öğe içinde true değerine sahip bir özellik ekleyebilir ve ardından öğeye bir Yaşam Süresi (TTL) ayarlayabilirsiniz. Değişim akışı bunu bir güncelleme olarak yakalar ve TTL süresi dolduğunda öğe otomatik olarak silinir. Alternatif olarak, TTL yeteneğini kullanarak, öğeleriniz için sınırlı bir son kullanma süresi belirleyebilirsiniz. Bu çözümle, değişiklikleri TTL süresinin dolma süresinden daha kısa bir zaman aralığında işlemek zorundasınız.

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

• 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.

• Belirli bir işlem türü için değişiklik akışını filtreleyemezsiniz. Olası bir alternatif, güncellemeler için öğeye bir "yumuşak işaretleyici" eklemek ve değişiklik akışında öğeleri işlerken işaretleyiciye göre filtreleme yapmaktır.

• 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 hassasiyeti yaklaşık beş saniyedir.

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

• Değişiklik beslemesi, kapsayıcı içindeki öğelere yapılan ekleme, güncelleme ve silme işlemlerini içerir. Tarif süresi dolumlarından kaynaklanan silmeler de yakalanır.

• Değişiklik türünü belirlemek için metadata sağlanır, bu değişikliğin bir TTL süresinin dolması nedeniyle silme olup olmadığı da dahil.

• Değişiklik akışı öğeleri, değişiklik zamanlarının sırasına göre gelir. İşlem grubu, saklı yordam veya toplu mod isteği kapsamında yazılan öğeler aynı değişiklik zamanına sahiptir ve bu kapsamdaki değişiklikler herhangi bir sırada teslim edilebilir. TTL süre sonu silmelerinin, öğenin süresi dolduktan hemen sonra akışta görünmesi garanti değildir. Kap içinden öğe temizlendiğinde ortaya çıkarlar.

• Hesap üzerindeki sürekli yedeklemelerde saklama penceresi sırasında meydana gelen 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ışının başlangıç ​​noktası, "now" veya saklama süreniz içindeki belirli bir kontrol noktası olabilir. Bu modu kullanarak değişiklikleri kabın başlangıcından veya belirli bir zamandan itibaren okuyamazsınız.

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

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

En son sürüm modu

En son sürüm modunda değişiklik akışından değişiklikleri almak için aşağıdaki yolları kullanabilirsiniz:

Değişiklik akışını okumak için yöntem	.NET	Java	Python	Node.js
Akış çekme modelini değiştirme	Yes	Yes	Yes	Yes
Değişiklik akışı işlemcisi	Yes	Yes	Hayı	Hayı
Azure İşlevleri tetikleyicisi	Yes	Yes	Yes	Yes

Yanıt nesnesini ayrıştır

En son sürüm modunda, varsayılan yanıt nesnesi, değişen öğelerin bir dizisidir. Her bir öğe, _etag ve _ts dahil olmak üzere, herhangi bir Azure Cosmos DB öğesi için standart meta verileri içerir ve _lsn adlı yeni bir özelliğin eklenmesiyle birlikte gelir.

_etag formatı dahili bir formattır ve ona bağlı kalmamalısınız çünkü istediği zaman değişebilir. _ts bir değiştirme veya oluşturma zaman damgasıdır. Kronolojik karşılaştırma için _ts kullanabilirsiniz. _lsn, yalnızca değişiklik akışı için eklenen ve işlem kimliğini temsil eden bir yığın kimliğidir. Birçok öğe aynı _lsn'e sahip olabilir.

ETag üzerindeki FeedResponse, öğe üzerinde gördüğünüz _etag’den farklıdır. _etag dahili bir tanımlayıcıdır ve eşzamanlılık kontrolü için kullanılır. _etag özelliği, öğenin sürümünü temsil ederken, ETag özelliği beslemenin sıralanması için kullanılır.

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

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

Değişiklik akışını okumak için yöntem	.NET	Java	Python	Node.js	Spark
Akış çekme modelini değiştirme	>= 3.32.0-önizleme	>= 4.63.3	>= 4.9.1b1	>= 4.1.0	>= Tüm Spark Çalışma Zamanları için 4.40.0
Değişiklik akışı işlemcisi	>= 3.40.0-preview.0	>= 4.63.3	Hayı	Hayı	Hayı
Azure İşlevleri tetikleyicisi	Hayı	Hayı	Hayı	Hayı	Hayı

Note

Uygulamanızda yapılandırılan bağlantı modu ne olursa olsun, tüm sürümlerle yapılan değişiklik ve silme beslemeleri için yapılan tüm istekler Gateway modu kullanacaktır.

Get started

Tüm sürümleri kullanmaya başlamak ve değişiklik akışı modunu silmek için Azure Cosmos DB hesabınızdaki Özellikler sayfasına gidin. Tüm sürümler ve silmeler değişiklik akışı modu (önizleme) özelliğini seçip etkinleştirin. Özelliği etkinleştirmeden önce Azure Cosmos DB hesabınız için sürekli yedeklemelerin yapılandırılmış olması gerekir. Etkinleştirme işleminin tamamlanması 30 dakika kadar sürebilir ve bu süre boyunca hesapta başka bir değişiklik yapılamaz.

Alternatif olarak, "enableAllVersionsAndDeletesChangeFeed" : true REST API ile önceden mevcut bir hesabın properties kısmına ekleyerek tüm sürümleri ve silme modunu etkinleştirin. Bu özellik önizleme API'sinde veya sonraki sürümlerde 2024-12-01-preview kullanılabilir. Hesap oluşturma sırasında bu özelliğin etkinleştirilmesi desteklenmez.

Yanıt nesnesini ayrıştır

Yanıt nesnesi, her değişikliği temsil eden öğelerin bir dizisidir. Değişiklik türüne bağlı olarak farklı özellikler doldurulacaktır. Şu anda, değiştirme veya silme işlemleri için öğelerin önceki sürümünü elde etmenin bir yolu yoktur.

• İşlemleri oluştur

  {
    "current": {
      <The current version of the item that changed. All the properties of your item will appear here.>
    },
    "metadata": {
      "operationType": "create",
      "lsn": <A number that represents the batch ID. Many items can have the same lsn.>,
      "crts": <A number that represents the Conflict Resolved Timestamp. It has the same format as _ts.>
    }
  }
  

• Değiştirme işlemleri

  {
    "current": {
      <The current version of the item that changed. All the properties of your item will appear here.>
    },
    "metadata": {
      "operationType": "replace",
      "lsn": <A number that represents the batch ID. Many items can have the same lsn.>,
      "crts": <A number that represents the Conflict Resolved Timestamp. It has the same format as _ts.>,
      "previousImageLSN" : <A number that represents the batch ID of the change prior to this one.>,
    }
  }
  

• Silme işlemleri

  {
    "metadata": {
      "operationType": "delete",
      "lsn": <A number that represents the batch ID. Many items can have the same lsn.>,
      "crts": <A number that represents the Conflict Resolved Timestamp. It has the same format as _ts.>,
      "previousImageLSN" : <A number that represents the batch ID of the change prior to this one.>,
      "timeToLiveExpired" : <'true' if it was deleted due to a TTL expiration.>,
      "id": "<Id of the deleted item.>",
      "partitionKey": {
        "<Partition key property name>": "<Partition key property value>"
      }
    }
  }
  

Sınırlamalar

• NoSQL hesapları için Azure Cosmos DB'yi destekler. Diğer Azure Cosmos DB hesap türleri desteklenmemektedir.

• Bu değişiklik besleme modunu kullanmak için sürekli yedeklemeler gereklidir. Sürekli yedekleme kullanımının sınırlamalarına bakın.

• Değişiklik akışını baştan okumaya başlama veya geçmiş bir zaman damgasına göre başlangıç zamanı seçme özelliği şu anda desteklenmiyor. "Ya 'şimdi'den ya da daha önceki bir kiralama veya devam belirteci ile başlayabilirsiniz."

• Silinmiş veya güncellenmiş öğelerin önceki sürümlerini almak şu anda mümkün değil.

• Bölümlerin birleştirilmesini etkinleştiren hesaplar desteklenmiyor.

Sonraki Adımlar

"Değişiklik akışı hakkında daha fazla bilgi edinin: Aşağıdaki makalelerde öğrenin:"

• Değişiklik akışına genel bakış
• Değişiklik akışı tasarım kalıpları
• Değişiklik akışını okuma seçenekleri