Liaison de sortie Dapr Binding pour Azure Functions

L’exemple suivant illustre l’utilisation d’un déclencheur d’appel de service Dapr et d’une liaison de sortie Dapr pour lire et traiter une demande de liaison.

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

More samples for the Dapr output invoke binding are available in the GitHub repository.

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

Dans l’exemple suivant, la liaison de sortie Dapr est associée au déclencheur de sortie d’appel Dapr, qui est inscrit par l’objet app :

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

app.generic('SendMessageToKafka', {
    trigger: trigger.generic({
        type: 'daprServiceInvocationTrigger',
        name: "payload"
    }),
    return: daprBindingOutput,
    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 };
    }
});

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

Here's the function.json file for daprBinding:

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

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

Voici le code JavaScript :

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

L’exemple suivant montre une liaison de sortie Dapr Binding, qui utilise le modèle de programmation Python v2. Pour utiliser @dapp.dapr_binding_output dans le code de votre application de fonction 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’exemple suivant montre une liaison de sortie Dapr Binding, qui utilise le modèle de programmation Python v1.

Here's the function.json file for daprBinding:

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

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

Voici le code 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}))

In the in-process model, use the DaprBinding to define a Dapr binding output binding, which supports these parameters:

Dans le modèle de rôle de travail isolé, utilisez le DaprBindingOutput pour définir une liaison de sortie de Dapr Binding, qui prend en charge ces paramètres :

Le tableau suivant décrit les propriétés de configuration de liaison que vous définissez dans le code.

Le tableau suivant décrit les propriétés de configuration de liaison que vous définissez dans le fichier function.json.

Le tableau suivant explique les propriétés de configuration de liaison pour @dapp.dapr_binding_output que vous définissez dans votre code Python.

Le tableau suivant décrit les propriétés de configuration de liaison que vous définissez dans le fichier function.json.

Pour utiliser daprBinding dans Python v2, configurez votre projet avec les dépendances appropriées.

1. Créer et activer un environnement virtuel.

2. Dans votre fichier requirements.text, ajoutez la ligne suivante :

   azure-functions==1.18.0b3
   

3. Dans le terminal, installez la bibliothèque Python.

   pip install -r .\requirements.txt
   

4. Modifiez votre fichier local.setting.json avec la configuration suivante :

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Le modèle Python v1 ne nécessite aucune modification supplémentaire, à part la configuration du composant de liaison de sortie.