MongoDB için Azure Cosmos DB'de depolanan verileri yönetmek için MongoDB uzantısı komutlarını kullanma

ŞUNLAR IÇIN GEÇERLIDIR: MongoDB

Aşağıdaki belgede MongoDB için Azure Cosmos DB'ye özgü özel eylem komutları yer alır. Bu komutlar, Azure Cosmos DB kapasite modeline özgü veritabanı kaynakları oluşturmak ve almak için kullanılabilir.

MongoDB için Azure Cosmos DB'yi kullanarak Azure Cosmos DB'nin paylaşılan avantajlarından yararlanabilirsiniz. Bu avantajlar şunlardır ancak bunlarla sınırlı değildir:

• Genel dağıtım
• Otomatik parçalama
• Yüksek kullanılabilirlik
• Gecikme süresi garantileri
• Bekleme sırasında şifreleme
• Yedekler

Mevcut MongoDB uygulamanıza yaptığınız yatırımları korurken bu avantajlardan yararlanabilirsiniz. Açık kaynak MongoDB istemci sürücülerinden herhangi birini kullanarak MongoDB için Azure Cosmos DB ile iletişim kurabilirsiniz. MongoDB için Azure Cosmos DB, MongoDB kablo protokolüne bağlı olarak mevcut istemci sürücülerinin kullanılmasını sağlar.

MongoDB protokol desteği

MongoDB için Azure Cosmos DB, MongoDB sunucu sürümü 4.0, 3.6 ve 3.2 ile uyumludur. Daha fazla bilgi için bkz. 4.0, 3.6 ve 3.2 sürümlerinde desteklenen özellikler ve söz dizimi.

Aşağıdaki uzantı komutları, veritabanı istekleri aracılığıyla Azure Cosmos DB'ye özgü kaynakları oluşturur ve değiştirir:

• Veritabanı oluşturma
• Veritabanını güncelleştirme
• Veritabanı alma
• Koleksiyon oluşturma
• Koleksiyonu güncelleştirme
• Koleksiyon alma

Veritabanı oluşturma

Veritabanı uzantısı oluştur komutu yeni bir MongoDB veritabanı oluşturur. Veritabanı adı, komutu tarafından ayarlanan veritabanı bağlamından use database kullanılabilir. Aşağıdaki tabloda komutundaki parametreler açıklanmaktadır:

Çıktı

Komut başarılı olursa aşağıdaki yanıtı döndürür:

{ "ok" : 1 }

Çıktıdaki parametreler için özel komutun varsayılan çıkışına bakın.

Örnek: Veritabanı oluşturma

Tüm varsayılan değerleri kullanan adlı "test" bir veritabanı oluşturmak için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "CreateDatabase"});

Bu komut, veritabanı düzeyinde aktarım hızı olmayan bir veritabanı oluşturur. Bu işlem, bu veritabanındaki koleksiyonların kullanmanız gereken aktarım hızı miktarını belirtmesi gerektiği anlamına gelir.

Örnek: Aktarım hızıyla veritabanı oluşturma

adlı "test" bir veritabanı oluşturmak ve 1000 RU'nun veritabanı düzeyinde sağlanan aktarım hızını belirtmek için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "CreateDatabase", offerThroughput: 1000 });

Bu komut bir veritabanı oluşturur ve buna bir aktarım hızı ayarlar. Koleksiyonlar belirli bir aktarım hızı düzeyiyle oluşturulmadığı sürece, bu veritabanındaki tüm koleksiyonlar ayarlanan aktarım hızını paylaşır.

Örnek: Otomatik ölçeklendirme aktarım hızıyla veritabanı oluşturma

adlı "test" bir veritabanı oluşturmak ve veritabanı düzeyinde maksimum 20.000 RU/sn aktarım hızını otomatik ölçeklendirmek için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "CreateDatabase", autoScaleSettings: { maxThroughput: 20000 } });

Veritabanını güncelleştirme

Veritabanı uzantısını güncelleştir komutu, belirtilen veritabanıyla ilişkili özellikleri güncelleştirir. Veritabanınızı sağlanan aktarım hızından otomatik ölçeklendirmeye (veya tam tersi) değiştirmek yalnızca Azure portalında desteklenir. Aşağıdaki tabloda komutundaki parametreler açıklanmaktadır:

Bu komut, oturum bağlamında belirtilen veritabanını kullanır. Bu veritabanı, komutta kullandığınız veritabanıyla use <database> aynıdır. Şu anda bu komut kullanılarak veritabanı adı değiştirilemez.

Çıktı

Komut başarılı olursa aşağıdaki yanıtı döndürür:

{ "ok" : 1 }

Çıktıdaki parametreler için özel komutun varsayılan çıkışına bakın.

Örnek: Veritabanıyla ilişkili sağlanan aktarım hızını güncelleştirme

