如何使用 Azure 函数返回 documentDB 文档？答案

【问题标题】：How to return a documentDB document with Azure functions?如何使用 Azure 函数返回 documentDB 文档？
【发布时间】：2017-02-02 04:01:25
【问题描述】：

我创建了一个 azure 函数以及一个带有用户集合的 documentDB 数据库，但是，我坚持将它们两者相互连接起来。我只想发送一个用户名，该函数会查询数据库，然后返回具有该唯一用户名的用户。

我正在使用节点 js。有什么想法吗？

谢谢

【问题讨论】：

您能否提供一个您尝试过的示例代码，以便我们提供帮助？顺便说一句，DocumentDB 和 Azure Functions 绑定的一个很好的参考是 Azure Functions DocumentDB bindings。

标签： javascript node.js azure azure-cosmosdb azure-functions

【解决方案1】：

首先，您需要通过 npm 安装 documentdb 模块。使用以下命令：

npm install documentdb --save

之后，您就完成了设置。现在您可以开始编写一些代码来查询数据库中的集合。以下是使用 Azure HTTP 触发函数查询 family 集合的示例。

文件夹结构：

node_modules/
.gitignore
config.js
function.json
index.js
package.json

CONFIG.JS

var config = {}

config.endpoint = "https://<documentdb name>.documents.azure.com:443/";
config.primaryKey = "<primary key>";

config.database = {
    "id": "FamilyDB"
};

config.collection = {
    "id": "FamilyColl"
};

module.exports = config;

INDEX.JS

var documentClient = require("documentdb").DocumentClient;
var config = require("./config");

var databaseUrl = `dbs/${config.database.id}`;
var collectionUrl = `${databaseUrl}/colls/${config.collection.id}`;

var client = new documentClient(config.endpoint, { "masterKey": config.primaryKey });

module.exports = function (context, req) {
    context.log('JavaScript HTTP trigger function processed a request.');

    if (req.query.name || (req.body && req.body.name)) {

        var name = req.query.name || req.body.name;

        queryCollectionByName(name).then((result) => {
            context.log('result: ', result);
            res = {
                body: "Result: " + JSON.stringify(result)
            };

            context.done(null, res);

        }, (err) => {
            context.log('error: ', err);
            res = {
                body: "Error: " + JSON.stringify(err)
            };

            context.done(null, res);
        });

    }
    else {
        res = {
            status: 400,
            body: "Please pass a name on the query string or in the request body"
        };

        context.done(null, res);
    }
};


function queryCollectionByName(name) {

    return new Promise((resolve, reject) => {
        client.queryDocuments(
            collectionUrl,
            `SELECT VALUE r.children FROM root r WHERE r.lastName = "${name}"`
        ).toArray((err, results) => {
            if (err) reject(err)
            else {
                resolve(results);
            }
        });
    });
};

测试结果：

【讨论】：

非常感谢，这就是我目前正在做的事情，我认为有一种更简单的方法可以将它们连接在一起。我正在寻找一种更“原生”的方法。不过谢谢！