Sdílet prostřednictvím

Výstupní vazba dapr pro Azure Functions

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.

Example

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

Execution model Description
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 Příručce pro spouštění funkcí Azure Functions jazyka C# v izolovaném pracovním modelu.
In-process model 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 jazyka C# pomocí Azure Functions.

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

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 daprBinding:

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

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

In code:

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'))

Attributes

In the in-process model, use the DaprBinding to define a Dapr binding output binding, which supports these parameters:

Parameter Description Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
BindingName Název vazby Dapr. ✔️ ✔️
Operation Nakonfigurovaná operace vazby. ✔️ ✔️
Metadata Obor názvů metadat. ❌ ✔️
Data Required. Data pro operaci vazby. ❌ ✔️

Annotations

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

Element Description Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
bindingName Název vazby Dapr. ✔️ ✔️
output Nakonfigurovaná operace vazby. ✔️ ✔️
metadata Obor názvů metadat. ❌ ✔️
data Required. Data pro operaci vazby. ❌ ✔️

Configuration

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

Property Description Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
bindingName Název vazby. ✔️ ✔️
operation Operace vazby. ✔️ ✔️
metadata Obor názvů metadat. ❌ ✔️
data Required. Data pro operaci vazby. ❌ ✔️

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

function.json property Description Lze odeslat prostřednictvím atributu. Lze odeslat přes RequestBody.
bindingName Název vazby. ✔️ ✔️
operation Operace vazby. ✔️ ✔️
metadata Obor názvů metadat. ❌ ✔️
data Required. Data pro operaci vazby. ❌ ✔️

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

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

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

See the Example section for complete examples.

Usage

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

Next steps

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

  • Last updated on