Dapr-Dienstaufruftrigger für Azure-Funktionen

Azure Functions können für einen Dapr-Dienstaufruf mithilfe der folgenden Dapr-Ereignisse ausgelöst werden.

Informationen zu Setup- und Konfigurationsdetails der Dapr-Erweiterung finden Sie in der Dapr-Erweiterungsübersicht.

Example

Eine C#-Funktion kann mit einem der folgenden C#-Modi erstellt werden:

Execution model	Description
Isoliertes Workermodell	Ihr Funktionscode wird in einem separaten .NET-Workerprozess ausgeführt. Verwenden Sie dazu unterstützte Versionen von .NET und .NET Framework. Weitere Informationen finden Sie im Handbuch zum Ausführen von C#-Azure-Funktionen im isolierten Arbeitsmodell.
In-process model	Ihr Funktionscode wird im gleichen Prozess wie der Functions-Hostprozess ausgeführt. Unterstützt nur LTS-Versionen (Long Term Support) von .NET. Weitere Informationen finden Sie unter Entwickeln von C#-Klassenbibliotheksfunktionen mithilfe von Azure Functions.

In-process

[FunctionName("CreateNewOrder")]
public static void Run(
    [DaprServiceInvocationTrigger] JObject payload,
    [DaprState("%StateStoreName%", Key = "order")] out JToken order,
    ILogger log)
{
    log.LogInformation("C# function processed a CreateNewOrder request from the Dapr Runtime.");

    // payload must be of the format { "data": { "value": "some value" } }
    order = payload["data"];
}

Isolated process

[Function("CreateNewOrder")]
[DaprStateOutput("%StateStoreName%", Key = "order")]
public static JsonElement Run(
    [DaprServiceInvocationTrigger] JsonElement payload, 
    FunctionContext functionContext)
{
    var log = functionContext.GetLogger("CreateNewOrder");
    log.LogInformation("C# function processed a CreateNewOrder request from the Dapr Runtime.");

    // payload must be of the format { "data": { "value": "some value" } }
    payload.TryGetProperty("data", out JsonElement data);

    return data;
}

Dies ist der Java-Code für den Dapr-Dienstaufruftrigger:

@FunctionName("CreateNewOrder")
public String run(
        @DaprServiceInvocationTrigger(
            methodName = "CreateNewOrder") 
)

Node.js v4

Verwenden Sie das app Objekt, um folgendes daprInvokeOutputzu registrieren:

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

app.generic('InvokeOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "invoke/{appId}/{methodName}",
        name: "req"
    }),
    return: daprInvokeOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");

        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { body: payload };
    }
});

Node.js v3

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

Here's the function.json file for daprServiceInvocationTrigger:

{
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload"
    }
  ]
}

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

Der JavaScript-Code sieht wie folgt aus:

module.exports = async function (context) {
    context.log("Node function processed a RetrieveOrder request from the Dapr Runtime.");

    // print the fetched state value
    context.log(context.bindings.data);
};

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

Here's the function.json file for daprServiceInvocationTrigger:

{
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload",
      "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 (
    $payload
)

# C# function processed a CreateNewOrder request from the Dapr Runtime.
Write-Host "PowerShell function processed a CreateNewOrder request from the Dapr Runtime."

# Payload must be of the format { "data": { "value": "some value" } }

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $payload| ConvertTo-Json

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name order -Value $payload["data"]

Python v2

Das folgende Beispiel zeigt einen Dapr Service Invocation Trigger, der das v2 Python-Programmiermodell verwendet. So verwenden Sie den daprServiceInvocationTrigger In-Python-Funktions-App-Code:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="RetrieveOrder")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveOrder")
@app.dapr_state_input(arg_name="data", state_store="statestore", key="order")
def main(payload, data: str) :
    # Function should be invoked with this command: dapr invoke --app-id functionapp --method RetrieveOrder  --data '{}'
    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
    logging.info(data)

Python v1

Das folgende Beispiel zeigt einen Dapr Service Invocation-Trigger, der das v1 Python-Programmiermodell verwendet.

