Поделиться через

Выходная привязка привязки Dapr для Функции Azure

  • Статья

Выходная привязка Dapr позволяет отправлять значение в выходную привязку Dapr во время выполнения функции.

Сведения о настройке и настройке расширения Dapr см. в обзоре расширения Dapr.

Пример

Функцию C# можно создать с помощью одного из следующих режимов C#:

Модель выполнения Description
Изолированная рабочая модель Код функции выполняется в отдельном рабочем процессе .NET. Используйте поддерживаемые версии .NET и платформа .NET Framework. Дополнительные сведения см. в статье "Разработка изолированных рабочих процессов .NET".
Модель внутрипроцессного процесса Код функции выполняется в том же процессе, что и хост-процесс Функций. Поддерживает только долгосрочные версии .NET. Дополнительные сведения см. в статье "Разработка функций библиотеки классов .NET".

В следующем примере показано использование триггера вызова службы Dapr и выходной привязки Dapr для чтения и обработки запроса привязки.

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

В следующем примере создается "SendMessagetoKafka" функция с помощью привязки DaprBindingOutput с 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;
}

В следующем примере выходная привязка Dapr связана с триггером выходных данных Dapr, зарегистрированным app объектом:

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

app.generic('SendMessageToKafka', {
    trigger: trigger.generic({
        type: 'daprServiceInvocationTrigger',
        name: "payload"
    }),
    return: daprBindingOuput,
    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 };
    }
});

В следующих примерах показаны триггеры Dapr в файле function.json и коде PowerShell, использующем эти привязки.

Ниже приведен файл function.json для daprBinding:

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

Дополнительные сведения о свойствах файла function.json см. в разделе "Конфигурация ".

В коде:

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

В следующем примере показана выходная привязка Dapr, которая использует модель программирования Python версии 2. Чтобы использовать код приложения-функции Python, выполните следующие действия @dapp.dapr_binding_output .

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

Атрибуты

В модели в процессе используйте DaprBinding выходную привязку Dapr, которая поддерживает следующие параметры:

Параметр Описание Можно отправлять с помощью атрибута Может отправляться через RequestBody
BindingName Имя привязки Dapr. ✔️ ✔️
Операция Настроенная операция привязки. ✔️ ✔️
Метаданные Пространство имен метаданных. ❌ ✔️
Данные Обязательный. Данные для операции привязки. ❌ ✔️

Заметки

Заметка DaprBindingOutput позволяет создать функцию, которая отправляет выходную привязку.

Элемент Description Можно отправлять с помощью атрибута Может отправляться через RequestBody
bindingName Имя привязки Dapr. ✔️ ✔️
выходные данные Настроенная операция привязки. ✔️ ✔️
metadata Пространство имен метаданных. ❌ ✔️
data Обязательный. Данные для операции привязки. ❌ ✔️

Настройка

В следующей таблице описываются свойства конфигурации привязки, заданные в коде.

Свойство Description Можно отправлять с помощью атрибута Может отправляться через RequestBody
bindingName Имя привязки. ✔️ ✔️
operation Операция привязки. ✔️ ✔️
metadata Пространство имен метаданных. ❌ ✔️
data Обязательный. Данные для операции привязки. ❌ ✔️

В следующей таблице описываются свойства конфигурации привязки, которые задаются в файле function.json.

Свойство в function.json Description Можно отправлять с помощью атрибута Может отправляться через RequestBody
bindingName Имя привязки. ✔️ ✔️
operation Операция привязки. ✔️ ✔️
metadata Пространство имен метаданных. ❌ ✔️
data Обязательный. Данные для операции привязки. ❌ ✔️

В следующей таблице описываются свойства конфигурации привязки, заданные @dapp.dapr_binding_output в коде Python.

Свойство Description Можно отправлять с помощью атрибута Может отправляться через RequestBody
binding_name Имя события привязки. ✔️ ✔️
operation Имя или идентификатор операции привязки. ✔️ ✔️
metadata Пространство имен метаданных. ❌ ✔️
data Обязательный. Данные для операции привязки. ❌ ✔️

Если свойства определены как в атрибутах, так и RequestBodyприоритет присваивается данным, предоставленным в RequestBody.

Подробные примеры см. в разделе Примеры.

Использование

Чтобы использовать выходную привязку Dapr, начните с настройки компонента выходной привязки Dapr. Дополнительные сведения о том, какой компонент следует использовать и как настроить его в официальной документации dapr.

Чтобы использовать daprBinding Python версии 2, настройте проект с правильными зависимостями.

  1. Создание и активация виртуальной среды.

  2. requirements.text В файле добавьте следующую строку:

    azure-functions==1.18.0b3

  3. В терминале установите библиотеку Python.

    pip install -r .\requirements.txt

  4. Измените local.setting.json файл со следующей конфигурацией:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Следующие шаги

Дополнительные сведения о вызове службы Dapr.