Trigger vstupních vazeb Dapr pro Azure Functions

Azure Functions je možné aktivovat u vstupní vazby Dapr pomocí následujících událostí Dapr.

Informace o nastavení a konfiguraci rozšíření Dapr najdete v přehledu rozšíření Dapr.

Example

Funkci jazyka C# je možné vytvořit pomocí jednoho z následujících režimů jazyka C#:

Execution model	Description
Izolovaný model pracovního procesu	Kód funkce se spouští v samostatném pracovním procesu .NET. Používá se s podporovanými verzemi rozhraní .NET a .NET Framework. Další informace najdete v Příručce pro spouštění funkcí Azure Functions jazyka C# v izolovaném pracovním modelu.
In-process model	Kód funkce se spouští ve stejném procesu jako hostitelský proces služby Functions. Podporuje pouze verze dlouhodobé podpory (LTS) rozhraní .NET. Další informace najdete v tématu Vývoj funkcí knihovny tříd jazyka C# pomocí Azure Functions.

In-process

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

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

Tady je kód Java pro trigger vstupní vazby Dapr:

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

Node.js v4

Pomocí objektu app zaregistrujte 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

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

Here's the function.json file for daprBindingTrigger:

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

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

Tady je javascriptový kód:

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

    context.log(`Trigger data: ${context.bindings.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"

Python v2

Následující příklad ukazuje trigger vstupní vazby Dapr, který používá programovací model Pythonu v2. Použití kódu aplikace funkcí Pythonu daprBinding :

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

Následující příklad ukazuje trigger vstupní vazby Dapr, který používá programovací model Pythonu v1.

Here's the function.json file for daprBindingTrigger:

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

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

Tady je kód Pythonu:

import logging
import json
import azure.functions as func

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

Attributes

In-process

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

Parameter	Description
BindingName	Název triggeru Dapr. Pokud není zadaný, název funkce se použije jako název triggeru.

Isolated process

V izolovaném modelu pracovního procesu použijte DaprBindingTrigger k definování triggeru vazby Dapr, který podporuje tyto parametry:

Parameter	Description
BindingName	Název triggeru Dapr. Pokud není zadaný, název funkce se použije jako název triggeru.

Annotations

Poznámka DaprBindingTrigger umožňuje vytvořit funkci, která se aktivuje komponentou vazby, kterou jste vytvořili.

Element	Description
bindingName	Název vazby Dapr.

Configuration

Node.js v4

Následující tabulka vysvětluje vlastnosti konfigurace vazby, které jste nastavili v kódu.

Property	Description
bindingName	Název vazby.

Node.js v3

Následující tabulka vysvětluje vlastnosti konfigurace vazby, které jste nastavili v souboru function.json.

function.json property	Description
bindingName	Název vazby.

Následující tabulka vysvětluje vlastnosti konfigurace vazby, které jste nastavili v souboru function.json.

function.json property	Description
bindingName	Název vazby.

Python v2

Následující tabulka vysvětluje vlastnosti konfigurace vazby, @dapp.dapr_binding_trigger které jste nastavili v kódu Pythonu.

Property	Description
binding_name	Název vazby.

Python v1

Následující tabulka vysvětluje vlastnosti konfigurace vazby, které jste nastavili v souboru function.json.

function.json property	Description
bindingName	Název vazby.

See the Example section for complete examples.

Usage

Pokud chcete použít trigger vstupní vazby Dapr, začněte nastavením komponenty vstupní vazby Dapr. Další informace o tom, kterou komponentu použít a jak ji nastavit, najdete v oficiální dokumentaci k Dapr.

• Specifikace komponent vstupní vazby Dapr
• Postupy: Aktivace aplikace pomocí vstupních vazeb

Python v2

Pokud chcete použít python daprBindingTrigger v2, nastavte projekt se správnými závislostmi.

1. Vytvoření a aktivace virtuálního prostředí

2. requirements.text Do souboru přidejte následující řádek:

   azure-functions==1.18.0b3
   

3. V terminálu nainstalujte knihovnu Pythonu.

   pip install -r .\requirements.txt
   

4. Upravte local.setting.json soubor pomocí následující konfigurace:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Python v1

Model Pythonu v1 nevyžaduje žádné další změny, kromě nastavení komponenty vazeb.

Next steps

Přečtěte si další informace o vyvolání služby Dapr.