Getting Started with MongoDB Atlas and Azure Functions using .NET and C#

1
func init MongoExample

1
func new --name GetMovies --template "HTTP trigger"

1
dotnet add package MongoDB.Driver

1
using System;
2
using System.IO;
3
using System.Threading.Tasks;
4
using Microsoft.AspNetCore.Mvc;
5
using Microsoft.Azure.WebJobs;
6
using Microsoft.Azure.WebJobs.Extensions.Http;
7
using Microsoft.AspNetCore.Http;
8
using Microsoft.Extensions.Logging;
9
using Newtonsoft.Json;
10
using MongoDB.Driver;
11
using System.Collections.Generic;
12
using MongoDB.Bson.Serialization.Attributes;
13
using MongoDB.Bson;
14
using System.Text.Json.Serialization;
15
16
namespace MongoExample
17
{
18
19
    [BsonIgnoreExtraElements]
20
    public class Movie
21
    {
22
23
        [BsonId]
24
        [BsonRepresentation(BsonType.ObjectId)]
25
        public string? Id { get; set; }
26
27
        [BsonElement("title")]
28
        [JsonPropertyName("title")]
29
        public string Title { get; set; } = null!;
30
31
        [BsonElement("plot")]
32
        [JsonPropertyName("plot")]
33
        public string Plot { get; set; } = null!;
34
35
    }
36
37
    public static class GetMovies
38
    {
39
40
        public static Lazy<MongoClient> lazyClient = new Lazy<MongoClient>(InitializeMongoClient);
41
        public static MongoClient client = lazyClient.Value;
42
43
        public static MongoClient InitializeMongoClient()
44
        {
45
            return new MongoClient(Environment.GetEnvironmentVariable("MONGODB_ATLAS_URI"));
46
        }
47
48
        [FunctionName("GetMovies")]
49
        public static async Task<IActionResult> Run(
50
            [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
51
            ILogger log)
52
        {
53
54
            string limit = req.Query["limit"];
55
            IMongoCollection<Movie> moviesCollection = client.GetDatabase("sample_mflix").GetCollection<Movie>("movies");
56
57
            BsonDocument filter = new BsonDocument{
58
                {
59
                    "year", new BsonDocument{
60
                        { "$gt", 2005 },
61
                        { "$lt", 2010 }
62
                    }
63
                }
64
            };
65
66
            var moviesToFind = moviesCollection.Find(filter);
67
68
            if(limit != null && Int32.Parse(limit) > 0) {
69
                moviesToFind.Limit(Int32.Parse(limit));
70
            }
71
72
            List<Movie> movies = moviesToFind.ToList();
73
74
            return new OkObjectResult(movies);
75
76
        }
77
78
    }
79
80
}

1
[BsonIgnoreExtraElements]
2
public class Movie
3
{
4
5
    [BsonId]
6
    [BsonRepresentation(BsonType.ObjectId)]
7
    public string? Id { get; set; }
8
9
    [BsonElement("title")]
10
    [JsonPropertyName("title")]
11
    public string Title { get; set; } = null!;
12
13
    [BsonElement("plot")]
14
    [JsonPropertyName("plot")]
15
    public string Plot { get; set; } = null!;
16
17
}

1
public static Lazy<MongoClient> lazyClient = new Lazy<MongoClient>(InitializeMongoClient);
2
public static MongoClient client = lazyClient.Value;
3
4
public static MongoClient InitializeMongoClient()
5
{
6
7
    return new MongoClient(Environment.GetEnvironmentVariable("MONGODB_ATLAS_URI"));
8
9
}

1
string limit = req.Query["limit"];
2
3
IMongoCollection<Movie> moviesCollection = client.GetDatabase("sample_mflix").GetCollection<Movie>("movies");
4
5
BsonDocument filter = new BsonDocument{
6
    {
7
        "year", new BsonDocument{
8
            { "$gt", 2005 },
9
            { "$lt", 2010 }
10
        }
11
    }
12
};
13
14
var moviesToFind = moviesCollection.Find(filter);
15
16
if(limit != null && Int32.Parse(limit) > 0) {
17
    moviesToFind.Limit(Int32.Parse(limit));
18
}
19
20
List<Movie> movies = moviesToFind.ToList();
21
22
return new OkObjectResult(movies);

1
{
2
    "IsEncrypted": false,
3
    "Values": {
4
        // OTHER VALUES ...
5
        "MONGODB_ATLAS_URI": "mongodb+srv://<USER>:<PASS>@<CLUSTER>.170lwj0.mongodb.net/?retryWrites=true&w=majority"
6
    },
7
    "ConnectionStrings": {}
8
}

1
func start

1
az group create --name <GROUP_NAME> --location <AZURE_REGION>

1
az storage account create --name <STORAGE_NAME> --location <AZURE_REGION> --resource-group <GROUP_NAME> --sku Standard_LRS

1
az functionapp create --resource-group <GROUP_NAME> --consumption-plan-location <AZURE_REGION> --runtime dotnet --functions-version 4 --name <APP_NAME> --storage-account <STORAGE_NAME>

1
func azure functionapp fetch-app-settings <FUNCTION_APP_NAME>

1
func azure storage fetch-connection-string <STORAGE_ACCOUNT_NAME>

1
az functionapp config appsettings set --name <FUNCTION_APP_NAME> --resource-group <RESOURCE_GROUP_NAME> --settings MONGODB_ATLAS_URI=<MONGODB_ATLAS_URI>

1
func azure functionapp publish <FUNCTION_APP_NAME>

1
curl https://<FUNCTION_APP_NAME>.azurewebsites.net/api/GetMovies?code=<HOST_KEY_HERE>