Cómo crear varios desencadenadores de Azure Functions para Azure Cosmos DB

  • Artículo

SE APLICA A: NoSQL

En este artículo se describe cómo puede configurar varios desencadenadores de Azure Functions para Azure Cosmos DB para trabajar en paralelo y reaccionar de forma independiente a los cambios.

Funciones basadas en eventos sin servidor que funcionan con el desencadenador de Azure Functions para Azure Cosmos DB y comparten un contenedor de concesiones

Requisitos de la arquitectura basada en eventos

Al compilar arquitecturas sin servidor con Azure Functions, se recomienda crear pequeños conjuntos de funciones que trabajen conjuntamente, en lugar de grandes funciones de larga duración.

Al compilar flujos sin servidor basados en eventos mediante el desencadenador de Azure Functions para Azure Cosmos DB, se producirá un escenario en el que querrá realizar varias acciones siempre que haya un nuevo evento en un determinado contenedor de Azure Cosmos DB. Si las acciones que quiere desencadenar son independientes entre sí, la solución ideal consiste en crear un desencadenador de Azure Functions para Azure Cosmos DB por cada acción que quiera realizar y que todas escuchen los cambios en el mismo contenedor de Azure Cosmos DB.

Optimización de contenedores para varios desencadenadores

Dados los requisitos del desencadenador de Azure Functions para Azure Cosmos DB, necesitamos un segundo contenedor para almacenar el estado, también denominado contenedor de concesiones. ¿Esto significa que necesita un contenedor de concesiones independiente para cada función de Azure?

Dispone de dos opciones:

  • Crear un contenedor de concesiones para cada función: Este enfoque puede suponer costos adicionales, a menos que use una base de datos de rendimiento compartido. Recuerde que el rendimiento mínimo a nivel de contenedor es de 400 unidades de solicitud y, en el caso del contenedor de concesiones, solo se usa para aplicar el punto de control al progreso y mantener el estado.
  • Tener un contenedor de concesiones y compartirlo para todas las funciones: Esta segunda opción hace un mejor uso de las unidades de solicitud aprovisionadas en el contenedor, ya que permite que varias instancias de Azure Functions se compartan y usen el mismo rendimiento aprovisionado.

El objetivo de este artículo es guiarle con la segunda opción.

Configuración de un contenedor de concesiones compartido

Para configurar el contenedor de concesiones compartido, la única configuración adicional que tiene que realizar en los desencadenadores consiste en agregar el atributoLeaseContainerPrefix si usa C# o el atributoleaseContainerPrefix si usa JavaScript. El valor del atributo debe ser un descriptor lógico de ese desencadenador en particular.

Por ejemplo, si tiene tres desencadenadores (uno que envía correos electrónicos, otro que realiza una agregación para crear una vista materializada y otro que envía los cambios a otro almacenamiento para su análisis posterior), puede asignar el elemento LeaseContainerPrefix de "emails" al primero de ellos, "materialized"al segundo y "analytics" al tercero.

Lo importante es que los tres desencadenadores puedan usar la misma configuración de contenedor de concesiones (cuenta, base de datos y nombre del contenedor).

Un ejemplo de código muy sencillo con el atributo LeaseContainerPrefix en C# tendría el aspecto siguiente:

using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Host;
using System.Collections.Generic;
using Microsoft.Extensions.Logging;

[FunctionName("SendEmails")]
public static void SendEmails([CosmosDBTrigger(
    databaseName: "ToDoItems",
    containerName: "Items",
    Connection = "CosmosDBConnection",
    LeaseContainerName = "leases",
    LeaseContainerPrefix = "emails")]IReadOnlyList<MyItem> items,
    ILogger log)
{
    ...
}

[FunctionName("MaterializedViews")]
public static void MaterializedViews([CosmosDBTrigger(
    databaseName: "ToDoItems",
    containerName: "Items",
    Connection = "CosmosDBConnection",
    LeaseContainerName = "leases",
    LeaseContainerPrefix = "materialized")]IReadOnlyList<MyItem> items,
    ILogger log)
{
    ...
}

Para JavaScript, puede aplicar la configuración en el archivo function.json con el atributo leaseContainerPrefix:

{
    "type": "cosmosDBTrigger",
    "name": "documents",
    "direction": "in",
    "leaseContainerName": "leases",
    "connection": "CosmosDBConnection",
    "databaseName": "ToDoItems",
    "containerName": "Items",
    "leaseContainerPrefix": "emails"
},
{
    "type": "cosmosDBTrigger",
    "name": "documents",
    "direction": "in",
    "leaseContainerName": "leases",
    "connection": "CosmosDBConnection",
    "databaseName": "ToDoItems",
    "containerName": "Items",
    "leaseContainerPrefix": "materialized"
}

Nota:

Supervise siempre las unidades de solicitud aprovisionadas en el contenedor de concesiones compartido. Cada desencadenador que lo comparta aumentará el consumo medio de rendimiento, por lo que es posible que tenga que aumentar el rendimiento aprovisionado a medida que aumente el número de instancias de Azure Functions que lo estén usando.

Pasos siguientes