Share via

Azure Functions에 대한 Dapr 게시 출력 바인딩

  • 아티클

Dapr 게시 출력 바인딩을 사용하면 함수 실행 중에 Dapr 항목에 메시지를 게시할 수 있습니다.

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

예시

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

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

다음 예에서는 Dapr 게시 출력 바인딩을 사용하여 게시/구독 구성 요소 및 항목에 대한 Dapr 게시 작업을 수행하는 방법을 보여 줍니다.

[FunctionName("PublishOutputBinding")]
public static void Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "topic/{topicName}")] HttpRequest req,
    [DaprPublish(PubSubName = "%PubSubName%", Topic = "{topicName}")] out DaprPubSubEvent pubSubEvent,
    ILogger log)
{
    string requestBody = new StreamReader(req.Body).ReadToEnd();
    pubSubEvent = new DaprPubSubEvent(requestBody);
}

다음 예에서는 DaprTopicTrigger와 함께 DaprPublishOutput 바인딩을 사용하여 "TransferEventBetweenTopics" 함수를 만듭니다.

@FunctionName("TransferEventBetweenTopics")
public String run(
        @DaprTopicTrigger(
            pubSubName = "%PubSubName%",
            topic = "A")
            String request,
        @DaprPublishOutput(
            pubSubName = "%PubSubName%",
            topic = "B")
        OutputBinding<String> payload,
        final ExecutionContext context) throws JsonProcessingException {
    context.getLogger().info("Java function processed a TransferEventBetweenTopics request from the Dapr Runtime.");
}

다음 예에서 Dapr 게시 출력 바인딩은 app 개체에 의해 등록된 HTTP 트리거와 쌍을 이룹니다.

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

app.generic('PublishOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "topic/{topicName}",
        name: "req"
    }),
    return: daprPublishOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");
        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { payload: payload };
    }
});

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

다음은 daprPublish에 대한 function.json 파일입니다.

{
  "bindings": 
    {
      "type": "daprPublish",
      "direction": "out",
      "name": "pubEvent",
      "pubsubname": "%PubSubName%",
      "topic": "B"
    }
}

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

# Example to use Dapr Service Invocation Trigger and Dapr State Output binding to persist a new state into statestore
param (
    $subEvent
)

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

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $subEvent["data"]

$messageFromTopicA = "Transfer from Topic A: $jsonString".Trim()

$publish_output_binding_req_body = @{
    "payload" = $messageFromTopicA
}

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

다음 예에서는 v2 Python 프로그래밍 모델을 사용하는 Dapr 게시 출력 바인딩을 보여 줍니다. Python 함수 앱 코드에서 daprPublish를 사용하려면 다음 안내를 따릅니다.

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="TransferEventBetweenTopics")
@app.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="A", route="A")
@app.dapr_publish_output(arg_name="pubEvent", pub_sub_name="%PubSubName%", topic="B")
def main(subEvent, pubEvent: func.Out[bytes]) -> None:
    logging.info('Python function processed a TransferEventBetweenTopics request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    payload = "Transfer from Topic A: " + str(subEvent_json["data"])
    pubEvent.set(json.dumps({"payload": payload}).encode('utf-8'))

특성

In Process 모델에서 DaprPublish를 사용하여 다음 매개 변수를 지원하는 Dapr 게시 출력 바인딩을 정의합니다.

function.json 속성 설명 특성을 통해 전송 가능 RequestBody를 통해 전송 가능
PubSubName 메시지를 보낼 Dapr pub/sub의 이름입니다. ✔️ ✔️
항목 메시지를 보낼 Dapr 항목의 이름입니다. ✔️ ✔️
페이로드 필수입니다. 게시되는 메시지입니다. ❌ ✔️

주석

DaprPublishOutput 주석을 사용하면 함수가 게시된 메시지에 액세스할 수 있습니다.

요소 설명 특성을 통해 전송 가능 RequestBody를 통해 전송 가능
pubSubName 메시지를 보낼 Dapr pub/sub의 이름입니다. ✔️ ✔️
topic 메시지를 보낼 Dapr 항목의 이름입니다. ✔️ ✔️
payload 필수입니다. 게시되는 메시지입니다. ❌ ✔️

구성

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

속성 설명 특성을 통해 전송 가능 RequestBody를 통해 전송 가능
pubsubname 게시자 구성 요소 서비스의 이름입니다. ✔️ ✔️
topic 게시자 항목의 이름/식별자입니다. ✔️ ✔️
payload 필수입니다. 게시되는 메시지입니다. ❌ ✔️

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

function.json 속성 설명 특성을 통해 전송 가능 RequestBody를 통해 전송 가능
pubsubname 게시자 구성 요소 서비스의 이름입니다. ✔️ ✔️
topic 게시자 항목의 이름/식별자입니다. ✔️ ✔️
payload 필수입니다. 게시되는 메시지입니다. ❌ ✔️

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

속성 설명 특성을 통해 전송 가능 RequestBody를 통해 전송 가능
pub_sub_name 게시자 이벤트의 이름입니다. ✔️ ✔️
topic 게시자 항목 이름/식별자입니다. ✔️ ✔️
payload 필수입니다. 게시되는 메시지입니다. ❌ ✔️

속성이 특성과 RequestBody 둘 다에 정의된 경우 RequestBody에 제공된 데이터에 우선 순위가 부여됩니다.

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

사용

Dapr 게시 출력 바인딩을 사용하려면 먼저 Dapr 게시/구독 구성 요소를 설정합니다. 공식 Dapr 설명서에서 사용할 구성 요소와 설정 방법에 대해 자세히 알아볼 수 있습니다.

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

  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 게시 및 구독에 대해 자세히 알아봅니다.