Wyzwalacz wywołania usługi Dapr dla usługi Azure Functions

Usługa Azure Functions może zostać wyzwolona w wywołaniu usługi Dapr przy użyciu następujących zdarzeń języka Dapr.

Aby uzyskać informacje na temat konfiguracji i szczegółów konfiguracji rozszerzenia Języka Dapr, zobacz Omówienie rozszerzenia Języka Dapr.

Przykład

Funkcję języka C# można utworzyć przy użyciu jednego z następujących trybów języka C#:

Model wykonania	opis
Model izolowanego procesu roboczego	Kod funkcji jest uruchamiany w osobnym procesie roboczym platformy .NET. Używaj z obsługiwanymi wersjami platform .NET i .NET Framework. Aby dowiedzieć się więcej, zobacz Develop .NET isolated worker process functions (Tworzenie izolowanych funkcji procesów roboczych platformy .NET).
Model w procesie	Kod funkcji jest uruchamiany w tym samym procesie co proces hosta usługi Functions. Obsługuje tylko wersje long term support (LTS) platformy .NET. Aby dowiedzieć się więcej, zobacz Tworzenie funkcji biblioteki klas platformy .NET.

Proces

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

Proces izolowany

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

Oto kod Java wyzwalacza wywołania usługi Dapr:

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

Node.js w wersji 4

Użyj obiektu , app aby zarejestrować obiekt daprInvokeOutput:

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 w wersji 3

W poniższych przykładach pokazano wyzwalacze języka Dapr w pliku function.json i kodzie JavaScript, który używa tych powiązań.

Oto plik function.json dla elementu daprServiceInvocationTrigger:

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

Aby uzyskać więcej informacji na temat function.json właściwości pliku, zobacz sekcję Konfiguracja.

Oto kod JavaScript:

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

W poniższych przykładach pokazano wyzwalacze języka Dapr w pliku function.json i kodzie programu PowerShell, który używa tych powiązań.

Oto plik function.json dla elementu daprServiceInvocationTrigger:

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

Aby uzyskać więcej informacji na temat function.json właściwości pliku, zobacz sekcję Konfiguracja.

W kodzie:

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

W poniższym przykładzie pokazano wyzwalacz wywołania usługi Dapr, który używa modelu programowania w języku Python w wersji 2. Aby użyć elementu daprServiceInvocationTrigger w kodzie aplikacji funkcji języka Python:

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

W poniższym przykładzie pokazano wyzwalacz wywołania usługi Dapr, który używa modelu programowania w języku Python w wersji 1.

Oto plik function.json dla elementu daprServiceInvocationTrigger:

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

Aby uzyskać więcej informacji na temat function.json właściwości pliku, zobacz sekcję Konfiguracja.

Oto kod języka Python:

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)

Atrybuty

Proces

W modelu przetwarzania użyj DaprServiceInvocationTrigger polecenia , aby wyzwolić powiązanie wywołania usługi Dapr, które obsługuje następujące właściwości.

Parametr	Opis
Methodname	Opcjonalny. Nazwa metody, która powinna być używana przez obiekt wywołujący Dapr. Jeśli nie zostanie określona, nazwa funkcji jest używana jako nazwa metody.

Proces izolowany

W modelu izolowanego procesu roboczego użyj DaprServiceInvocationTrigger polecenia , aby zdefiniować wyzwalacz wywołania usługi Dapr, który obsługuje następujące parametry:

Parametr	Opis
Methodname	Opcjonalny. Nazwa metody, która powinna być używana przez obiekt wywołujący Dapr. Jeśli nie zostanie określona, nazwa funkcji jest używana jako nazwa metody.

Adnotacje

Adnotacja DaprServiceInvocationTrigger umożliwia utworzenie funkcji wywoływanej przez środowisko uruchomieniowe języka Dapr.

Element	opis
Methodname	Nazwa metody.

Konfigurowanie

Node.js w wersji 4

W poniższej tabeli opisano właściwości konfiguracji powiązania ustawione w kodzie.

Właściwości	Opis
type	Musi być ustawiona wartość daprServiceInvocationTrigger.
name	Nazwa zmiennej reprezentującej dane języka Dapr w kodzie funkcji.

Node.js w wersji 3

W poniższej tabeli opisano właściwości konfiguracji powiązania ustawione w pliku function.json.

właściwość function.json	opis
type	Musi być ustawiona wartość daprServiceInvocationTrigger.
name	Nazwa zmiennej reprezentującej dane języka Dapr w kodzie funkcji.

W poniższej tabeli opisano właściwości konfiguracji powiązania ustawione w pliku function.json.

właściwość function.json	opis
type	Musi być ustawiona wartość daprServiceInvocationTrigger.
name	Nazwa zmiennej reprezentującej dane języka Dapr w kodzie funkcji.

Python v2

W poniższej tabeli opisano właściwości konfiguracji powiązania ustawione @dapp.dapr_service_invocation_trigger w kodzie języka Python.

Właściwości	opis
method_name	Nazwa zmiennej reprezentującej dane dapr.

Python v1

W poniższej tabeli opisano właściwości konfiguracji powiązania ustawione w pliku function.json.

właściwość function.json	opis
type	Musi być ustawiona wartość daprServiceInvocationTrigger.
name	Nazwa zmiennej reprezentującej dane języka Dapr w kodzie funkcji.

Zobacz sekcję Przykład, aby zapoznać się z kompletnymi przykładami.

Użycie

Aby użyć wyzwalacza wywołania usługi Dapr, dowiedz się więcej o składnikach, które mają być używane z wyzwalaczem wywołania usługi i jak je skonfigurować w oficjalnej dokumentacji języka Dapr.

• Specyfikacje składników języka Dapr
• Wywołanie usługi Dapr

Python v2

Aby użyć elementu daprServiceInvocationTrigger w języku Python w wersji 2, skonfiguruj projekt przy użyciu poprawnych zależności.

1. Tworzenie i aktywowanie środowiska wirtualnego.

2. requirements.text W pliku dodaj następujący wiersz:

   azure-functions==1.18.0b3
   

3. W terminalu zainstaluj bibliotekę języka Python.

   pip install -r .\requirements.txt
   

4. local.setting.json Zmodyfikuj plik przy użyciu następującej konfiguracji:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Python v1

Model języka Python w wersji 1 nie wymaga żadnych dodatkowych zmian, oprócz konfigurowania składnika wywołania usługi.

Następne kroki

Dowiedz się więcej o wywołaniu usługi Dapr.