Dapr-onderwerptrigger voor Azure Functions

Azure Functions kan worden geactiveerd voor een Dapr-onderwerpabonnement met behulp van de volgende Dapr-gebeurtenissen.

Zie het overzicht van de Dapr-extensie voor meer informatie over het instellen en configureren van de Dapr-extensie.

Opmerking

U kunt een C#-functie maken met behulp van een van de volgende C#-modi:

Uitvoeringsmodel	Beschrijving
Geïsoleerde werkrolmodel	Uw functiecode wordt uitgevoerd in een afzonderlijk .NET-werkproces. Gebruiken met ondersteunde versies van .NET en .NET Framework. Zie .NET geïsoleerde werkprocesfuncties ontwikkelen voor meer informatie.
Model in proces	Uw functiecode wordt uitgevoerd in hetzelfde proces als het Functions-hostproces. Ondersteunt alleen LTS-versies (Long Term Support) van .NET. Zie .NET-klassebibliotheekfuncties ontwikkelen voor meer informatie.

In-proces

[FunctionName("TransferEventBetweenTopics")]
public static void Run(
    [DaprTopicTrigger("%PubSubName%", Topic = "A")] CloudEvent subEvent,
    [DaprPublish(PubSubName = "%PubSubName%", Topic = "B")] out DaprPubSubEvent pubEvent,
    ILogger log)
{
    log.LogInformation("C# function processed a TransferEventBetweenTopics request from the Dapr Runtime.");


    pubEvent = new DaprPubSubEvent("Transfer from Topic A: " + subEvent.Data);
}

Geïsoleerd proces

[Function("TransferEventBetweenTopics")]
[DaprPublishOutput(PubSubName = "%PubSubName%", Topic = "B")]
public static DaprPubSubEvent Run(
    [DaprTopicTrigger("%PubSubName%", Topic = "A")] CloudEvent subEvent, FunctionContext functionContext)
{
    var log = functionContext.GetLogger("TransferEventBetweenTopics");
    log.LogInformation("C# function processed a TransferEventBetweenTopics request from the Dapr Runtime.");

    return new DaprPubSubEvent("Transfer from Topic A: " + subEvent.Data);
}

Hier volgt de Java-code voor het abonneren op een onderwerp met behulp van de Dapr-onderwerptrigger:

@FunctionName("PrintTopicMessage")
public String run(
        @DaprTopicTrigger(
            pubSubName = "%PubSubName%",
            topic = "B")
        String payload,
        final ExecutionContext context) throws JsonProcessingException {
    Logger logger = context.getLogger();
    logger.info("Java function processed a PrintTopicMessage request from the Dapr Runtime.");

Node.js v4

Gebruik het app object om het daprTopicTriggervolgende te registreren:

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

app.generic('TransferEventBetweenTopics', {
    trigger: trigger.generic({
        type: 'daprTopicTrigger',
        name: "subEvent",
        pubsubname: "%PubSubName%",
        topic: "A"
    }),
    return: daprPublishOutput,
    handler: async (request, context) => {
        context.log("Node function processed a TransferEventBetweenTopics request from the Dapr Runtime.");
        context.log(context.triggerMetadata.subEvent.data);

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

Node.js v3

In de volgende voorbeelden ziet u Dapr-triggers in een function.json-bestand en JavaScript-code die gebruikmaakt van deze bindingen.

Dit is het function.json-bestand voor daprTopicTrigger:

{
  "bindings": [
    {
      "type": "daprTopicTrigger",
      "pubsubname": "messagebus",
      "topic": "B",
      "name": "subEvent"
    }
  ]
}

Zie de sectie Configuratie voor meer informatie over function.json bestandseigenschappen.

Dit is de JavaScript-code voor de Dapr-onderwerptrigger:

module.exports = async function (context) {
    context.log("Node function processed a PrintTopicMessage request from the Dapr Runtime.");
    context.log(`Topic B received a message: ${context.bindings.subEvent.data}.`);
};

In de volgende voorbeelden ziet u Dapr-triggers in een function.json-bestand en PowerShell-code die gebruikmaakt van deze bindingen.

Dit is het function.json-bestand voor daprTopicTrigger:

{
  "bindings": [
    {
      "type": "daprTopicTrigger",
      "pubsubname": "%PubSubName%",
      "topic": "B",
      "name": "subEvent",
      "direction": "in"
    }
  ]
}

Zie de sectie Configuratie voor meer informatie over function.json bestandseigenschappen.

In code:

using namespace System
using namespace Microsoft.Azure.WebJobs
using namespace Microsoft.Extensions.Logging
using namespace Microsoft.Azure.WebJobs.Extensions.Dapr
using namespace Newtonsoft.Json.Linq

param (
    $subEvent
)

Write-Host "PowerShell function processed a PrintTopicMessage request from the Dapr Runtime."

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $subEvent["data"] | ConvertTo-Json -Compress

Write-Host "Topic B received a message: $jsonString"

Python v2

In het volgende voorbeeld ziet u een Dapr-onderwerptrigger, die gebruikmaakt van het v2 Python-programmeermodel. Ga als volgt te werk om de code van uw daprTopicTrigger Python-functie-app te gebruiken:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="PrintTopicMessage")
@app.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="B", route="B")
def main(subEvent) -> None:
    logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    logging.info("Topic B received a message: " + subEvent_json["data"])

Python v1

In het volgende voorbeeld ziet u een Dapr-onderwerptrigger, die gebruikmaakt van het python-programmeermodel v1.

Dit is het function.json-bestand voor daprTopicTrigger:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "daprTopicTrigger",
      "pubsubname": "messagebus",
      "topic": "B",
      "name": "subEvent",
      "direction": "in"
    }
  ]
}

