Azure Functions에 대한 Dapr 입력 바인딩 트리거

Important

Azure Functions용 Dapr 확장은 현재 미리 보기로 제공되며 Azure Container Apps 환경에서만 지원됩니다.

Azure Functions는 다음 Dapr 이벤트를 사용하여 Dapr 입력 바인딩에서 트리거할 수 있습니다.

Dapr 확장의 설정 및 구성 세부 정보에 대한 자세한 내용은 Dapr 확장 개요를 참조하세요.

예시

C# 함수는 다음 C# 모드 중 하나를 사용하여 만들 수 있습니다.

실행 모델	설명
격리된 작업자 모델	함수 코드는 별도의 .NET 작업자 프로세스에서 실행됩니다. 지원되는 .NET 및 .NET Framework 버전과 함께 사용합니다. 자세한 내용은 .NET 격리 작업자 프로세스 함수 개발을 참조하세요.
In Process 모델	함수 코드는 Functions 호스트 프로세스와 동일한 프로세스에서 실행됩니다. .NET의 LTS(장기 지원) 버전만 지원합니다. 자세한 내용은 .NET 클래스 라이브러리 함수 개발을 참조하세요.

In-process

[FunctionName("ConsumeMessageFromKafka")]
public static void Run(
    // Note: the value of BindingName must match the binding name in components/kafka-bindings.yaml
    [DaprBindingTrigger(BindingName = "%KafkaBindingName%")] JObject triggerData,
    ILogger log)
{
    log.LogInformation("Hello from Kafka!");
    log.LogInformation($"Trigger data: {triggerData}");
}

격리된 프로세스

[Function("ConsumeMessageFromKafka")]
public static void Run(
    // Note: the value of BindingName must match the binding name in components/kafka-bindings.yaml
    [DaprBindingTrigger(BindingName = "%KafkaBindingName%")] JsonElement triggerData,
    FunctionContext functionContext)
{
    var log = functionContext.GetLogger("ConsumeMessageFromKafka");

    log.LogInformation("Hello from Kafka!");

    log.LogInformation($"Trigger data: {triggerData}");
}

Dapr 입력 바인딩 트리거에 대한 Java 코드는 다음과 같습니다.

@FunctionName("ConsumeMessageFromKafka")
public String run(
        @DaprBindingTrigger(
            bindingName = "%KafkaBindingName%")
)

Node.js v4

개체를 사용하여 다음을 app 등록합니다 daprBindingTrigger.

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

app.generic('ConsumeMessageFromKafka', {
    trigger: trigger.generic({
        type: 'daprBindingTrigger',
        bindingName: "%KafkaBindingName%",
        name: "triggerData"
    }),
    handler: async (request, context) => {
        context.log("Node function processed a ConsumeMessageFromKafka request from the Dapr Runtime.");
        context.log(context.triggerMetadata.triggerData)
    }
});

Node.js v3

다음 예제에서는 function.json 파일의 Dapr 트리거와 해당 바인딩을 사용하는 JavaScript 코드를 보여 줍니다.

다음의 function.json 파일은 다음과 같습니다.daprBindingTrigger

{
  "bindings": [
    {
      "type": "daprBindingTrigger",
      "bindingName": "%KafkaBindingName%",
      "name": "triggerData"
    }
  ]
}

function.json 파일 속성에 대한 자세한 내용은 구성 섹션을 참조하세요.

JavaScript 코드는 다음과 같습니다.

module.exports = async function (context) {
    context.log("Hello from Kafka!");

    context.log(`Trigger data: ${context.bindings.triggerData}`);
};

다음 예제에서는 function.json 파일의 Dapr 트리거와 해당 바인딩을 사용하는 PowerShell 코드를 보여 줍니다.

다음의 function.json 파일은 다음과 같습니다.daprBindingTrigger

{
  "bindings": [
    {
      "type": "daprBindingTrigger",
      "bindingName": "%KafkaBindingName%",
      "name": "triggerData",
      "direction": "in"
    }
  ]
}

function.json 파일 속성에 대한 자세한 내용은 구성 섹션을 참조하세요.

코드

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 (
    $triggerData
)