Adı "test" 1200 RU olan bir veritabanının sağlanan aktarım hızını güncelleştirmek için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "UpdateDatabase", offerThroughput: 1200 });

Örnek: Veritabanıyla ilişkili Otomatik Ölçeklendirme aktarım hızını güncelleştirme

Bir veritabanının sağlanan "test" aktarım hızını 20.000 RU'ya güncelleştirmek veya otomatik ölçeklendirme aktarım hızı düzeyine dönüştürmek için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "UpdateDatabase", autoScaleSettings: { maxThroughput: 20000 } });

Veritabanı alma

Veritabanı uzantısını al komutu veritabanı nesnesini döndürür. Veritabanı adı, komutun yürütüldiği veritabanı bağlamından kullanılır.

{
  customAction: "GetDatabase"
}

Aşağıdaki tabloda komutundaki parametreler açıklanmaktadır:

Çıktı

Komut başarılı olursa, yanıt aşağıdaki alanları içeren bir belge içerir:

Komut başarısız olursa, varsayılan bir özel komut yanıtı döndürülür. Çıktıdaki parametreler için özel komutun varsayılan çıkışına bakın.

Örnek: Veritabanını alma

adlı "test"bir veritabanının veritabanı nesnesini almak için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "GetDatabase"});

Veritabanında ilişkili aktarım hızı yoksa çıkış şu şekilde olur:

{ "database" : "test", "ok" : 1 }

Veritabanıyla ilişkilendirilmiş veritabanı düzeyinde el ile aktarım hızı varsa çıktıda provisionedThroughput şu değerler gösterilir:

{ "database" : "test", "provisionedThroughput" : 20000, "ok" : 1 }

Veritabanıyla ilişkilendirilmiş veritabanı düzeyinde bir Otomatik Ölçeklendirme aktarım hızı varsa, çıkışta veritabanı autoScaleSettings için en düşük RU/sn'yi açıklayan ve veritabanı için en yüksek RU/sn'yi açıklayan öğesini içeren maxThroughputnesnesi gösterilirprovisionedThroughput.

{
        "database" : "test",
        "provisionedThroughput" : 2000,
        "autoScaleSettings" : {
                "maxThroughput" : 20000
        },
        "ok" : 1
}

Koleksiyon oluşturma

Koleksiyon uzantısı oluştur komutu yeni bir MongoDB koleksiyonu oluşturur. Veritabanı adı, komutu tarafından ayarlanan veritabanları bağlamından use database kullanılır. CreateCollection komutunun biçimi aşağıdaki gibidir:

{
  customAction: "CreateCollection",
  collection: "<Collection Name>",
  shardKey: "<Shard key path>",
  // Replace the line below with "autoScaleSettings: { maxThroughput: (int) }" to use Autoscale instead of Provisioned Throughput. Fill the required Autoscale max throughput setting.
  offerThroughput: (int) // Provisioned Throughput enabled with required throughput amount set.
  indexes: [{key: {_id: 1}, name: "_id_1"}, ... ] // Optional indexes (3.6+ accounts only).
}

Aşağıdaki tabloda komutundaki parametreler açıklanmaktadır:

Çıktı

Varsayılan bir özel komut yanıtı döndürür. Çıktıdaki parametreler için özel komutun varsayılan çıkışına bakın.

Örnek: En düşük yapılandırmaya sahip bir koleksiyon oluşturma

Ad "testCollection" ve varsayılan değerlerle yeni bir koleksiyon oluşturmak için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "CreateCollection", collection: "testCollection"});

Bu işlem, 400RU/sn ile yeni bir sabit, parçalanmamış koleksiyon ve otomatik olarak oluşturulan alanda bir dizinle _id sonuçlanır. Bu yapılandırma türü, işlev aracılığıyla insert() yeni koleksiyonlar oluştururken de geçerlidir. Örneğin:

use test
db.newCollection.insert({});

Örnek: Parçalanmamış koleksiyon oluşturma

Adı "testCollection" ve sağlanan aktarım hızı 1000 RU olan parçalanmamış bir koleksiyon oluşturmak için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "CreateCollection", collection: "testCollection", offerThroughput: 1000});

Parça anahtarı belirtmenize gerek kalmadan 10.000 RU/sn'ye offerThroughput kadar olan bir koleksiyon oluşturabilirsiniz. Daha büyük aktarım hızına sahip koleksiyonlar için sonraki bölüme göz atın.

Örnek: Parçalı koleksiyon oluşturma

Adı "testCollection" ve sağlanan aktarım hızı 11.000 RU olan parçalı bir koleksiyon ve shardkey "a.b" özelliği oluşturmak için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "CreateCollection", collection: "testCollection", offerThroughput: 11000, shardKey: "a.b" });

