Compartir vía

Desencadenador de tema de Dapr para Azure Functions

Azure Functions se puede desencadenar en una suscripción de tema de Dapr mediante los siguientes eventos de Dapr.

Para obtener información sobre la configuración y los detalles de configuración de la extensión Dapr, consulte la introducción a la extensión Dapr.

Example

Se puede crear una función C# usando uno de los siguientes modos de C#:

Execution model Description
Modelo de trabajo aislado El código de función se ejecuta en un proceso de trabajo de .NET independiente. Se usa con versiones compatibles de .NET y .NET Framework. Para más información, consulte Guía para ejecutar C# azure Functions en el modelo de trabajo aislado.
In-process model El código de función se ejecuta en el mismo proceso que el proceso de host de Functions. Solo admite versiones de .NET de compatibilidad a largo plazo (LTS). Para más información, consulte Desarrollo de funciones de la biblioteca de clases de C# con Azure Functions. 
[FunctionName("TransferEventBetweenTopics")]
public static void Run(
    [DaprTopicTrigger("%PubSubName%", Topic = "A")] CloudEvent subEvent,
    [DaprPublish(PubSubName = "%PubSubName%", Topic = "B")] out DaprPubSubEvent pubEvent,
    ILogger log)
{
    log.LogInformation("C# function processed a TransferEventBetweenTopics request from the Dapr Runtime.");


    pubEvent = new DaprPubSubEvent("Transfer from Topic A: " + subEvent.Data);
}

Este es el código Java para suscribirse a un tema mediante el desencadenador De tema de Dapr:

@FunctionName("PrintTopicMessage")
public String run(
        @DaprTopicTrigger(
            pubSubName = "%PubSubName%",
            topic = "B")
        String payload,
        final ExecutionContext context) throws JsonProcessingException {
    Logger logger = context.getLogger();
    logger.info("Java function processed a PrintTopicMessage request from the Dapr Runtime.");

Use el app objeto para registrar :daprTopicTrigger

const { app, trigger } = require('@azure/functions');

app.generic('TransferEventBetweenTopics', {
    trigger: trigger.generic({
        type: 'daprTopicTrigger',
        name: "subEvent",
        pubsubname: "%PubSubName%",
        topic: "A"
    }),
    return: daprPublishOutput,
    handler: async (request, context) => {
        context.log("Node function processed a TransferEventBetweenTopics request from the Dapr Runtime.");
        context.log(context.triggerMetadata.subEvent.data);

        return { payload: context.triggerMetadata.subEvent.data };
    }
});

The following examples show Dapr triggers in a function.json file and PowerShell code that uses those bindings.

Here's the function.json file for daprTopicTrigger:

{
  "bindings": [
    {
      "type": "daprTopicTrigger",
      "pubsubname": "%PubSubName%",
      "topic": "B",
      "name": "subEvent",
      "direction": "in"
    }
  ]
}

For more information about function.json file properties, see the Configuration section.

In code:

using namespace System
using namespace Microsoft.Azure.WebJobs
using namespace Microsoft.Extensions.Logging
using namespace Microsoft.Azure.WebJobs.Extensions.Dapr
using namespace Newtonsoft.Json.Linq

param (
    $subEvent
)

Write-Host "PowerShell function processed a PrintTopicMessage request from the Dapr Runtime."

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $subEvent["data"] | ConvertTo-Json -Compress

Write-Host "Topic B received a message: $jsonString"

En el ejemplo siguiente se muestra un desencadenador de Tema de Dapr, que usa el modelo de programación de Python v2. Para usar en el código de daprTopicTrigger la aplicación de funciones de Python:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="PrintTopicMessage")
@app.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="B", route="B")
def main(subEvent) -> None:
    logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    logging.info("Topic B received a message: " + subEvent_json["data"])

Attributes

In the in-process model, use the DaprTopicTrigger to trigger a Dapr pub/sub binding, which supports the following properties.

Parameter Description
PubSubName Nombre del archivo pub/sub de Dapr.
Topic Nombre del tema de Dapr.

Annotations

La DaprTopicTrigger anotación permite crear una función que se ejecuta cuando se recibe un tema.

Element Description
pubSubName Nombre del archivo pub/sub de Dapr.
topic Nombre del tema de Dapr.

Configuration

En la siguiente tabla se explican las propiedades de configuración de enlace que se establecen en el código.

Property Description
pubsubname Nombre del tipo de componente pub/sub de Dapr.
topic Nombre del tema.

The following table explains the binding configuration properties that you set in the function.json file.

function.json property Description
pubsubname Nombre del tipo de componente pub/sub de Dapr.
topic Nombre del tema.

En la tabla siguiente, se explican las propiedades de configuración de enlace para @dapp.dapr_topic_trigger que estableció en el código de Python.

Property Description Se puede enviar mediante el elemento Attribute. Se puede enviar mediante el elemento RequestBody.
pub_sub_name Nombre del tipo de componente de suscripción de Dapr. ✔️ ❌
topic El tema de la suscripción. ✔️ ❌

See the Example section for complete examples.

Usage

Para usar un desencadenador de tema de Dapr, empiece por configurar un componente pub/sub de Dapr. Puede obtener más información sobre qué componente usar y cómo configurarlo en la documentación oficial de Dapr.

Para usar daprTopicTrigger en Python v2, configure el proyecto con las dependencias correctas.

  1. Creación y activación de un entorno virtual.

  2. En el archivo requirements.text, agregue la línea siguiente:

    azure-functions==1.18.0b3

  3. En el terminal, instale la biblioteca de Python.

    pip install -r .\requirements.txt

  4. Modifique el archivo local.setting.json con la siguiente configuración:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Next steps

Obtenga más información sobre la publicación y suscripción de Dapr.

  • Last updated on