Trigger di chiamata al servizio Dapr per Funzioni di Azure

Funzioni di Azure può essere attivato in una chiamata al servizio Dapr usando gli eventi Dapr seguenti.

Per informazioni sull'installazione e sulla configurazione dell'estensione Dapr, vedere panoramica dell'estensione Dapr.

Example

È possibile creare una funzione C# usando una delle modalità C# seguenti:

Execution model	Description
Modello di lavoro isolato	Il codice della funzione viene eseguito in un processo di lavoro .NET separato. Usare con le versioni supportate di .NET e .NET Framework. Per altre informazioni, vedere Guida per l'esecuzione di Funzioni di Azure C# nel modello di lavoro isolato.
In-process model	Il codice della funzione viene eseguito nello stesso processo del processo host di Funzioni. Supporta solo versioni LTS (Long Term Support) di .NET. Per altre informazioni, vedere Sviluppare funzioni della libreria di classi C# usando Funzioni di Azure.

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

Ecco il codice Java per il trigger di chiamata al servizio Dapr:

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

Node.js v4

Usare l'oggetto app per registrare :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 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.

Ecco il codice 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);
};

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

L'esempio seguente illustra un trigger di chiamata al servizio Dapr, che usa il modello di programmazione Python v2. Per usare nel codice dell'app per le daprServiceInvocationTrigger funzioni 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

L'esempio seguente illustra un trigger di chiamata al servizio Dapr, che usa il modello di programmazione Python v1.

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.

Ecco il codice 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)

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. Nome del metodo che deve essere usato dal chiamante Dapr. Se non specificato, il nome della funzione viene usato come nome del metodo.

Isolated process

Nel modello di lavoro isolato usare DaprServiceInvocationTrigger per definire un trigger di chiamata al servizio Dapr, che supporta questi parametri:

Parameter	Description
MethodName	Optional. Nome del metodo che deve essere usato dal chiamante Dapr. Se non specificato, il nome della funzione viene usato come nome del metodo.

Annotations

L'annotazione DaprServiceInvocationTrigger consente di creare una funzione che viene richiamata dal runtime dapr.

Element	Description
methodName	Nome del metodo.

Configuration

Node.js v4

Nella tabella seguente vengono illustrate le proprietà di configurazione dell'associazione impostate nel codice.

Property	Description
type	Deve essere impostato su daprServiceInvocationTrigger.
name	Nome della variabile che rappresenta i dati dapr nel codice della funzione.

Node.js v3

Nella tabella seguente sono illustrate le proprietà di configurazione dell'associazione impostate nel file function.json.

function.json property	Description
type	Deve essere impostato su daprServiceInvocationTrigger.
name	Nome della variabile che rappresenta i dati dapr nel codice della funzione.

Nella tabella seguente sono illustrate le proprietà di configurazione dell'associazione impostate nel file function.json.

function.json property	Description
type	Deve essere impostato su daprServiceInvocationTrigger.
name	Nome della variabile che rappresenta i dati dapr nel codice della funzione.

Python v2

La tabella seguente illustra le proprietà di configurazione dell'associazione per @dapp.dapr_service_invocation_trigger impostate nel codice Python.

Property	Description
method_name	Nome della variabile che rappresenta i dati dapr.

Python v1

Nella tabella seguente sono illustrate le proprietà di configurazione dell'associazione impostate nel file function.json.

function.json property	Description
type	Deve essere impostato su daprServiceInvocationTrigger.
name	Nome della variabile che rappresenta i dati dapr nel codice della funzione.

See the Example section for complete examples.

Usage

Per usare un trigger di chiamata al servizio Dapr, vedere altre informazioni sui componenti da usare con il trigger di chiamata al servizio e su come configurarli nella documentazione ufficiale di Dapr.

• Specifiche del componente Dapr
• Chiamata al servizio Dapr

Python v2

Per usare daprServiceInvocationTrigger in Python v2, configurare il progetto con le dipendenze corrette.

1. Creare e attivare un ambiente virtuale.

2. Nel file requirements.text aggiungere la riga seguente:

   azure-functions==1.18.0b3
   

3. Nel terminale installare la libreria Python.

   pip install -r .\requirements.txt
   

4. Modificare il file local.setting.json con la configurazione seguente:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Python v1

Il modello Python v1 non richiede modifiche aggiuntive, a parte la configurazione del componente di chiamata al servizio.

Next steps

Altre informazioni sulla chiamata al servizio Dapr.