Bu komut artık parametresini shardKey gerektirir çünkü içinde 10.000 RU/sn'den fazla belirtilmiştir offerThroughput.

Örnek: Parçalanmamış otomatik ölçeklendirme koleksiyonu oluşturma

4.000 RU/sn'ye ayarlanmış Otomatik Ölçeklendirme aktarım hızı kapasitesini kullanan adlı 'testCollection' parçasız bir koleksiyon oluşturmak için aşağıdaki komutu kullanın:

use test
db.runCommand({ 
    customAction: "CreateCollection", collection: "testCollection", 
    autoScaleSettings:{
      maxThroughput: 4000
    } 
});

autoScaleSettings.maxThroughput Değer için, parça anahtarı olmadan 4.000 RU/sn ile 10.000 RU/sn arasında bir aralık belirtebilirsiniz. Daha yüksek otomatik ölçeklendirme aktarım hızı için parametresini shardKey belirtmeniz gerekir.

Örnek: Parçalı Otomatik Ölçeklendirme koleksiyonu oluşturma

adlı 'testCollection' 'a.b've 20.000 RU/sn'ye ayarlanmış Otomatik ölçeklendirme aktarım hızı kapasitesi kullanan bir parçalı koleksiyon oluşturmak için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "CreateCollection", collection: "testCollection", shardKey: "a.b", autoScaleSettings: { maxThroughput: 20000 }});

Koleksiyonu güncelleştirme

Koleksiyon uzantısını güncelleştir komutu, belirtilen koleksiyonla ilişkili özellikleri güncelleştirir. Koleksiyonunuzu sağlanan aktarım hızından otomatik ölçeklendirmeye (veya tam tersi) değiştirmek yalnızca Azure portalında desteklenir.

{
  customAction: "UpdateCollection",
  collection: "<Name of the collection that you want to update>",
  // Replace the line below with "autoScaleSettings: { maxThroughput: (int) }" if using Autoscale instead of Provisioned Throughput. Fill the required Autoscale max throughput setting. Changing between Autoscale and Provisioned throughput is only supported in the Azure Portal.
  offerThroughput: (int) // Provisioned Throughput enabled with required throughput amount set.
  indexes: [{key: {_id: 1}, name: "_id_1"}, ... ] // Optional indexes (3.6+ accounts only).
}

Aşağıdaki tabloda komutundaki parametreler açıklanmaktadır:

Çıktı

Varsayılan bir özel komut yanıtı döndürür. Çıktıdaki parametreler için özel komutun varsayılan çıkışına bakın.

Örnek: Bir koleksiyonla ilişkili sağlanan aktarım hızını güncelleştirme

Bir koleksiyonun sağlanan aktarım hızını adla "testCollection" 1200 RU'ya güncelleştirmek için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "UpdateCollection", collection: "testCollection", offerThroughput: 1200 });

Koleksiyon alma

Get collection özel komutu koleksiyon nesnesini döndürür.

{
  customAction: "GetCollection",
  collection: "<Name of the collection>"
}

Aşağıdaki tabloda komutundaki parametreler açıklanmaktadır:

Çıktı

Komut başarılı olursa, yanıt aşağıdaki alanları içeren bir belge içerir

Komut başarısız olursa, varsayılan bir özel komut yanıtı döndürülür. Çıktıdaki parametreler için özel komutun varsayılan çıkışına bakın.

Örnek: Koleksiyonu alma

adlı "testCollection"bir koleksiyonun koleksiyon nesnesini almak için aşağıdaki komutu kullanın:

use test
db.runCommand({customAction: "GetCollection", collection: "testCollection"});

Koleksiyonun kendisiyle ilişkilendirilmiş bir aktarım hızı kapasitesi varsa, değeri içerir provisionedThroughput ve çıkış şu şekilde olur:

{
        "database" : "test",
        "collection" : "testCollection",
        "provisionedThroughput" : 400,
        "ok" : 1
}

Koleksiyonun ilişkili bir Otomatik Ölçeklendirme aktarım hızı varsa, nesnesini parametresiyle maxThroughput birlikte içerir autoScaleSettings ve bu, koleksiyonun dinamik olarak artırdığı en yüksek aktarım hızını tanımlar. Ayrıca, koleksiyonda provisionedThroughput istek yoksa bu koleksiyonun azalttığı en düşük aktarım hızını tanımlayan değerini de içerir:

{
        "database" : "test",
        "collection" : "testCollection",
        "provisionedThroughput" : 1000,
        "autoScaleSettings" : {
            "maxThroughput" : 10000
        },
        "ok" : 1
}

Koleksiyon otomatik ölçeklendirme modunda veya el ile veritabanı düzeyinde aktarım hızını paylaşıyorsa çıkış şu şekilde olur:

{ "database" : "test", "collection" : "testCollection", "ok" : 1 }

