使用 Node.js 和 Azure Cosmos DB 的用于 MongoDB 的 API 生成应用Build an app using Node.js and Azure Cosmos DB's API for MongoDB

• 03/04/2019
• • 

此示例说明如何使用 Node.js 和 Azure Cosmos DB 的用于 MongoDB 的 API 生成控制台应用。This example shows you how to build a console app using Node.js and Azure Cosmos DB's API for MongoDB.

若要使用此示例，必须：To use this example, you must:

• 创建 Cosmos 帐户，配置为使用 Azure Cosmos DB 的用于 MongoDB 的 API。Create a Cosmos account configured to use Azure Cosmos DB's API for MongoDB.
• 检索连接字符串信息。Retrieve your connection string information.

创建应用Create the app

1. 创建 app.js 文件，并复制粘贴以下代码。Create a app.js file and copy & paste the code below.

   var MongoClient = require('mongodb').MongoClient;
   var assert = require('assert');
   var ObjectId = require('mongodb').ObjectID;
   var url = 'mongodb://<username>:<password>@<endpoint>.documents.azure.cn: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 驱动程序，请替换下面的代码片段 ：Optional: If you are using the MongoDB Node.js 2.2 driver, please replace the following code snippet:

   原始：Original:

   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();
           });
       });
       });
   });
   });
   

   应替换为：Should be replaced with:

   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 文件中的以下变量（了解如何查找连接字符串）：Modify the following variables in the app.js file per your account settings (Learn how to find your connection string):

   Important

   MongoDB Node.js 3.0 驱动程序需要在 Cosmos DB 密码中对特殊字符进行编码 。The MongoDB Node.js 3.0 driver requires encoding special characters in the Cosmos DB password. 请务必将“=”字符编码为 %3DMake sure to encode '=' characters as %3D

   示例：密码 jm1HbNdLg5zxEuyD86ajvINRFrFCUX0bIWP15ATK3BvSv== 编码为 jm1HbNdLg5zxEuyD86ajvINRFrFCUX0bIWP15ATK3BvSv%3D%3D Example: The password jm1HbNdLg5zxEuyD86ajvINRFrFCUX0bIWP15ATK3BvSv== encodes to jm1HbNdLg5zxEuyD86ajvINRFrFCUX0bIWP15ATK3BvSv%3D%3D

   MongoDB Node.js 2.2 驱动程序无需在 Cosmos DB 密码中对特殊字符进行编码 。The MongoDB Node.js 2.2 driver does not require encoding special characters in the Cosmos DB password.

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

3. 打开偏爱的终端，运行 npm install mongodb --save，并使用 node app.js 运行应用程序Open your favorite terminal, run npm install mongodb --save, then run your app with node app.js

后续步骤Next steps

• 了解如何将 Studio 3T 与 Azure Cosmos DB 的用于 MongoDB 的 API 配合使用。Learn how to use Studio 3T with Azure Cosmos DB's API for MongoDB.
• 了解如何将 Robo 3T 与 Azure Cosmos DB 的用于 MongoDB 的 API 配合使用。Learn how to use Robo 3T with Azure Cosmos DB's API for MongoDB.
• 使用 Azure Cosmos DB 的用于 MongoDB 的 API 浏览 MongoDB 示例。Explore MongoDB samples with Azure Cosmos DB's API for MongoDB.