使用 Node.js 和 Azure Cosmos DB 適用於 MongoDB 的 API 建置應用程式

適用於： MongoDB

此範例示範如何使用 Node.js 和 Azure Cosmos DB 適用於 MongoDB 的 API 建置主控台應用程式。

若要使用此範例，您必須︰

• 建立 Azure Cosmos DB 帳戶，並將其設定為使用適用於 MongoDB 的 Azure Cosmos DB API。
• 擷取連接字串資訊。

建立 應用程式

1. 建立 app.js 檔案，複製並貼上下列程式碼。

   var MongoClient = require('mongodb').MongoClient;
   var assert = require('assert');
   var ObjectId = require('mongodb').ObjectID;
   var url = 'mongodb://<username>:<password>@<endpoint>.documents.azure.com:10255/?ssl=true';
   
   var insertDocument = function(db, callback) {
   db.collection('families').insertOne( {
           "id": "AndersenFamily",
           "lastName": "Andersen",
           "parents": [
               { "firstName": "Thomas" },
               { "firstName": "Mary Kay" }
           ],
           "children": [
               { "firstName": "John", "gender": "male", "grade": 7 }
           ],
           "pets": [
               { "givenName": "Fluffy" }
           ],
           "address": { "country": "USA", "state": "WA", "city": "Seattle" }
       }, function(err, result) {
       assert.equal(err, null);
       console.log("Inserted a document into the families collection.");
       callback();
   });
   };
   
   var findFamilies = function(db, callback) {
   var cursor =db.collection('families').find( );
   cursor.each(function(err, doc) {
       assert.equal(err, null);
       if (doc != null) {
           console.dir(doc);
       } else {
           callback();
       }
   });
   };
   
   var updateFamilies = function(db, callback) {
   db.collection('families').updateOne(
       { "lastName" : "Andersen" },
       {
           $set: { "pets": [
               { "givenName": "Fluffy" },
               { "givenName": "Rocky"}
           ] },
           $currentDate: { "lastModified": true }
       }, function(err, results) {
       console.log(results);
       callback();
   });
   };
   
   var removeFamilies = function(db, callback) {
   db.collection('families').deleteMany(
       { "lastName": "Andersen" },
       function(err, results) {
           console.log(results);
           callback();
       }
   );
   };
   
   MongoClient.connect(url, function(err, client) {
   assert.equal(null, err);
   var db = client.db('familiesdb');
   insertDocument(db, function() {
       findFamilies(db, function() {
       updateFamilies(db, function() {
           removeFamilies(db, function() {
               client.close();
           });
       });
       });
   });
   });
   

   選擇性：如果您使用 MongoDB Node.js 2.2 驅動程式，請取代以下程式碼片段：

   原始：

   MongoClient.connect(url, function(err, client) {
   assert.equal(null, err);
   var db = client.db('familiesdb');
   insertDocument(db, function() {
       findFamilies(db, function() {
       updateFamilies(db, function() {
           removeFamilies(db, function() {
               client.close();
           });
       });
       });
   });
   });
   

   應取代為：

   MongoClient.connect(url, function(err, db) {
   assert.equal(null, err);
   insertDocument(db, function() {
       findFamilies(db, function() {
       updateFamilies(db, function() {
           removeFamilies(db, function() {
               db.close();
           });
       });
       });
   });
   });
   

2. 在 app.js 中根據每個帳戶設定 (了解如何尋找您的連接字串) 修改下列變數：

   重要

   MongoDB Node.js 3.0 驅動程式要求您為 Azure Cosmos DB 密碼中的特殊字元編碼。 請務必將 '=' 字元編碼為 %3D

   範例：密碼 jm1HbNdLg5zxEuyD86ajvINRFrFCUX0bIWP15ATK3BvSv== 應編碼為 jm1HbNdLg5zxEuyD86ajvINRFrFCUX0bIWP15ATK3BvSv%3D%3D

   MongoDB Node.js 2.2 驅動程式不要求您為 Azure Cosmos DB 密碼中的特殊字元編碼。

   var url = 'mongodb://<endpoint>:<password>@<endpoint>.documents.azure.com:10255/?ssl=true';
   

3. 開啟您最愛的終端機，執行 npm install mongodb --save，然後使用 node app.js 執行您的應用程式

下一步

• 了解如何使用 Studio 3T 搭配 Azure Cosmos DB 適用於 MongoDB 的 API。
• 了解如何使用 Robo 3T 搭配 Azure Cosmos DB 適用於 MongoDB 的 API。
• 使用 Azure Cosmos DB 適用於 MongoDB 的 API 瀏覽 Cosmos DB 範例。
• 正在嘗試為遷移至 Azure Cosmos DB 進行容量規劃嗎？ 您可以使用現有資料庫叢集的相關資訊進行容量規劃。
  • 如果您知道現有資料庫叢集中的虛擬核心和伺服器數目，請參閱使用虛擬核心或 vCPU 來估計要求單位
  • 如果您知道目前資料庫工作負載的一般要求率，請參閱使用 Azure Cosmos DB 容量規劃工具來估計要求單位