Skip to content
Branch: master
Find file History
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Type Name Latest commit message Commit time
Failed to load latest commit information.

Serverless and Schema-less with Azure Functions and Azure Cosmos DB

This repo contains the presentation slides and code samples for serverless and schema-less with Azure Functions and Azure Cosmos DB

Local coding instructions

For purposes of convenience, this demo and code samples are geared to running on a local development machine with minimal external dependencies.


  • Visual Studio 2017 with Azure Development Workload
  • Install Azure storage emulator download
  • Install CosmosDB emulator download
  • Install latest version of Azure Functions tools for v2 check out v2.0 section
Nuget Packages:
  • Microsoft.Azure.WebJobs.Extensions.CosmosDB (latest version)
Before you start:
  • Make sure Azure Storage emulator is running
  • Make sure CosmosDB emulator is running
Http Trigger
  • Create a new Azure Functions project in visual studio. Make sure you pick v2 as the engine not v1.
  • Add an empty project with no functions
  • Add a new function, call it HttpTriggerFunction, pick Http Trigger and anonymous access (for this demo).
  • In the function code file, changed function name attribute to CheckoutEndPoint or something else that makes sense
  • Run your code and hit up the endpoint at the url generated
Add Http Trigger to write to Cosmos DB
  • Add Nuget package: Microsoft.Azure.WebJobs.Extensions.CosmosDB (latest version)

  • Paste the connection string for the CosmosDB emulator into your local.settings.json file

    "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "CosmosDBConnection": "AccountEndpoint=https://localhost:8081/;AccountKey=C2y6yDjf5/R+ob0N8A7Cgv30VRDJIWEHLM+4QDU5DE2nQ9nDuVTqobD4b8mGGyPMbIZnqyMsEcaGQy67XIw/Jw=="
  • Replace the function code body with this chunk
        public static async Task Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)]HttpRequest req,
            [CosmosDB(databaseName: "salesdb",
            collectionName: "salescollection",
            CreateIfNotExists = true,
            CollectionThroughput = 1000,
            PartitionKey = "/sku",
            ConnectionStringSetting = "CosmosDBConnection")]
        IAsyncCollector<dynamic> outputDocuments,
            ILogger log)
            string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
            dynamic data = JsonConvert.DeserializeObject(requestBody);
            await outputDocuments.AddAsync(data);
  • In above code sample: the "CosmosDB" attribute with "out" indicates outgoing data. By deserializing the request and assigning it to the "out" variable we're sending it to the Cosmos DB datastore indicate in the "databaseName", "collectionName" and "ConnectionString" attributes. The CreateIfNotExists=true is a defensive coding mechanism that creates a database and/or collection if they don't exist.

  • When you run this sample, the database and collection will autocreate if they don't exist.

  • Copy-paste the json data in the file in your favorite REST client body and issue a POST to the CheckoutEndPoint. You will notice that the data gets stored in the "salescollection" data store - verify with local emulator Data Explorer.

Add Cosmos DB Triggered Function to determine shipping
  • Add a function called "CalculateTaxCosmosFunction" and select CosmosDB as the trigger.

  • Add the correct database name, collection name and connection string name

  • Replace the code inside the function body as follows:

        public static void Run([CosmosDBTrigger(
            databaseName: "salesdb",
            collectionName: "salescollection",
            ConnectionStringSetting = "CosmosDBConnection",
            LeaseCollectionName = "leases",
            CreateLeaseCollectionIfNotExists = true,
            LeasesCollectionThroughput = 1000)]IReadOnlyList<Document> documents,
            ILogger log)
            if (documents != null && documents.Count > 0)
                foreach (var document in documents)
                    if (((dynamic)document).requires_shipping)
                        log.LogWarning("Invoked shipping function");
                        log.LogWarning("No shipping!!!!");
  • In the above code sample: the CosmosDB trigger is invoked when data enters the data collection. Since multiple records could be inserted at once we read them in a list and iterate throught them,
You can’t perform that action at this time.