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.

Exempel

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

Körningsmodell	beskrivning
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 Utveckla .NET-isolerade arbetsprocessfunktioner.
Processmodell	Funktionskoden körs i samma process som Functions-värdprocessen. Stöder endast LTS-versioner (Long Term Support) av .NET. Mer information finns i Utveckla .NET-klassbiblioteksfunktioner.

Pågående

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

Isolerad process

[Function("ConsumeMessageFromKafka")]
public static void Run(
    // Note: the value of BindingName must match the binding name in components/kafka-bindings.yaml
    [DaprBindingTrigger(BindingName = "%KafkaBindingName%")] JsonElement triggerData,
    FunctionContext functionContext)
{
    var log = functionContext.GetLogger("ConsumeMessageFromKafka");

    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%")
)

Node.js v4

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

Node.js v3

I följande exempel visas Dapr-utlösare i en function.json fil och JavaScript-kod som använder dessa bindningar.

Här är filen function.json för daprBindingTrigger:

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

Mer information om function.json filegenskaper finns i avsnittet Konfiguration .

Här är JavaScript-koden:

module.exports = async function (context) {
    context.log("Hello from Kafka!");

    context.log(`Trigger data: ${context.bindings.triggerData}`);
};

I följande exempel visas Dapr-utlösare i en function.json fil och PowerShell-kod som använder dessa bindningar.

Här är filen function.json för daprBindingTrigger:

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

Mer information om function.json filegenskaper finns i avsnittet Konfiguration .

I kod:

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"

Python v2

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)

Python v1

I följande exempel visas en Dapr-indatabindningsutlösare som använder programmeringsmodellen v1 Python.

Här är filen function.json för daprBindingTrigger:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "daprBindingTrigger",
      "bindingName": "sample-topic",
      "name": "triggerData",
      "direction": "in"
    }
  ]
}

Mer information om function.json filegenskaper finns i avsnittet Konfiguration .

Här är Python-koden:

import logging
import json
import azure.functions as func

def main(triggerData: str) -> None:
    logging.info('Hello from Kafka!')
    logging.info('Trigger data: ' + triggerData)

Attribut

Pågående

I den processbaserade modellen använder du DaprBindingTrigger för att utlösa en Dapr-indatabindning, som stöder följande egenskaper.

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

Isolerad process

I den isolerade arbetsmodellen använder du DaprBindingTrigger för att definiera en Dapr-bindningsutlösare som stöder följande parametrar:

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

Kommentarer

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

Element	Description
bindingName	Namnet på Dapr-bindningen.

Konfiguration

Node.js v4

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

Property	beskrivning
bindingName	Namnet på bindningen.

Node.js v3

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

function.json egenskap	beskrivning
bindingName	Namnet på bindningen.

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

function.json egenskap	beskrivning
bindingName	Namnet på bindningen.

Python v2

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

Property	beskrivning
binding_name	Namnet på bindningen.

Python v1

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

function.json egenskap	beskrivning
bindingName	Namnet på bindningen.

Se avsnittet Exempel för fullständiga exempel.

Användning

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.

• Specifikationer för dapr-indatabindningskomponent
• Anvisningar: Utlösa programmet med indatabindningar

Python v2

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
   

Python v1

Python v1-modellen kräver inga ytterligare ändringar, förutom att konfigurera bindningskomponenten.

Nästa steg

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