Sdílet prostřednictvím

Výstupní vazba dapr pro Azure Functions

  • Článek

Výstupní vazba Dapr umožňuje odeslat hodnotu výstupní vazbě Dapr během provádění funkce.

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

Příklad

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

Model spouštění Popis
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 tématu Vývoj funkcí izolovaného pracovního procesu .NET.
Model v procesu 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 .NET.

Následující příklad ukazuje použití triggeru volání služby Dapr a výstupní vazby Dapr ke čtení a zpracování žádosti o vazbu.

[FunctionName("SendMessageToKafka")]
public static async Task Run(
    [DaprServiceInvocationTrigger] JObject payload,
    [DaprBinding(BindingName = "%KafkaBindingName%", Operation = "create")] IAsyncCollector<object> messages,
    ILogger log)
{
    log.LogInformation("C#  function processed a SendMessageToKafka request.");
    await messages.AddAsync(payload);
}

Následující příklad vytvoří "SendMessageToKafka" funkci pomocí vazby DaprBindingOutput s DaprServiceInvocationTrigger:

@FunctionName("SendMessageToKafka")
public String run(
        @DaprServiceInvocationTrigger(
            methodName = "SendMessageToKafka") 
        String payload,
        @DaprBindingOutput(
            bindingName = "%KafkaBindingName%", 
            operation = "create")
        OutputBinding<String> product,
        final ExecutionContext context) {
    context.getLogger().info("Java  function processed a SendMessageToKafka request.");
    product.setValue(payload);

    return payload;
}

V následujícím příkladu se výstupní vazba Dapr spáruje s aktivační událostí volání Dapr, která je zaregistrována objektem app :

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

app.generic('SendMessageToKafka', {
    trigger: trigger.generic({
        type: 'daprServiceInvocationTrigger',
        name: "payload"
    }),
    return: daprBindingOutput,
    handler: async (request, context) => {
        context.log("Node function processed a SendMessageToKafka request from the Dapr Runtime.");
        context.log(context.triggerMetadata.payload)

        return { "data": context.triggerMetadata.payload };
    }
});

Následující příklady ukazují triggery Dapr v souboru function.json a kódu PowerShellu, který tyto vazby používá.

Tady je soubor function.json pro daprBinding:

{
  "bindings": 
    {
      "type": "daprBinding",
      "direction": "out",
      "bindingName": "%KafkaBindingName%",
      "operation": "create",
      "name": "messages"
    }
}

Další informace o function.json vlastnosti souboru naleznete v části Konfigurace .

V kódu:

using namespace System.Net

# Input bindings are passed in via param block.
param($req, $TriggerMetadata)

Write-Host "Powershell SendMessageToKafka processed a request."

$invoke_output_binding_req_body = @{
    "data" = $req
}

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name messages -Value $invoke_output_binding_req_body

Následující příklad ukazuje výstupní vazbu Dapr Binding, která používá programovací model Pythonu v2. @dapp.dapr_binding_output Použití v kódu aplikace funkcí Pythonu:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="SendMessageToKafka")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="SendMessageToKafka")
@app.dapr_binding_output(arg_name="messages", binding_name="%KafkaBindingName%", operation="create")
def main(payload: str, messages: func.Out[bytes]) -> None:
    logging.info('Python processed a SendMessageToKafka request from the Dapr Runtime.')
    messages.set(json.dumps({"data": payload}).encode('utf-8'))

Atributy

V modelu v procesu použijte DaprBinding k definování výstupní vazby Dapr vazby, která podporuje tyto parametry:

Parametr Popis Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
BindingName Název vazby Dapr. ✔️ ✔️
Operace Nakonfigurovaná operace vazby. ✔️ ✔️
Metadata Obor názvů metadat. ❌ ✔️
Data Povinný: Data pro operaci vazby. ❌ ✔️

Poznámky

Poznámka DaprBindingOutput umožňuje vytvořit funkci, která odesílá výstupní vazbu.

Element (Prvek) Popis Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
bindingName Název vazby Dapr. ✔️ ✔️
výstup Nakonfigurovaná operace vazby. ✔️ ✔️
metadata Obor názvů metadat. ❌ ✔️
data Povinný: Data pro operaci vazby. ❌ ✔️

Konfigurace

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

Vlastnost Popis Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
bindingName Název vazby. ✔️ ✔️
operace Operace vazby. ✔️ ✔️
metadata Obor názvů metadat. ❌ ✔️
data Povinný: Data pro operaci vazby. ❌ ✔️

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

vlastnost function.json Popis Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
bindingName Název vazby. ✔️ ✔️
operace Operace vazby. ✔️ ✔️
metadata Obor názvů metadat. ❌ ✔️
data Povinný: Data pro operaci vazby. ❌ ✔️

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

Vlastnost Popis Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
binding_name Název události vazby. ✔️ ✔️
operace Název nebo identifikátor operace vazby. ✔️ ✔️
metadata Obor názvů metadat. ❌ ✔️
data Povinný: Data pro operaci vazby. ❌ ✔️

Pokud jsou vlastnosti definovány v atributech a RequestBody, priorita je udělena datům zadaným v RequestBody.

Kompletní příklady najdete v části Příklad.

Využití

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

Pokud chcete použít python daprBinding 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

Další kroky

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