Enlace de salida de invocación de Dapr para Azure Functions

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 hospedada en otra aplicación dapr-ized. 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();
}

Hay disponibles más ejemplos para el enlace de salida de invocación de Dapr en el repositorio de GitHub.

[Function("InvokeOutputBinding")]
[DaprInvokeOutput(AppId = "{appId}", MethodName = "{methodName}", HttpVerb = "post")]
public static async Task<InvokeMethodParameters> Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = "invoke/{appId}/{methodName}")] HttpRequestData req, FunctionContext functionContext)
{
    var log = functionContext.GetLogger("InvokeOutputBinding");
    log.LogInformation("C# HTTP trigger function processed a request.");

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

    var outputContent = new InvokeMethodParameters
    {
        Body = requestBody
    };

    return outputContent;
}

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

Este es el código de JavaScript:

module.exports = async function (context, req) {
    context.log("Node HTTP trigger function processed a request.");
    context.bindings.output = { body: req.body };
    context.done(null);
};

En el ejemplo siguiente se muestra un enlace de salida Invoke de Dapr, que usa el modelo de programación de Python v2. Para usar daprInvoke 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="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'

En el ejemplo siguiente se muestra un enlace de salida Invoke de Dapr, que usa el modelo de programación de Python v1.

Este es el archivo function.json para daprInvoke:

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

Para más información sobre las propiedades del archivo function.json, consulte la sección Configuración donde se explican estas propiedades.

Este es el código de Python:

def main(req: func.HttpRequest,
         payload: func.Out[bytes]) -> func.HttpResponse:
    logging.info('Python InvokeOutputBinding processed a request.')
    data = req.params.get('data')

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

En el modelo de trabajo aislado, use el DaprInvokeOutput atributo para definir un enlace de salida de invocación de Dapr, que admite estos parámetros:

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

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

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.

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

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

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

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