Enlace de salida Dapr Invoke para Azure Functions

  • Artículo

Importante

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

El enlace de salida de invocación de Dapr permite invocar otra aplicación Dapr durante la ejecución de una función.

Para obtener información sobre la configuración y los detalles respectivos de la extensión Dapr, consulte la Información general de 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 el ejemplo siguiente se muestra cómo usar un enlace de salida de invocación de Dapr para realizar una operación de invocación del servicio Dapr que se hospeda en otra aplicación con Dapr. En este ejemplo, la función actúa como un proxy.

[FunctionName("InvokeOutputBinding")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", Route = "invoke/{appId}/{methodName}")] HttpRequest req,
    [DaprInvoke(AppId = "{appId}", MethodName = "{methodName}", HttpVerb = "post")] IAsyncCollector<InvokeMethodParameters> output,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

    string requestBody = await new StreamReader(req.Body).ReadToEndAsync();

    var outputContent = new InvokeMethodParameters
    {
        Body = requestBody
    };

    await output.AddAsync(outputContent);

    return new OkResult();
}

En el ejemplo siguiente se crea una función "InvokeOutputBinding" mediante el enlace DaprInvokeOutput con un elemento HttpTrigger:

@FunctionName("InvokeOutputBinding")
public String run(
        @HttpTrigger(
            name = "req",
            methods = {HttpMethod.GET, HttpMethod.POST},
            authLevel = AuthorizationLevel.ANONYMOUS,
            route = "invoke/{appId}/{methodName}")
            HttpRequestMessage<Optional<String>> request,
        @DaprInvokeOutput(
            appId = "{appId}", 
            methodName = "{methodName}", 
            httpVerb = "post")
        OutputBinding<String> payload,
        final ExecutionContext context)

En el ejemplo siguiente, el enlace de salida de invocación de Dapr se empareja con un desencadenador HTTP, que está registrado por el app objeto :

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 };
    }
});

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 daprInvoke:

{
  "bindings":
    {
      "type": "daprInvoke",
      "direction": "out",
      "appId": "{appId}",
      "methodName": "{methodName}",
      "httpVerb": "post",
      "name": "payload"
    }
}

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.Net

# Input bindings are passed in via param block.
param($req, $TriggerMetadata)

# Write to the Azure Functions log stream.
Write-Host "Powershell InvokeOutputBinding processed a request."

$req_body = $req.Body

$invoke_output_binding_req_body = @{
    "body" = $req_body
}

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name payload -Value $invoke_output_binding_req_body

Push-OutputBinding -Name res -Value ([HttpResponseContext]@{
    StatusCode = [HttpStatusCode]::OK
    Body = $req_body
})

En el ejemplo siguiente se muestra un enlace de salida de Dapr Invoke, que usa el modelo de programación de Python v2. Para usar daprInvoke en el código de aplicación de funciones de Python:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="InvokeOutputBinding")
@app.route(route="invoke/{appId}/{methodName}", auth_level=dapp.auth_level.ANONYMOUS)
@app.dapr_invoke_output(arg_name = "payload", app_id = "{appId}", method_name = "{methodName}", http_verb = "post")
def main(req: func.HttpRequest, payload: func.Out[str] ) -> str:
    # request body must be passed this way "{\"body\":{\"value\":{\"key\":\"some value\"}}}" to use the InvokeOutputBinding, all the data must be enclosed in body property.
    logging.info('Python function processed a InvokeOutputBinding request from the Dapr Runtime.')

    body = req.get_body()
    logging.info(body)
    if body is not None:
        payload.set(body)
    else:
        logging.info('req body is none')
    return 'ok'

Atributos

En el modelo en proceso, use el atributo DaprInvoke para definir un enlace de salida de invocación de Dapr, que admite estos parámetros:

Parámetro Descripción Se puede enviar mediante el elemento Attribute. Se puede enviar a través de RequestBody
AppId Identificador de la aplicación Dapr que se va a invocar. ✔️ ✔️
MethodName Nombre del método de la aplicación que se va a invocar. ✔️ ✔️
HttpVerb Opcional. Verbo HTTP para usar de la aplicación que se va a invocar. El valor predeterminado es POST. ✔️ ✔️
Cuerpo Necesario. Cuerpo de la solicitud. ❌ ✔️

anotaciones

La anotación DaprInvokeOutput permite que la función invoque y escuche un enlace de salida.

Elemento Descripción Se puede enviar mediante el elemento Attribute. Se puede enviar a través de RequestBody
appId Identificador de la aplicación implicada en el enlace de invocación. ✔️ ✔️
methodName Nombre de la variable de método. ✔️ ✔️
httpVerb Post o Get. ✔️ ✔️
cuerpo Necesario. Cuerpo de la solicitud. ❌ ✔️

Configuración

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

Propiedad Descripción Se puede enviar mediante el elemento Attribute. Se puede enviar a través de RequestBody
appId Identificador de la aplicación implicada en el enlace de invocación. ✔️ ✔️
methods Post o Get. ✔️ ✔️
cuerpo Necesario. Cuerpo de la solicitud. ❌ ✔️

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 Se puede enviar mediante el elemento Attribute. Se puede enviar a través de RequestBody
appId Identificador de la aplicación implicada en el enlace de invocación. ✔️ ✔️
methodName Nombre de la variable de método. ✔️ ✔️
httpVerb Post o Get. ✔️ ✔️
cuerpo Necesario. Cuerpo de la solicitud. ❌ ✔️

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

Propiedad Descripción Se puede enviar mediante el elemento Attribute. Se puede enviar a través de RequestBody
app_id Identificador de la aplicación implicada en el enlace de invocación. ✔️ ✔️
method_name Nombre de la variable de método. ✔️ ✔️
http_verb Establezca en post o en get. ✔️ ✔️
cuerpo Necesario. Cuerpo de la solicitud. ❌ ✔️

Si las propiedades se definen tanto en Attributes como en RequestBody, se da prioridad a los datos proporcionados en RequestBody.

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

Uso

Para usar el enlace de salida de invocación del servicio Dapr, obtenga más información sobre cómo usar la invocación del servicio Dapr en la documentación oficial de Dapr.

Para usar daprInvoke 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 su archivo local.setting.json con la configuración siguiente:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Pasos siguientes

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