{
        "database" : "test",
        "provisionedThroughput" : 2000,
        "autoScaleSettings" : {
            "maxThroughput" : 20000
        },
        "ok" : 1
}

Değişiklik akışlarını paralelleştirme

Değişiklik akışlarını büyük ölçekte kullanırken yükü eşit bir şekilde yaymak en iyisidir. Aşağıdaki komut bir veya daha fazla değişiklik akışı özgeçmiş belirteci döndürür. Her biri tek bir fiziksel parçadan/bölümden gelen verilere karşılık gelir (bir fiziksel bölümde birden çok mantıksal parça/bölüm bulunabilir). Her özgeçmiş belirteci watch() öğesinin yalnızca bu fiziksel parçadan/bölümden veri döndürmesine neden olur.

Değişiklik akışlarını verimli bir şekilde ölçeklendirmek için her özgeçmiş belirtecinde (belirteç başına bir iş parçacığı) kullanın db.collection.watch() .

{
        customAction: "GetChangeStreamTokens", 
        collection: "<Name of the collection>", 
        startAtOperationTime: "<BSON Timestamp>" // Optional. Defaults to the time the command is run.
} 

Örnek: Akış belirtecini alma

Her fiziksel parça/bölüm için bir özgeçmiş belirteci almak için özel komutu çalıştırın.

use test
db.runCommand({customAction: "GetChangeStreamTokens", collection: "<Name of the collection>"})

GetChangeStreamTokens özel komutundan döndürülen her özgeçmiş belirteci için bir watch() iş parçacığı/işlemi çalıştırın. İşte bir iş parçacığı örneği.

db.test_coll.watch([{ $match: { "operationType": { $in: ["insert", "update", "replace"] } } }, { $project: { "_id": 1, "fullDocument": 1, "ns": 1, "documentKey": 1 } }], 
{fullDocument: "updateLookup", 
resumeAfter: { "_data" : BinData(0,"eyJWIjoyLCJSaWQiOiJQeFVhQUxuMFNLRT0iLCJDb250aW51YXRpb24iOlt7IkZlZWRSYW5nZSI6eyJ0eXBlIjoiRWZmZWN0aXZlIFBhcnRpdGlvbiBLZXkgUmFuZ2UiLCJ2YWx1ZSI6eyJtaW4iOiIiLCJtYXgiOiJGRiJ9fSwiU3RhdGUiOnsidHlwZSI6ImNvbnRpbndkFLbiIsInZhbHVlIjoiXCIxODQ0XCIifX1dfQ=="), "_kind" : NumberInt(1)}})

resumeAfter alanındaki belge (değer), özgeçmiş belirtecini temsil eder. Komut watch() , GetChangeStreamTokens özel komutu çalıştırıldığından bu fiziksel bölümden eklenen, güncelleştirilen veya değiştirilen tüm belgeler için bir lanetleyici döndürür. Döndürülen verilerin bir örneği buraya eklenmiştir.

{
  "_id": {
    "_data": BinData(0,
    "eyJWIjoyLCJSaWQiOiJQeFVhQUxuMFNLRT0iLCJDfdsfdsfdsft7IkZlZWRSYW5nZSI6eyJ0eXBlIjoiRWZmZWN0aXZlIFBhcnRpdGlvbiBLZXkgUmFuZ2UiLCJ2YWx1ZSI6eyJtaW4iOiIiLCJtYXgiOiJGRiJ9fSwiU3RhdGUiOnsidHlwZSI6ImNvbnRpbnVhdGlvbiIsInZhbHVlIjoiXCIxOTgwXCIifX1dfQ=="),
    "_kind": 1
  },
  "fullDocument": {
    "_id": ObjectId("60da41ec9d1065b9f3b238fc"),
    "name": John,
    "age": 6
  },
  "ns": {
    "db": "test-db",
    "coll": "test_coll"
  },
  "documentKey": {
    "_id": ObjectId("60da41ec9d1065b9f3b238fc")
  }
}

Döndürülen her belge bir özgeçmiş belirteci içerir (her sayfa için hepsi aynıdır). İş parçacığı/işlem ölürse bu özgeçmiş belirteci depolanmalı ve yeniden kullanılmalıdır. Bu özgeçmiş belirteci kaldığınız yerden devam eder ve yalnızca bu fiziksel bölümden veri alır.

Özel komutun varsayılan çıkışı

Belirtilmezse, özel yanıt aşağıdaki alanlara sahip bir belge içerir:

Örneğin:

{ "ok" : 1 }

Sonraki adımlar

Ardından aşağıdaki Azure Cosmos DB kavramlarını öğrenmeye devam edebilirsiniz:

• Azure Cosmos DB’de dizin oluşturma
• Azure Cosmos DB'de verilerin yaşam süresiyle otomatik olarak süresinin dolması