Here's the function.json file for daprServiceInvocationTrigger:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload",
      "direction": "in"
    }
  ]
}

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

Dies ist der Python-Code:

import logging
import json
import azure.functions as func

def main(payload, data: str) -> None:
    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
    logging.info(data)

Attributes

In-process

In the in-process model, use the DaprServiceInvocationTrigger to trigger a Dapr service invocation binding, which supports the following properties.

Parameter	Description
MethodName	Optional. Der Name der Methode, die der Dapr-Aufrufer verwenden soll. Wenn nicht angegeben, wird der Name der Funktion als Methodenname verwendet.

Isolated process

Verwenden Sie im isolierten Workermodell den DaprServiceInvocationTrigger Aufruf eines Dapr-Diensts, der die folgenden Parameter unterstützt:

Parameter	Description
MethodName	Optional. Der Name der Methode, die der Dapr-Aufrufer verwenden soll. Wenn nicht angegeben, wird der Name der Funktion als Methodenname verwendet.

Annotations

Mit der DaprServiceInvocationTrigger Anmerkung können Sie eine Funktion erstellen, die von der Dapr-Laufzeit aufgerufen wird.

Element	Description
methodName	Der Methodenname.

Configuration

Node.js v4

Die folgende Tabelle gibt Aufschluss über die Bindungskonfigurationseigenschaften, die Sie im Code festlegen.

Property	Description
type	Muss auf daprServiceInvocationTrigger festgelegt sein.
name	Der Name der Variablen, die die Dapr-Daten im Funktionscode darstellt.

Node.js v3

Die folgende Tabelle gibt Aufschluss über die Bindungskonfigurationseigenschaften, die Sie in der Datei function.json festlegen.

function.json property	Description
type	Muss auf daprServiceInvocationTrigger festgelegt sein.
name	Der Name der Variablen, die die Dapr-Daten im Funktionscode darstellt.

Die folgende Tabelle gibt Aufschluss über die Bindungskonfigurationseigenschaften, die Sie in der Datei function.json festlegen.

function.json property	Description
type	Muss auf daprServiceInvocationTrigger festgelegt sein.
name	Der Name der Variablen, die die Dapr-Daten im Funktionscode darstellt.

Python v2

Die folgende Tabelle gibt Aufschluss über die Bindungskonfigurationseigenschaften für @dapp.dapr_service_invocation_trigger, die Sie im Python-Code festlegen.

Property	Description
method_name	Der Name der Variablen, die die Dapr-Daten darstellt.

Python v1

Die folgende Tabelle gibt Aufschluss über die Bindungskonfigurationseigenschaften, die Sie in der Datei function.json festlegen.

function.json property	Description
type	Muss auf daprServiceInvocationTrigger festgelegt sein.
name	Der Name der Variablen, die die Dapr-Daten im Funktionscode darstellt.

See the Example section for complete examples.

Usage

Wenn Sie einen Dapr Service Invocation Trigger verwenden möchten, erfahren Sie mehr darüber, welche Komponenten mit dem Dienstaufruftrigger verwendet werden sollen, und wie sie in der offiziellen Dapr-Dokumentation eingerichtet werden.

• Dapr-Komponentenspezifikationen
• Aufruf des Dapr-Diensts

Python v2

Um daprServiceInvocationTrigger in Python v2 zu verwenden, richten Sie Ihr Projekt mit den richtigen Abhängigkeiten ein.

1. Erstellen und Aktivieren einer virtuellen Umgebung

2. Fügen Sie in Ihrer requirements.text-Datei die folgende Zeile hinzu:

   azure-functions==1.18.0b3
   

3. Installieren Sie im Terminal die Python-Bibliothek.

   pip install -r .\requirements.txt
   

4. Ändern Sie ihre local.setting.json-Datei mit der folgenden Konfiguration:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Python v1

Das Python v1-Modell erfordert keine zusätzlichen Änderungen, abgesehen von der Einrichtung der Dienstaufrufkomponente.

Next steps

Erfahren Sie mehr über den Aufruf des Dapr-Dienstes.