Dela via

Dapr-indatabindningsutlösare för Azure Functions

Azure Functions kan utlösas på en Dapr-indatabindning med hjälp av följande Dapr-händelser.

Information om installation och konfiguration av Dapr-tillägget finns i översikten över Dapr-tillägget.

Example

En C#-funktion kan skapas med något av följande C#-lägen:

Execution model Description
Isolerad arbetsmodell Funktionskoden körs i en separat .NET-arbetsprocess. Använd med versioner av .NET och .NET Framework som stöds. Mer information finns i Guide för att köra C# Azure Functions i den isolerade arbetsmodellen.
In-process model Funktionskoden körs i samma process som värdprocessen för Functions. Stöder endast LTS-versioner (Long Term Support) av .NET. Mer information finns i Utveckla C#-klassbiblioteksfunktioner med Hjälp av Azure Functions. 
[FunctionName("ConsumeMessageFromKafka")]
public static void Run(
    // Note: the value of BindingName must match the binding name in components/kafka-bindings.yaml
    [DaprBindingTrigger(BindingName = "%KafkaBindingName%")] JObject triggerData,
    ILogger log)
{
    log.LogInformation("Hello from Kafka!");
    log.LogInformation($"Trigger data: {triggerData}");
}

Här är Java-koden för Dapr-indatabindningsutlösaren:

@FunctionName("ConsumeMessageFromKafka")
public String run(
        @DaprBindingTrigger(
            bindingName = "%KafkaBindingName%")
)

Använd - app objektet för att registrera daprBindingTrigger:

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

app.generic('ConsumeMessageFromKafka', {
    trigger: trigger.generic({
        type: 'daprBindingTrigger',
        bindingName: "%KafkaBindingName%",
        name: "triggerData"
    }),
    handler: async (request, context) => {
        context.log("Node function processed a ConsumeMessageFromKafka request from the Dapr Runtime.");
        context.log(context.triggerMetadata.triggerData)
    }
});

The following example shows Dapr triggers in a function.json file and PowerShell code that uses those bindings.

Here's the function.json file for daprBindingTrigger:

{
  "bindings": [
    {
      "type": "daprBindingTrigger",
      "bindingName": "%KafkaBindingName%",
      "name": "triggerData",
      "direction": "in"
    }
  ]
}

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

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 (
    $triggerData
)

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

$jsonString = $triggerData | ConvertTo-Json

Write-Host "Trigger data: $jsonString"

I följande exempel visas en Dapr-indatabindningsutlösare som använder programmeringsmodellen v2 Python. Så här använder daprBinding du i din Python-funktionsappkod:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="ConsumeMessageFromKafka")
@app.dapr_binding_trigger(arg_name="triggerData", binding_name="%KafkaBindingName%")
def main(triggerData: str) -> None:
    logging.info('Python function processed a ConsumeMessageFromKafka request from the Dapr Runtime.')
    logging.info('Trigger data: ' + triggerData)

Attributes

In the in-process model, use the DaprBindingTrigger to trigger a Dapr input binding, which supports the following properties.

Parameter Description
BindingName Namnet på Dapr-utlösaren. Om det inte anges används namnet på funktionen som utlösarnamn.

Annotations

Med anteckningen DaprBindingTrigger kan du skapa en funktion som utlöses av bindningskomponenten som du skapade.

Element Description
bindingName Namnet på Dapr-bindningen.

Configuration

I följande tabell förklaras de bindningskonfigurationsegenskaper som du anger i koden.

Property Description
bindingName Namnet på bindningen.

I följande tabell förklaras de bindningskonfigurationsegenskaper som du anger i function.json-filen.

function.json property Description
bindingName Namnet på bindningen.

I följande tabell beskrivs bindningskonfigurationsegenskaperna för @dapp.dapr_binding_trigger som du anger i Python-koden.

Property Description
binding_name Namnet på bindningen.

See the Example section for complete examples.

Usage

Om du vill använda Dapr-indatabindningsutlösaren börjar du med att konfigurera en Dapr-indatabindningskomponent. Du kan lära dig mer om vilken komponent som ska användas och hur du konfigurerar den i den officiella Dapr-dokumentationen.

Om du vill använda daprBindingTrigger i Python v2 konfigurerar du projektet med rätt beroenden.

  1. Skapa och aktivera en virtuell miljö.

  2. requirements.text Lägg till följande rad i filen:

    azure-functions==1.18.0b3

  3. Installera Python-biblioteket i terminalen.

    pip install -r .\requirements.txt

  4. local.setting.json Ändra filen med följande konfiguration:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Next steps

Läs mer om anrop av Dapr-tjänsten.