Zie de sectie Configuratie voor meer informatie over function.json bestandseigenschappen.

Dit is de Python-code:

import logging
import json
import azure.functions as func

def main(subEvent) -> None:
    logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    logging.info("Topic B received a message: " + subEvent_json["data"])

Kenmerken

In-proces

Gebruik in het procesmodel de DaprTopicTrigger opdracht om een Dapr pub/subbinding te activeren, die de volgende eigenschappen ondersteunt.

Parameter	Description
PubSubName	De naam van de Dapr pub/sub.
Onderwerp	De naam van het Dapr-onderwerp.

Geïsoleerd proces

Gebruik in het geïsoleerde werkrolmodel een DaprTopicTrigger Dapr-onderwerptrigger te definiëren die ondersteuning biedt voor deze parameters:

Parameter	Description
PubSubName	De naam van de Dapr pub/sub.
Onderwerp	De naam van het Dapr-onderwerp.

Aantekeningen

Met de DaprTopicTrigger aantekening kunt u een functie maken die wordt uitgevoerd wanneer een onderwerp wordt ontvangen.

Element	Beschrijving
pubSubName	De naam van de Dapr pub/sub.
onderwerp	De naam van het Dapr-onderwerp.

Configuratie

Node.js v4

In de volgende tabel worden de bindingsconfiguratie-eigenschappen uitgelegd die u in de code hebt ingesteld.

Eigenschappen	Beschrijving
pubsubname	De naam van het type Dapr pub/subonderdeel.
onderwerp	Naam van het onderwerp.

Node.js v3

In de volgende tabel worden de bindingsconfiguratie-eigenschappen uitgelegd die u in het function.json-bestand hebt ingesteld.

function.json-eigenschap	Beschrijving
pubsubname	De naam van het type Dapr pub/subonderdeel.
onderwerp	Naam van het onderwerp.

In de volgende tabel worden de bindingsconfiguratie-eigenschappen uitgelegd die u in het function.json-bestand hebt ingesteld.

function.json-eigenschap	Beschrijving
pubsubname	De naam van het type Dapr pub/subonderdeel.
onderwerp	Naam van het onderwerp.

Python v2

In de volgende tabel worden de bindingsconfiguratie-eigenschappen @dapp.dapr_topic_trigger uitgelegd die u in uw Python-code hebt ingesteld.

Eigenschappen	Beschrijving	Kan worden verzonden via kenmerk	Kan worden verzonden via RequestBody
pub_sub_name	De naam van het onderdeeltype Dapr-abonnement.	✔️	❌
onderwerp	Het abonnementsonderwerp.	✔️	❌

Python v1

In de volgende tabel worden de bindingsconfiguratie-eigenschappen uitgelegd die u in het function.json-bestand hebt ingesteld.

function.json-eigenschap	Beschrijving	Kan worden verzonden via kenmerk	Kan worden verzonden via RequestBody
pubsubname	De naam van het onderdeeltype Dapr-abonnement.	✔️	❌
onderwerp	Naam van het onderwerp.	✔️	❌

Zie de sectie Voorbeeld voor volledige voorbeelden.

Gebruik

Als u een Dapr-onderwerptrigger wilt gebruiken, begint u met het instellen van een Dapr pub/subonderdeel. Meer informatie over welk onderdeel u moet gebruiken en hoe u dit kunt instellen in de officiële Dapr-documentatie.

• Dapr pub/subcomponentspecificaties
• Procedure: Een bericht publiceren en zich abonneren op een onderwerp

Python v2

Als u het daprTopicTrigger project in Python v2 wilt gebruiken, stelt u uw project in met de juiste afhankelijkheden.

1. Een virtuele omgeving maken en activeren.

2. Voeg in het requirements.text bestand de volgende regel toe:

   azure-functions==1.18.0b3
   

3. Installeer de Python-bibliotheek in de terminal.

   pip install -r .\requirements.txt
   

4. Wijzig uw local.setting.json bestand met de volgende configuratie:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Python v1

Voor het Python v1-model zijn geen aanvullende wijzigingen vereist, afgezien van het instellen van het pub/subonderdeel.

Volgende stappen

Meer informatie over publiceren en abonneren op Dapr.