Liaison de sortie Dapr Publish pour Azure Functions

L'exemple suivant illustre l'utilisation d'une liaison de sortie de publication Dapr pour effectuer une opération de publication Dapr vers un composant et une rubrique publication ou abonnement.

[FunctionName("PublishOutputBinding")]
public static void Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "topic/{topicName}")] HttpRequest req,
    [DaprPublish(PubSubName = "%PubSubName%", Topic = "{topicName}")] out DaprPubSubEvent pubSubEvent,
    ILogger log)
{
    string requestBody = new StreamReader(req.Body).ReadToEnd();
    pubSubEvent = new DaprPubSubEvent(requestBody);
}

D’autres exemples pour la liaison de sortie de publication Dapr sont disponibles dans le référentiel GitHub.

[Function("PublishOutputBinding")]
[DaprPublishOutput(PubSubName = "%PubSubName%", Topic = "{topicName}")]
public static DaprPubSubEvent Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "topic/{topicName}")] HttpRequestData req,
    FunctionContext functionContext)
{
    string requestBody = new StreamReader(req.Body).ReadToEnd();

    return new DaprPubSubEvent(requestBody);
}

Dans l’exemple suivant, la liaison de sortie de publication Dapr est associée à un déclencheur HTTP, qui est inscrit par l’objet app :

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

app.generic('PublishOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "topic/{topicName}",
        name: "req"
    }),
    return: daprPublishOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");
        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { payload: payload };
    }
});

Les exemples suivants montrent les déclencheurs Dapr dans un fichier function.json et le code JavaScript qui utilise ces liaisons.

Voici le fichier function.json pour daprPublish :

{
  "bindings": 
    {
      "type": "daprPublish",
      "direction": "out",
      "pubsubname": "messagebus",
      "topic": "{topicName}",
      "name": "payload"
    }
}

Pour plus d’informations sur les propriétés du fichier function.json, consultez la section Configuration.

Voici le code JavaScript :

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

L’exemple suivant montre une liaison de sortie Dapr Publish, qui utilise le modèle de programmation Python v2. Pour utiliser daprPublish 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="TransferEventBetweenTopics")
@app.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="A", route="A")
@app.dapr_publish_output(arg_name="pubEvent", pub_sub_name="%PubSubName%", topic="B")
def main(subEvent, pubEvent: func.Out[bytes]) -> None:
    logging.info('Python function processed a TransferEventBetweenTopics request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    payload = "Transfer from Topic A: " + str(subEvent_json["data"])
    pubEvent.set(json.dumps({"payload": payload}).encode('utf-8'))

L’exemple suivant montre une liaison de sortie Dapr Publish, qui utilise le modèle de programmation Python v1.

Voici le fichier function.json pour daprPublish :

{
  "scriptFile": "__init__.py",
  "bindings": 
    {
      "type": "daprPublish",
      "direction": "out",
      "name": "pubEvent",
      "pubsubname": "messagebus",
      "topic": "B"
    }
}

Pour plus d’informations sur les propriétés du fichier function.json, consultez la section Configuration.

Voici le code Python :

def main(subEvent,
         pubEvent: func.Out[bytes]) -> None:
    logging.info('Python function processed a TransferEventBetweenTopics request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    payload = "Transfer from Topic A: " + str(subEvent_json["data"])
    pubEvent.set(json.dumps({"payload": payload }))

Dans le modèle in-process, utilisez le DaprPublish pour définir une liaison de sortie de publication Dapr, qui prend en charge ces paramètres :

Dans le modèle de rôle de travail isolé, utilisez le DaprPublish Output pour définir une liaison de sortie de publication Dapr, 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_publish_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 daprPublish 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 sortie de publication ou d’abonnement.