Aanroeptrigger voor Dapr-service voor Azure Functions

Azure Functions kan worden geactiveerd in een Aanroep van een Dapr-service met behulp van de volgende Dapr-gebeurtenissen.

Zie het overzicht van de Dapr-extensie voor meer informatie over het instellen en configureren van de Dapr-extensie.

Opmerking

U kunt een C#-functie maken met behulp van een van de volgende C#-modi:

Uitvoeringsmodel	Beschrijving
Geïsoleerde werkrolmodel	Uw functiecode wordt uitgevoerd in een afzonderlijk .NET-werkproces. Gebruiken met ondersteunde versies van .NET en .NET Framework. Zie .NET geïsoleerde werkprocesfuncties ontwikkelen voor meer informatie.
Model in proces	Uw functiecode wordt uitgevoerd in hetzelfde proces als het Functions-hostproces. Ondersteunt alleen LTS-versies (Long Term Support) van .NET. Zie .NET-klassebibliotheekfuncties ontwikkelen voor meer informatie.

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

Geïsoleerd proces

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

Dit is de Java-code voor de aanroeptrigger van de Dapr-service:

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

Node.js v4

Gebruik het app object om het daprInvokeOutputvolgende te registreren:

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

In de volgende voorbeelden ziet u Dapr-triggers in een function.json-bestand en JavaScript-code die gebruikmaakt van deze bindingen.

Dit is het function.json-bestand voor daprServiceInvocationTrigger:

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

Zie de sectie Configuratie voor meer informatie over function.json bestandseigenschappen.

Dit is de JavaScript-code:

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

In de volgende voorbeelden ziet u Dapr-triggers in een function.json-bestand en PowerShell-code die gebruikmaakt van deze bindingen.

Dit is het function.json-bestand voor daprServiceInvocationTrigger:

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

Zie de sectie Configuratie voor meer informatie over function.json bestandseigenschappen.

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

In het volgende voorbeeld ziet u een Aanroeptrigger voor dapr-service, die gebruikmaakt van het python-programmeermodel v2. Ga als volgt te werk om de code van uw daprServiceInvocationTrigger Python-functie-app te gebruiken:

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

In het volgende voorbeeld ziet u een Aanroeptrigger voor dapr-service, die gebruikmaakt van het python-programmeermodel v1.

Dit is het function.json-bestand voor daprServiceInvocationTrigger:

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

Zie de sectie Configuratie voor meer informatie over function.json bestandseigenschappen.

Dit is de 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)

Kenmerken

In-proces

Gebruik in het procesmodel de DaprServiceInvocationTrigger opdracht om een Aanroepbinding van de Dapr-service te activeren, die de volgende eigenschappen ondersteunt.

Parameter	Description
MethodName	Optioneel. De naam van de methode die de Dapr-aanroeper moet gebruiken. Als deze niet is opgegeven, wordt de naam van de functie gebruikt als de naam van de methode.

Geïsoleerd proces

Gebruik in het geïsoleerde werkrolmodel de trigger voor het DaprServiceInvocationTrigger definiëren van een aanroeptrigger van de Dapr-service, die ondersteuning biedt voor deze parameters:

Parameter	Description
MethodName	Optioneel. De naam van de methode die de Dapr-aanroeper moet gebruiken. Als deze niet is opgegeven, wordt de naam van de functie gebruikt als de naam van de methode.

Aantekeningen

Met de DaprServiceInvocationTrigger aantekening kunt u een functie maken die wordt aangeroepen door dapr-runtime.

Element	Beschrijving
methodName	De naam van de methode.

Configuratie

Node.js v4

In de volgende tabel worden de bindingsconfiguratie-eigenschappen uitgelegd die u in de code hebt ingesteld.

Eigenschappen	Beschrijving
type	Moet worden ingesteld op daprServiceInvocationTrigger.
name	De naam van de variabele die de Dapr-gegevens in functiecode vertegenwoordigt.

Node.js v3

In de volgende tabel worden de bindingsconfiguratie-eigenschappen uitgelegd die u in het function.json-bestand hebt ingesteld.

function.json-eigenschap	Beschrijving
type	Moet worden ingesteld op daprServiceInvocationTrigger.
name	De naam van de variabele die de Dapr-gegevens in functiecode vertegenwoordigt.

In de volgende tabel worden de bindingsconfiguratie-eigenschappen uitgelegd die u in het function.json-bestand hebt ingesteld.

function.json-eigenschap	Beschrijving
type	Moet worden ingesteld op daprServiceInvocationTrigger.
name	De naam van de variabele die de Dapr-gegevens in functiecode vertegenwoordigt.

Python v2

In de volgende tabel worden de bindingsconfiguratie-eigenschappen @dapp.dapr_service_invocation_trigger uitgelegd die u in uw Python-code hebt ingesteld.

Eigenschappen	Beschrijving
method_name	De naam van de variabele die de Dapr-gegevens vertegenwoordigt.

Python v1

In de volgende tabel worden de bindingsconfiguratie-eigenschappen uitgelegd die u in het function.json-bestand hebt ingesteld.

function.json-eigenschap	Beschrijving
type	Moet worden ingesteld op daprServiceInvocationTrigger.
name	De naam van de variabele die de Dapr-gegevens in functiecode vertegenwoordigt.

Zie de sectie Voorbeeld voor volledige voorbeelden.

Gebruik

Als u een Aanroeptrigger voor dapr-services wilt gebruiken, leest u welke onderdelen u wilt gebruiken met de aanroeptrigger voor de service en hoe u deze instelt in de officiële Dapr-documentatie.

• Specificaties van dapr-onderdelen
• Aanroep van dapr-service

Python v2

Als u het daprServiceInvocationTrigger project in Python v2 wilt gebruiken, stelt u uw project in met de juiste afhankelijkheden.

1. Een virtuele omgeving maken en activeren.

2. Voeg in het requirements.text bestand de volgende regel toe:

   azure-functions==1.18.0b3
   

3. Installeer de Python-bibliotheek in de terminal.

   pip install -r .\requirements.txt
   

4. Wijzig uw local.setting.json bestand met de volgende configuratie:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Python v1

Voor het Python v1-model zijn geen aanvullende wijzigingen vereist, afgezien van het instellen van het aanroeponderdeel van de service.

Volgende stappen

Meer informatie over aanroepen van dapr-services.