В функциях Azure выполните запрос Cosmos DB в коде

Question

Могу ли я запустить Cosmos DB Query в самом коде? Все, что я мог сделать прямо сейчас, - это выполнить запрос до запуска кода (ввода). Что мне нужно, это сначала запустить некоторый код, а затем получить данные в космической БД. Как мне сделать это с помощью JavaScript?

Answer 1

При использовании привязки ввода есть опция (но только для C #) для извлечения DocumentClient , которую можно использовать для запуска любого запроса или операции.

Если вашограничение работает на JavaScript, вы, безусловно, можете использовать Cosmos DB JS SDK непосредственно в вашей функции вместо использования привязки ввода, например:

const cosmos = require('@azure/cosmos');
const endpoint = process.env.COSMOS_API_URL;
const masterKey = process.env.COSMOS_API_KEY;
const { CosmosClient } = cosmos;

const client = new CosmosClient({ endpoint, auth: { masterKey } });
// All function invocations also reference the same database and container.
const container = client.database("MyDatabaseName").container("MyContainerName");

module.exports = async function (context) {
    const querySpec = {
        query: "SELECT * FROM Families f WHERE  f.lastName = @lastName",
        parameters: [
          {
            name: "@lastName",
            value: "Andersen"
          }
        ]
    };

    const { result: results } = await container.items.query(querySpec).toArray();
    context.log(results);
}

COSMOS_API_URL и COSMOS_API_KEYдолжны быть переменными среды, указывающими на конечную точку учетной записи Azure Cosmos и мастер-ключ.При необходимости вы можете заменить имена базы данных, контейнера и повозки запросом.

Answer 2

Вы можете сослаться на пример кода в этой ссылке :

function.json:

{
  "bindings": [
    {
      "name": "query",
      "type": "httpTrigger",
      "direction": "in"
    },
    {
      "name": "$return",
      "type": "http",
      "direction": "out"
    },
    {
      "type": "documentDB",
      "name": "documents",
      "databaseName": "<your-database-name>",
      "collectionName": "<your-collection-name>",
      "sqlQuery": "SELECT * FROM d WHERE d.name = {Name} and d.city = {City}",
      "connection": "<connectionstring-setting-name>",
      "direction": "in"
    }
  ],
  "disabled": false
}

код функции:

module.exports = function (context, req) {
    var documents = context.bindings.documents;
    var totalDocuments = documents.length;
    context.log('Found '+ totalDocuments +' documents');

    if(totalDocuments === 0){
        context.res = {
            status: 404,
            body : "No documents found"
        };
    }
    else {
        context.res = {
            body: documents
        };
    }

    context.done();
};

Обратите внимание: приведенный выше код работает для конфигурации привязки Azure Function V1 .