Azure函数无法更新多个Cosmos文档

Question

{
  "bindings": [
    {
      "name": "myTimer",
      "type": "timerTrigger",
      "direction": "in",
      "schedule": "0 */10 * * * *"
    },
    {
      "name": "DocumentInput",
      "type": "cosmosDB",
      "databaseName": "MyDB1",
      "collectionName": "MyCC1",
      "sqlQuery": "SELECT * FROM c",
      "partitionKey": "/key",
      "connectionStringSetting": "CosmosDBConnectionExp",
      "direction": "in"
    },
    {
      "name": "DocumentOutput",
      "type": "cosmosDB",
      "databaseName": "MyDB1",
      "collectionName": "MyCC1",
      "createIfNotExists": false,
      "partitionKey": "/key",
      "connectionStringSetting": "CosmosDBConnectionExp",
      "direction": "out"
    }
  ]
}

const PushDataChanges = async (context) => {
    
    var cosmosOutput = context.bindings.DocumentOutput;
    var cosmosInput = context.bindings.DocumentInput;
   
    cosmosOutput = cosmosInput;
 

    for(var i = 0; i < cosmosOutput.length; i++) {
   
        var document = cosmosOutput[i];
        var docid = cosmosOutput[i].id;
        var now = new Date().toISOString();

        document.id = docid; //Making sure the id key is same so upsert or update happens.
        document.experiment.lastProcessedTime = "now";
        document.experiment.updateStatus = "This is now updated";
    }

    context.done();

}


module.exports = function (context, Timer) {
    
    context.log('Starting Delta Data Extraction and Sentiment Analysis');
    PushDataChanges(context);
     
};

Answer 1

这就是我在经历了大量的尝试和错误后终于成功的东西！用于Azure函数的cosmos绑定文档非常少。我花了很多时间从文档中的示例中推断出如何只更新一个文档。下面的代码给出了使用Java脚本通过Azure函数为多个cosmos DB文档更新/upsert的方法。

功能代码：

const PushDataChanges = async (context) => {
    
    var inputdoc = context.bindings.DocumentInput;
   
    for(var i = 0; i < inputdoc.length; i++) {

        console.log(inputdoc.length);

        var now2 = new Date().toISOString();

        inputdoc[i].experiment.updateStatus = "This is updated now";
        inputdoc[i].experiment.lastProcessedTime = now2;
        context.bindings.DocumentOutput = inputdoc;
    }


context.done;
}

module.exports = function (context, Timer) {
    
    context.log('Starting the Azure Function');

    PushDataChanges(context);

    context.done();
     
};

下面是我的绑定：

{
  "bindings": [
    {
      "name": "myTimer",
      "type": "timerTrigger",
      "direction": "in",
      "schedule": "0 0 */8 * * *"
    },
    {
      "type": "cosmosDB",
      "name": "DocumentInput",
      "databaseName": "gsk-next-internal-datastore",
      "collectionName": "experiment",
      "sqlQuery": "SELECT * FROM c",
      "connectionStringSetting": "CosmosDBConnectionExp",
      "direction": "in"
    },
    {
      "type": "cosmosDB",
      "name": "DocumentOutput",
      "databaseName": "gsk-next-internal-datastore",
      "collectionName": "experiment",
      "createIfNotExists": false,
      "connectionStringSetting": "CosmosDBConnectionExp",
      "direction": "out"
    }
  ]
}