Share via

Azure Functions에 대한 Dapr Invoke 출력 바인딩

  • 아티클

Important

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

Dapr 호출 출력 바인딩을 사용하면 함수 실행 중에 다른 Dapr 애플리케이션을 호출할 수 있습니다.

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

예시

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

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

다음 예제에서는 Dapr 호출 출력 바인딩을 사용하여 다른 Dapr 크기 애플리케이션에서 호스트되는 Dapr 서비스 호출 작업을 수행하는 방법을 보여 줍니다. 이 예제에서 함수는 프록시처럼 작동합니다.

[FunctionName("InvokeOutputBinding")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", Route = "invoke/{appId}/{methodName}")] HttpRequest req,
    [DaprInvoke(AppId = "{appId}", MethodName = "{methodName}", HttpVerb = "post")] IAsyncCollector<InvokeMethodParameters> output,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

    string requestBody = await new StreamReader(req.Body).ReadToEndAsync();

    var outputContent = new InvokeMethodParameters
    {
        Body = requestBody
    };

    await output.AddAsync(outputContent);

    return new OkResult();
}

다음 예제에서는 바인딩을 "InvokeOutputBinding" 사용하여 다음을 사용하여 DaprInvokeOutput 함수를 만듭니다.HttpTrigger

@FunctionName("InvokeOutputBinding")
public String run(
        @HttpTrigger(
            name = "req",
            methods = {HttpMethod.GET, HttpMethod.POST},
            authLevel = AuthorizationLevel.ANONYMOUS,
            route = "invoke/{appId}/{methodName}")
            HttpRequestMessage<Optional<String>> request,
        @DaprInvokeOutput(
            appId = "{appId}", 
            methodName = "{methodName}", 
            httpVerb = "post")
        OutputBinding<String> payload,
        final ExecutionContext context)

다음 예제에서 Dapr 호출 출력 바인딩은 개체에 의해 등록된 HTTP 트리거와 쌍을 이루어 집니다 app .

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

app.generic('InvokeOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "invoke/{appId}/{methodName}",
        name: "req"
    }),
    return: daprInvokeOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");

        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { body: payload };
    }
});

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

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

{
  "bindings":
    {
      "type": "daprInvoke",
      "direction": "out",
      "appId": "{appId}",
      "methodName": "{methodName}",
      "httpVerb": "post",
      "name": "payload"
    }
}

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

코드

using namespace System.Net

# Input bindings are passed in via param block.
param($req, $TriggerMetadata)

# Write to the Azure Functions log stream.
Write-Host "Powershell InvokeOutputBinding processed a request."

$req_body = $req.Body

$invoke_output_binding_req_body = @{
    "body" = $req_body
}

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

Push-OutputBinding -Name res -Value ([HttpResponseContext]@{
    StatusCode = [HttpStatusCode]::OK
    Body = $req_body
})

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

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="InvokeOutputBinding")
@app.route(route="invoke/{appId}/{methodName}", auth_level=dapp.auth_level.ANONYMOUS)
@app.dapr_invoke_output(arg_name = "payload", app_id = "{appId}", method_name = "{methodName}", http_verb = "post")
def main(req: func.HttpRequest, payload: func.Out[str] ) -> str:
    # request body must be passed this way "{\"body\":{\"value\":{\"key\":\"some value\"}}}" to use the InvokeOutputBinding, all the data must be enclosed in body property.
    logging.info('Python function processed a InvokeOutputBinding request from the Dapr Runtime.')

    body = req.get_body()
    logging.info(body)
    if body is not None:
        payload.set(body)
    else:
        logging.info('req body is none')
    return 'ok'

특성

In-process 모델에서 특성을 사용하여 DaprInvoke 다음 매개 변수를 지원하는 Dapr 호출 출력 바인딩을 정의합니다.

매개 변수 설명 특성을 통해 보낼 수 있습니다. RequestBody를 통해 보낼 수 있습니다.
AppId 호출할 Dapr 앱 ID입니다. ✔️ ✔️
Methodname 호출할 앱의 메서드 이름입니다. ✔️ ✔️
HttpVerb 선택 사항. 호출할 앱을 사용하는 HTTP 동사입니다. 기본값은 POST입니다. ✔️ ✔️
본문 필수입니다. 요청의 본문입니다. ❌ ✔️

주석

DaprInvokeOutput 주석을 사용하면 함수가 출력 바인딩을 호출하고 수신 대기하도록 할 수 있습니다.

요소 설명 특성을 통해 보낼 수 있습니다. RequestBody를 통해 보낼 수 있습니다.
appId 호출 바인딩에 관련된 애플리케이션의 앱 ID입니다. ✔️ ✔️
Methodname 메서드 변수의 이름입니다. ✔️ ✔️
httpVerb 게시하거나 가져옵니다. ✔️ ✔️
몸 필수입니다. 요청의 본문입니다. ❌ ✔️

구성

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

속성 설명 특성을 통해 보낼 수 있습니다. RequestBody를 통해 보낼 수 있습니다.
appId 호출 바인딩에 관련된 애플리케이션의 앱 ID입니다. ✔️ ✔️
메서드 게시하거나 가져옵니다. ✔️ ✔️
몸 필수입니다. 요청의 본문입니다. ❌ ✔️

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

function.json 속성 설명 특성을 통해 보낼 수 있습니다. RequestBody를 통해 보낼 수 있습니다.
appId 호출 바인딩에 관련된 애플리케이션의 앱 ID입니다. ✔️ ✔️
Methodname 메서드 변수의 이름입니다. ✔️ ✔️
httpVerb 게시하거나 가져옵니다. ✔️ ✔️
몸 필수입니다. 요청의 본문입니다. ❌ ✔️

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

속성 설명 특성을 통해 보낼 수 있습니다. RequestBody를 통해 보낼 수 있습니다.
app_id 호출 바인딩에 관련된 애플리케이션의 앱 ID입니다. ✔️ ✔️
method_name 메서드 변수의 이름입니다. ✔️ ✔️
http_verb post 또는 get로 설정합니다. ✔️ ✔️
몸 필수입니다. 요청의 본문입니다. ❌ ✔️

속성이 특성과 RequestBody둘 다에 정의되어 있으면 제공된 데이터에 우선 순위가 지정됩니다 RequestBody.

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

사용

Dapr 서비스 호출 출력 바인딩을 사용하려면 공식 Dapr 설명서에서 Dapr 서비스 호출을 사용하는 방법에 대해 자세히 알아보세요.

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

  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 서비스 호출에 대해 자세히 알아봅니다.