Skip to main content

Inserting Data with Azure Functions in CosmosDB


I was wondering how to use Azure Function to insert data in CosmosDB when this function receives an HTTP request
Surprise!!  It´s easy 

Step 1. Create your DataBase and Collection inside CosmosDB in Azure. 


Step 2. Create Function App




Step 3.  Create a new function. In this case use template "HttpTrigger - C#"



Step 4. Select "Integrate" option 


Be sure to change option in "Allowed HTTP methods" and select only "POST" HTTP method. 


Step 5. Create output binding



Step 6.  Configuring output binding


a:  Name of the entity variable to insert in CosmosDB.
b:  Name of the collection where the entity will be inserted (see image in Step 1).
c:  Partition Key  in case you need to define it. 
d:  DataBase name in Cosmos DB (see image in Step 1).
e:  ConnectionString.


Step 7.   "Short" programming....

a: Entity variable referenced in Step 6. a
b: Entity type (custom class). 

outputDocument= req.Content.ReadAsAsync<DTODocument>().Result;  

The function of this line is to read the body content in the request and deserialized it to the variable of DTODocument type.



Step 8. Testing 


a: Get Azure Function endpoint to invoque it from any programming language.
b: Request body example in JSON format (DTODocument)
c: Also you can test the function inside Azure Function App context.


See you late !!!

Comments

Post a Comment

Popular posts from this blog

Update data in COSMOS DB with Azure Functions.

I was looking for a way to update COSMOS DB document after receive a  request inside Azure Function without any COSMOS DB biding. I didn't find a way !!  I took another way. I don't know if it is the right or wrong way. But this way works for me. Scenario is very simple. We have sales orders arriving into the data base. We have another Azure function to insert those new orders. But suppose we need to cancel some order. How to do that using Azure Function ? Let´s start !!! Step 1. Sample Collection. This collection is very simple,  we are focused on results. Step 2. Create a Function and Select HttpTrigger template.  Step 3. Code  More code.  Step 4. Test Step 5. Results  See you soon 
2 comments
Read more

Add more security to an Azure CosmosDB Account.

W e can access programmatically to Azure Cosmos DB resources to create, query, and delete databases, document collections, and documents via REST API. To perform operations on Azure Cosmos DB resources, you can send HTTPS requests with a selected method: GET, POST, PUT, or DELETE to an CosmosDB endpoint.  Frequently we build architecture with centralized access to a persistence layer, then we won't let other applications access directly to this layer. Suppose we have the following hypothetical scenario (see Figure 1): Figure 1. Hypothetical Scenario Only WEB API Service with IP1 is allowed to establish connections with CosmosDB EndPoint. The others elements showed as Application are not allowed. By default we have in our CosmosDB resource the following configuration (see Figure 2) in Firewall and Virtual Networks option. Figure 2. Default Configuration To show you how this feature works, we are going to create a WEP API with a single function (r...
Post a Comment
Read more

Querying CosmosDB. Part 2

Hi!!! We will continue to play a little with the same  JSON Example  in  Part 1 We will try to do queries a little more complicated. Total amount of time (in minutes) of laboratory in particular event. Query SELECT VALUE SUM(act.duration) FROM c JOIN act IN c.activities WHERE act.type=”lab” AND c.event_name= “CosmosDB Conf” Results List activities from specific type and from specific event Query SELECT VALUE act FROM c JOIN act IN c.activities WHERE act.type=”conference” AND c.event_name= “CosmosDB Conf” Results Get activities where duration is more than 30 minutes Query SELECT VALUE act FROM c JOIN act IN c.activities WHERE act.duration>30 Results Same as previous but bring me more information for each document Query SELECT VALUE { “id”:c.id, “event”:c.event_name, “speaker”:c.speaker, “country”:c.event_country, “activity”:act} FROM c JOIN act IN c.activities WHERE act.duration>30 and act.type=”lab” Results In case...
Post a Comment
Read more