Partilhar via

Vinculação de saída de Dapr para o Azure Functions

  • Artigo

A ligação de saída Dapr permite enviar um valor para uma ligação de saída Dapr durante a execução de uma função.

Para obter informações sobre detalhes de instalação e configuração da extensão Dapr, consulte a visão geral da extensão Dapr.

Exemplo

Uma função C# pode ser criada usando um dos seguintes modos C#:

Modelo de execução Description
Modelo de trabalhador isolado Seu código de função é executado em um processo de trabalho .NET separado. Use com versões suportadas do .NET e .NET Framework. Para saber mais, consulte Desenvolver funções de processo de trabalho isoladas do .NET.
Modelo em processo Seu código de função é executado no mesmo processo que o processo de host de funções. Suporta apenas versões LTS (Long Term Support) do .NET. Para saber mais, consulte Desenvolver funções de biblioteca de classes .NET.

O exemplo a seguir demonstra o uso de um gatilho de invocação de serviço Dapr e uma ligação de saída Dapr para ler e processar uma solicitação de vinculação.

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

O exemplo a seguir cria uma "SendMessageToKafka" função usando a DaprBindingOutput associação com o 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;
}

No exemplo a seguir, a ligação de saída Dapr é emparelhada com o gatilho de saída de invocação Dapr, que é registrado pelo app objeto:

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

Os exemplos a seguir mostram gatilhos Dapr em um arquivo function.json e código PowerShell que usa essas associações.

Aqui está o arquivo function.json para daprBinding:

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

Para obter mais informações sobre function.json propriedades do arquivo, consulte a seção Configuração .

No código:

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

O exemplo a seguir mostra uma ligação de saída Dapr Binding, que usa o modelo de programação Python v2. Para usar @dapp.dapr_binding_output no código do aplicativo de função Python:

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

Atributos

No modelo em processo, use o DaprBinding para definir uma ligação de saída de ligação Dapr, que suporta estes parâmetros:

Parâmetro Description Pode ser enviado via Atributo Pode ser enviado via RequestBody
BindingName O nome da ligação Dapr. ✔️ ✔️
Operação A operação de vinculação configurada. ✔️ ✔️
Metadados O namespace de metadados. ❌ ✔️
Dados Obrigatório. Os dados para a operação de vinculação. ❌ ✔️

Anotações

A DaprBindingOutput anotação permite criar uma função que envia uma ligação de saída.

Elemento Description Pode ser enviado via Atributo Pode ser enviado via RequestBody
bindingName O nome da ligação Dapr. ✔️ ✔️
Saída A operação de vinculação configurada. ✔️ ✔️
metadados O namespace de metadados. ❌ ✔️
data Obrigatório. Os dados para a operação de vinculação. ❌ ✔️

Configuração

A tabela a seguir explica as propriedades de configuração de vinculação definidas no código.

Property Description Pode ser enviado via Atributo Pode ser enviado via RequestBody
bindingName O nome da ligação. ✔️ ✔️
Funcionamento A operação de vinculação. ✔️ ✔️
metadados O namespace de metadados. ❌ ✔️
data Obrigatório. Os dados para a operação de vinculação. ❌ ✔️

A tabela a seguir explica as propriedades de configuração de vinculação definidas no arquivo function.json.

function.json propriedade Description Pode ser enviado via Atributo Pode ser enviado via RequestBody
bindingName O nome da ligação. ✔️ ✔️
Funcionamento A operação de vinculação. ✔️ ✔️
metadados O namespace de metadados. ❌ ✔️
data Obrigatório. Os dados para a operação de vinculação. ❌ ✔️

A tabela a seguir explica as propriedades de configuração de vinculação definidas @dapp.dapr_binding_output no código Python.

Property Description Pode ser enviado via Atributo Pode ser enviado via RequestBody
binding_name O nome do evento de vinculação. ✔️ ✔️
Funcionamento O nome/identificador da operação de vinculação. ✔️ ✔️
metadados O namespace de metadados. ❌ ✔️
data Obrigatório. Os dados para a operação de vinculação. ❌ ✔️

Se as propriedades forem definidas em Atributos e RequestBody, será dada prioridade aos dados fornecidos em RequestBody.

Consulte a seção Exemplo para obter exemplos completos.

Utilização

Para usar a ligação de saída Dapr, comece configurando um componente de vinculação de saída Dapr. Você pode saber mais sobre qual componente usar e como configurá-lo na documentação oficial do Dapr.

Para usar o daprBinding em Python v2, configure seu projeto com as dependências corretas.

  1. Crie e ative um ambiente virtual.

  2. No ficheiro requirements.text , adicione a seguinte linha:

    azure-functions==1.18.0b3

  3. No terminal, instale a biblioteca Python.

    pip install -r .\requirements.txt

  4. Modifique seu local.setting.json arquivo com a seguinte configuração:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Próximos passos

Saiba mais sobre a invocação do serviço Dapr.