Azure Functions: Trigger Azure Function với Cosmos DB - Day 3

Azure functions hỗ trợ rất nhiều triggers, trong đó có Cosmos DB Trigger. Cosmos DB Trigger sử dụng Azure Cosmos DB change feed để listen những thay đổi từ container (inserting, updating, chưa hỗ trợ delete).

Tham khảo bài viết Tìm hiểu về CosmosDB để xem cách tạo Database, container trong Cosmos: https://nhatkyhoctap.blogspot.com/2023/05/tim-hieu-ve-azure-comos-db.html

Tham khảo bài viết cách tạo Azure Functioin trong Visual Studio Code: https://nhatkyhoctap.blogspot.com/2023/05/azure-functions-tao-project-azure.html

Các bước tạo Azure Function tương tự như trên, tuy nhiên ở bước chọn trigger, bạn chọn Azure Cosmos DB Trigger. Nếu có hộp thoại hỏi chọn database name, bạn bấm Skip for now.

Azure Function sẽ có đoạn code như sau:

using System;
using System.Collections.Generic;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

namespace AzureLearning.Function
{
    public class CosmosSampleTrigger
    {
        private readonly ILogger _logger;

        public CosmosSampleTrigger(ILoggerFactory loggerFactory)
        {
            _logger = loggerFactory.CreateLogger<CosmosSampleTrigger>();
        }

        [Function("CosmosSampleTrigger")]
        public void Run([CosmosDBTrigger(
            databaseName: "databaseName",
            collectionName: "collectionName",
            ConnectionStringSetting = "",
            LeaseCollectionName = "leases")] IReadOnlyList<MyDocument> input)
        {
            if (input != null && input.Count > 0)
            {
                _logger.LogInformation("Documents modified: " + input.Count);
                _logger.LogInformation("First document Id: " + input[0].Id);
            }
        }
    }

    public class MyDocument
    {
        public string Id { get; set; }

        public string Text { get; set; }

        public int Number { get; set; }

        public bool Boolean { get; set; }
    }
}

local.settings.json

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
    "CosmosDbConnectionString": "AccountEndpoint=..."
  }
}

Trong đoạn code trên, ConnectionStringSetting là từ khóa dùng để lấy config từ local.settings.json. Bạn sẽ để PrimaryKeyConnectionString vào AzureWebJobsStorage Trong bài trước, mình có model là Employee, mình sẽ update lại MyDocument sao cho giống với Model có sẵn

public class MyDocument
{
	public string? id { get; set;}
	public string? Name { get; set;}
	public string? Country { get; set;}
	public string? City { get; set;}
	public string? Department { get; set;}
	public string? Designation { get; set;}
	public DateTime? JoiningDate { get; set;}
}

Hàm Run được update như sau:

[Function("CosmosSampleTrigger")]
public void Run([CosmosDBTrigger(
	databaseName: "EmployeeManagementDB",
	collectionName: "Employees",
	ConnectionStringSetting = "CosmosDbConnectionString",
	LeaseCollectionName = "lease", CreateLeaseCollectionIfNotExists = true)] IReadOnlyList<MyDocument> input)
{
	if (input != null && input.Count > 0)
	{
		_logger.LogInformation("Documents modified: " + input.Count);
		foreach(var item in input)
		{
			_logger.LogInformation($"Document Id: {item.id}, department {item.Department}, name: {item.Name}");
		}
		
	}
}

Bấm F5 để debug và test kết quả xem nào. 

Trong bài viết tới, mình sẽ đưa ra hướng giải quyết Trigger này sao cho hiệu quả.