Write-Host "PowerShell function processed a ConsumeMessageFromKafka request from the Dapr Runtime."

$jsonString = $triggerData | ConvertTo-Json

Write-Host "Trigger data: $jsonString"

Python v2

다음 예제에서는 v2 Python 프로그래밍 모델을 사용하는 Dapr 입력 바인딩 트리거를 보여줍니다. Python 함수 앱 코드에서 사용하려면 다음을 daprBinding 수행합니다.

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="ConsumeMessageFromKafka")
@app.dapr_binding_trigger(arg_name="triggerData", binding_name="%KafkaBindingName%")
def main(triggerData: str) -> None:
    logging.info('Python function processed a ConsumeMessageFromKafka request from the Dapr Runtime.')
    logging.info('Trigger data: ' + triggerData)

Python v1

다음 예제에서는 v1 Python 프로그래밍 모델을 사용하는 Dapr 입력 바인딩 트리거를 보여줍니다.

다음의 function.json 파일은 다음과 같습니다.daprBindingTrigger

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "daprBindingTrigger",
      "bindingName": "sample-topic",
      "name": "triggerData",
      "direction": "in"
    }
  ]
}

function.json 파일 속성에 대한 자세한 내용은 구성 섹션을 참조하세요.

Python 코드는 다음과 같습니다.

import logging
import json
import azure.functions as func

def main(triggerData: str) -> None:
    logging.info('Hello from Kafka!')
    logging.info('Trigger data: ' + triggerData)

특성

In-process

In-process 모델에서 다음 속성을 지원하는 Dapr 입력 바인딩을 트리거하는 데 사용합니다DaprBindingTrigger.

매개 변수	설명
BindingName	Dapr 트리거의 이름입니다. 지정하지 않으면 함수 이름이 트리거 이름으로 사용됩니다.

격리된 프로세스

격리된 작업자 모델DaprBindingTrigger에서 다음 매개 변수를 지원하는 Dapr 바인딩 트리거를 정의합니다.

매개 변수	설명
BindingName	Dapr 트리거의 이름입니다. 지정하지 않으면 함수 이름이 트리거 이름으로 사용됩니다.

주석

주석 DaprBindingTrigger 을 사용하면 만든 바인딩 구성 요소에 의해 트리거되는 함수를 만들 수 있습니다.

요소	설명
bindingName	Dapr 바인딩의 이름입니다.

구성

Node.js v4

다음 표에서는 코드에서 설정한 바인딩 구성 속성에 대해 설명합니다.

속성	설명
bindingName	바인딩 이름입니다.

Node.js v3

다음 표에서는 function.json 파일에 설정한 바인딩 구성 속성에 대해 설명합니다.

function.json 속성	설명
bindingName	바인딩 이름입니다.

다음 표에서는 function.json 파일에 설정한 바인딩 구성 속성에 대해 설명합니다.

function.json 속성	설명
bindingName	바인딩 이름입니다.

Python v2

다음 표에서는 Python 코드에서 설정한 바인딩 구성 속성에 대해 @dapp.dapr_binding_trigger 설명합니다.

속성	설명
binding_name	바인딩 이름입니다.

Python v1

다음 표에서는 function.json 파일에 설정한 바인딩 구성 속성에 대해 설명합니다.

function.json 속성	설명
bindingName	바인딩 이름입니다.

전체 예제는 예제 섹션을 참조하세요.

사용

Dapr 입력 바인딩 트리거를 사용하려면 먼저 Dapr 입력 바인딩 구성 요소를 설정합니다. 사용할 구성 요소 및 공식 Dapr 설명서에서 설정하는 방법에 대해 자세히 알아볼 수 있습니다.

• Dapr 입력 바인딩 구성 요소 사양
• 방법: 입력 바인딩을 사용하여 애플리케이션 트리거

Python v2

Python v2에서 사용 daprBindingTrigger 하려면 올바른 종속성을 사용하여 프로젝트를 설정합니다.

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
   

Python v1

Python v1 모델은 바인딩 구성 요소를 설정하는 것 외에 추가 변경이 필요하지 않습니다.

다음 단계

Dapr 서비스 호출에 대해 자세히 알아봅니다.