public static class ctTestCosmos
    {
        [FunctionName("ctTestCosmos")]
        public static void Run([CosmosDBTrigger(
            databaseName: "MyCosmosDB",
            collectionName: "MyOrders",
            ConnectionStringSetting = "MyCosmosDBConnection",
            LeaseCollectionName = "leases", CreateLeaseCollectionIfNotExists =true)]IReadOnlyList<Document> input, ILogger log)
        {
            if (input != null && input.Count > 0)
            {
                log.LogInformation("Documents modified " + input.Count);
                log.LogInformation("First document Id " + input[0].Id);
            }
        }
    }Get specified field value…
foreach (var item in input)
{
     log.LogInformation("Order Id " + item.GetPropertyValue<int>("OrderId"));
}Note:
- Make sure you installed the Microsoft.Azure.WebJobs.Extensions.CosmosDB package.
- Created a CosmosDB connection string (Get string value from Azure Portal).
- Created a container called “leases” or set CreateLeaseCollectionIfNotExists =true.
Comments