Desencadenador de invocación del servicio Dapr para Azure Functions

Importante

La extensión Dapr para Azure Functions se encuentra actualmente en versión preliminar y solo se admite en entornos de Azure Container Apps.

Azure Functions se puede desencadenar en una invocación al servicio 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.

Ejemplo

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

Modelo de ejecución	Descripción
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 obtener más información, consulte Desarrollo de funciones de procesos de trabajo aislados en .NET.
Modelo de proceso	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 obtener más información, consulte Desarrollo de funciones de la biblioteca de clases de .NET.

En proceso

[FunctionName("CreateNewOrder")]
public static void Run(
    [DaprServiceInvocationTrigger] JObject payload,
    [DaprState("%StateStoreName%", Key = "order")] out JToken order,
    ILogger log)
{
    log.LogInformation("C# function processed a CreateNewOrder request from the Dapr Runtime.");

    // payload must be of the format { "data": { "value": "some value" } }
    order = payload["data"];
}

Proceso aislado

[Function("CreateNewOrder")]
[DaprStateOutput("%StateStoreName%", Key = "order")]
public static JsonElement Run(
    [DaprServiceInvocationTrigger] JsonElement payload, 
    FunctionContext functionContext)
{
    var log = functionContext.GetLogger("CreateNewOrder");
    log.LogInformation("C# function processed a CreateNewOrder request from the Dapr Runtime.");

    // payload must be of the format { "data": { "value": "some value" } }
    payload.TryGetProperty("data", out JsonElement data);

    return data;
}

Este es el código Java para el desencadenador de invocación del servicio Dapr:

@FunctionName("CreateNewOrder")
public String run(
        @DaprServiceInvocationTrigger(
            methodName = "CreateNewOrder") 
)

Node.js v4

Use el app objeto para registrar :daprInvokeOutput

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

app.generic('InvokeOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "invoke/{appId}/{methodName}",
        name: "req"
    }),
    return: daprInvokeOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");

        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { body: payload };
    }
});

Node.js v3

En los ejemplos siguientes, se muestran desencadenadores de Dapr en un archivo function.json y código JavaScript que usa esos enlaces.

Este es el archivo function.json para daprServiceInvocationTrigger:

{
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload"
    }
  ]
}

Para obtener más información sobre las propiedades del archivo function.json, consulte la sección de Configuración.

Este es el código de JavaScript:

module.exports = async function (context) {
    context.log("Node function processed a RetrieveOrder request from the Dapr Runtime.");

    // print the fetched state value
    context.log(context.bindings.data);
};

En los ejemplos siguientes, se muestran desencadenadores de Dapr en un archivo function.json y código de PowerShell que usa esos enlaces.

Este es el archivo function.json para daprServiceInvocationTrigger:

{
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload",
      "direction": "in"
    }
  ]
}

Para obtener más información sobre las propiedades del archivo function.json, consulte la sección de Configuración.

Mediante código:

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 (
    $payload
)

# C# function processed a CreateNewOrder request from the Dapr Runtime.
Write-Host "PowerShell function processed a CreateNewOrder request from the Dapr Runtime."

# Payload must be of the format { "data": { "value": "some value" } }

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $payload| ConvertTo-Json

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name order -Value $payload["data"]

Python v2

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

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="RetrieveOrder")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveOrder")
@app.dapr_state_input(arg_name="data", state_store="statestore", key="order")
def main(payload, data: str) :
    # Function should be invoked with this command: dapr invoke --app-id functionapp --method RetrieveOrder  --data '{}'
    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
    logging.info(data)

Python v1

En el ejemplo siguiente, se muestra un desencadenador de invocación al servicio Dapr, que usa el modelo de programación de Python v1.

Este es el archivo function.json para daprServiceInvocationTrigger:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload",
      "direction": "in"
    }
  ]
}

Para obtener más información sobre las propiedades del archivo function.json, consulte la sección de Configuración.

Este es el código de Python:

import logging
import json
import azure.functions as func

def main(payload, data: str) -> None:
    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
    logging.info(data)

Atributos

En proceso

En el modelo In-Process, use DaprServiceInvocationTrigger para desencadenar un enlace de invocación al servicio Dapr, que admite las siguientes propiedades.

Parámetro	Descripción
MethodName	Opcional. Nombre del método que debe usar el autor de la llamada de Dapr. Si no se especifica, se utiliza el nombre de la función como nombre del método.

Proceso aislado

En el modelo de trabajo aislado, use DaprServiceInvocationTrigger para definir un desencadenador de invocación al servicio Dapr, que admite estos parámetros:

Parámetro	Descripción
MethodName	Opcional. Nombre del método que debe usar el autor de la llamada de Dapr. Si no se especifica, se utiliza el nombre de la función como nombre del método.

anotaciones

La anotación DaprServiceInvocationTrigger le permite crear una función que será invocada por el entorno de ejecución de Dapr.

Elemento	Descripción
methodName	El nombre del método.

Configuración

Node.js v4

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

Propiedad	Descripción
type	Se debe establecer en daprServiceInvocationTrigger.
name	Nombre de la variable que representa los datos de Dapr en el código de la función.

Node.js v3

En la siguiente tabla se explican las propiedades de configuración de enlace que se establecen en el archivo function.json.

Propiedad de function.json	Descripción
type	Se debe establecer en daprServiceInvocationTrigger.
name	Nombre de la variable que representa los datos de Dapr en el código de la función.

En la siguiente tabla se explican las propiedades de configuración de enlace que se establecen en el archivo function.json.

Propiedad de function.json	Descripción
type	Se debe establecer en daprServiceInvocationTrigger.
name	Nombre de la variable que representa los datos de Dapr en el código de la función.

Python v2

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

Propiedad	Descripción
method_name	Nombre de la variable que representa los datos de Dapr.

Python v1

En la siguiente tabla se explican las propiedades de configuración de enlace que se establecen en el archivo function.json.

Propiedad de function.json	Descripción
type	Se debe establecer en daprServiceInvocationTrigger.
name	Nombre de la variable que representa los datos de Dapr en el código de la función.

Consulte la sección de ejemplos para ver ejemplos completos.

Uso

Para usar un desencadenador de invocación al servicio Dapr, obtenga más información sobre qué componentes usar con el desencadenador de invocación al servicio y cómo configurarlos en la documentación oficial de Dapr.

• Especificaciones de los componentes de Dapr
• Invocación al servicio Dapr

Python v2

Para usar daprServiceInvocationTrigger 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
   

Python v1

El modelo de Python v1 no requiere cambios adicionales, además de configurar los componentes de invocación al servicio.

Pasos siguientes

Obtenga más información sobre la invocación del servicio Dapr.