Associazione di output del binding dapr per Funzioni di Azure

L'esempio seguente illustra l'uso di un trigger di chiamata al servizio Dapr e di un'associazione di output Dapr per leggere ed elaborare una richiesta di associazione.

[FunctionName("SendMessageToKafka")]
public static async Task Run(
    [DaprServiceInvocationTrigger] JObject payload,
    [DaprBinding(BindingName = "%KafkaBindingName%", Operation = "create")] IAsyncCollector<object> messages,
    ILogger log)
{
    log.LogInformation("C#  function processed a SendMessageToKafka request.");
    await messages.AddAsync(payload);
}

Altri esempi per l'associazione di richiamo dell'output Dapr sono disponibili nel repository GitHub.

[Function("SendMessageToKafka")]
[DaprBindingOutput(BindingName = "%KafkaBindingName%", Operation = "create")]
public static JsonElement Run(
    [DaprServiceInvocationTrigger] JsonElement payload, FunctionContext functionContext)
{
    var log = functionContext.GetLogger("SendMessageToKafka");
    log.LogInformation("C#  function processed a SendMessageToKafka request.");

    return payload;
}

Nell'esempio seguente, l'associazione di output Dapr viene associata al trigger di output Dapr invoke, registrato dall'oggetto app:

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

app.generic('SendMessageToKafka', {
    trigger: trigger.generic({
        type: 'daprServiceInvocationTrigger',
        name: "payload"
    }),
    return: daprBindingOuput,
    handler: async (request, context) => {
        context.log("Node function processed a SendMessageToKafka request from the Dapr Runtime.");
        context.log(context.triggerMetadata.payload)

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

Negli esempi seguenti vengono illustrati i trigger Dapr in un file function.json e nel codice JavaScript che usa tali associazioni.

Ecco il file function.json per daprBinding:

{
  "bindings": 
    {
      "type": "daprBinding",
      "direction": "out",
      "bindingName": "%KafkaBindingName%",
      "operation": "create",
      "name": "messages"
    }
}

Per altre informazioni sulle proprietà dei file function.json, vedere la sezione configurazione.

Ecco il codice JavaScript:

module.exports = async function (context) {
    context.log("Node HTTP trigger function processed a request.");
    context.bindings.messages = { "data": context.bindings.args };
};

L'esempio seguente mostra un'associazione di output dapr Binding, che usa il modello di programmazione Python v2. Per usare @dapp.dapr_binding_output nel codice dell'app per le funzioni Python:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="SendMessageToKafka")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="SendMessageToKafka")
@app.dapr_binding_output(arg_name="messages", binding_name="%KafkaBindingName%", operation="create")
def main(payload: str, messages: func.Out[bytes]) -> None:
    logging.info('Python processed a SendMessageToKafka request from the Dapr Runtime.')
    messages.set(json.dumps({"data": payload}).encode('utf-8'))

L'esempio seguente mostra un'associazione di output dapr Binding, che usa il modello di programmazione Python v1.

Ecco il file function.json per daprBinding:

{
  "scriptFile": "__init__.py",
  "bindings": 
    {
      "type": "daprBinding",
      "direction": "out",
      "bindingName": "%KafkaBindingName%",
      "operation": "create",
      "name": "messages"
    }
}

Per altre informazioni sulle proprietà dei file function.json, vedere la sezione configurazione.

Ecco il codice Python:

import logging
import json
import azure.functions as func

def main(args, messages: func.Out[bytes]) -> None:
    logging.info('Python processed a SendMessageToKafka request from the Dapr Runtime.')
    messages.set(json.dumps({"data": args}))

Nel modello in-process usare il DaprBinding per definire un'associazione di output di associazione Dapr, che supporta questi parametri:

Nel modello di lavoro isolato, usare il DaprBindingOutput per definire un'associazione di output di associazione Dapr, che supporta questi parametri:

Nella tabella seguente vengono illustrate le proprietà di configurazione dell'associazione impostate nel codice.

Nella tabella seguente sono illustrate le proprietà di configurazione dell'associazione impostate nel file function.json.

La tabella seguente illustra le proprietà di configurazione dell'associazione per @dapp.dapr_binding_output impostate nel codice Python.

Nella tabella seguente sono illustrate le proprietà di configurazione dell'associazione impostate nel file function.json.

Per usare daprBinding in Python v2, configurare il progetto con le dipendenze corrette.

1. Creare e attivare un ambiente virtuale.

2. Nel file requirements.text aggiungere la riga seguente:

   azure-functions==1.18.0b3
   

3. Nel terminale installare la libreria Python.

   pip install -r .\requirements.txt
   

4. Modificare il file local.setting.json con la configurazione seguente:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Il modello Python v1 non richiede modifiche aggiuntive, a parte la configurazione del componente di associazione di output.