Azure Functions에 대한 Dapr 상태 출력 바인딩

Dapr 상태 출력 바인딩을 사용하면 함수를 실행하는 동안 Dapr 상태에 값을 저장할 수 있습니다.

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

Example

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

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

In-process

다음 예제에서는 Dapr 상태 출력 바인딩을 사용하여 상태 저장소에 새 상태를 유지하는 방법을 보여 줍니다.

[FunctionName("StateOutputBinding")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "state/{key}")] HttpRequest req,
    [DaprState("statestore", Key = "{key}")] IAsyncCollector<string> state,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

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

    return new OkResult();
}

Isolated process

More samples for the Dapr output state binding are available in the GitHub repository.

[Function("StateOutputBinding")]
[DaprStateOutput("statestore", Key = "{key}")]
public static string Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "state/{key}")] HttpRequestData req,
    FunctionContext functionContext)
{
    var log = functionContext.GetLogger("StateOutputBinding");
    log.LogInformation("C# HTTP trigger function processed a request.");

    string requestBody = new StreamReader(req.Body).ReadToEnd();

    return requestBody;
}

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

@FunctionName("CreateNewOrderHttpTrigger")
public String run(
        @HttpTrigger(
            name = "req",
            methods = {HttpMethod.POST},
            authLevel = AuthorizationLevel.ANONYMOUS)
            HttpRequestMessage<Optional<String>> request,
        @DaprStateOutput(
            stateStore = "%StateStoreName%",
            key = "product")
        OutputBinding<String> product,
        final ExecutionContext context) {
    context.getLogger().info("Java HTTP trigger (CreateNewOrderHttpTrigger) processed a request.");
}

Node.js v4

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

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

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

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

        return { value : payload };
    }
});

Node.js v3

The following examples show Dapr triggers in a function.json file and JavaScript code that uses those bindings.

Here's the function.json file for daprState output:

{
  "bindings": 
    {
      "type": "daprState",
      "direction": "out",
      "name": "dapr",
      "stateStore": "statestore",
      "key": "{key}",
      "daprAddress": "%daprAddress%"
    }
}

For more information about function.json file properties, see the Configuration section.

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

module.exports = async function (context, req) {
    context.log('JavaScript HTTP trigger function processed a request.');

    context.bindings.dapr = {
        // stateStore: 'statestore-if-not-in-function.json'
        // key: 'key-if-not-in-function.json'
        value: req.body
    };
};

The following examples show Dapr triggers in a function.json file and PowerShell code that uses those bindings.

Here's the function.json file for daprState output:

{
  "bindings": 
    {
      "type": "daprState",
      "stateStore": "%StateStoreName%",
      "direction": "out",
      "name": "order",
      "key": "order"
    }
}

For more information about function.json file properties, see the Configuration section.

In code:

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

# C# function processed a CreateNewOrder request from the Dapr Runtime.
Write-Host "PowerShell function processed a CreateNewOrder request from the Dapr Runtime."

# Payload must be of the format { "data": { "value": "some value" } }

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $payload| ConvertTo-Json

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name order -Value $payload["data"]

Python v2

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

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="HttpTriggerFunc")
@app.route(route="req", auth_level=dapp.auth_level.ANONYMOUS)
@app.dapr_state_output(arg_name="state", state_store="statestore", key="newOrder")
def main(req: func.HttpRequest, state: func.Out[str] ) -> str:
    # request body must be passed this way '{\"value\": { \"key\": \"some value\" } }'
    body = req.get_body()
    if body is not None:
        state.set(body.decode('utf-8'))
        logging.info(body.decode('utf-8'))
    else:
        logging.info('req body is none')
    return 'ok'

Python v1

다음 예제에서는 v1 Python 프로그래밍 모델을 사용하는 Dapr 상태 출력 바인딩을 보여줍니다.

Here's the function.json file for daprState:

{
  "scriptFile": "__init__.py",
  "bindings": 
    {
      "type": "daprState",
      "stateStore": "%StateStoreName%",
      "direction": "out",
      "name": "order",
      "key": "order"
    }
}

For more information about function.json file properties, see the Configuration section.

다음은 Python 코드입니다.

import logging
import json
import azure.functions as func

def main(payload,
         order: func.Out[str]) -> None:
    logging.info('Python function processed a CreateNewOrder request from the Dapr Runtime.')  
    payload_json = json.loads(payload)
    logging.info(payload_json["data"])
    order.set(json.dumps(payload_json["data"]))

Attributes

In-process

In the in-process model, use the DaprState to define a Dapr state output binding, which supports these parameters:

Parameter	Description	특성을 통해 전송 가능	RequestBody를 통해 보낼 수 있음
StateStore	상태를 저장할 상태 저장소의 이름입니다.	✔️	❌
Key	상태 저장소 내에서 상태를 저장할 키의 이름입니다.	✔️	✔️
Value	Required. 저장되는 값입니다.	❌	✔️

Isolated process

격리된 작업자 모델DaprStateOutput에서 다음 매개 변수를 지원하는 Dapr 상태 출력 바인딩을 정의합니다.

Parameter	Description	특성을 통해 전송 가능	RequestBody를 통해 보낼 수 있음
StateStore	상태를 저장할 상태 저장소의 이름입니다.	✔️	❌
Key	상태 저장소 내에서 상태를 저장할 키의 이름입니다.	✔️	✔️
Value	Required. 저장되는 값입니다.	❌	✔️

Annotations

DaprStateOutput 주석을 사용하면 상태 저장소에 액세스하는 기능을 수행할 수 있습니다.

Element	Description	특성을 통해 전송 가능	RequestBody를 통해 보낼 수 있음
stateStore	상태를 저장할 상태 저장소의 이름입니다.	✔️	❌
key	상태 저장소 내에서 상태를 저장할 키의 이름입니다.	✔️	✔️
value	Required. 저장되는 값입니다.	❌	✔️

Configuration

Node.js v4

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

Property	Description	특성을 통해 전송 가능	RequestBody를 통해 보낼 수 있음
stateStore	상태를 저장할 상태 저장소의 이름입니다.	✔️	❌
key	상태 저장소 내에서 상태를 저장할 키의 이름입니다.	✔️	✔️
value	Required. 저장되는 값입니다.	❌	✔️

Node.js v3

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

function.json property	Description	특성을 통해 전송 가능	RequestBody를 통해 보낼 수 있음
stateStore	상태를 저장할 상태 저장소의 이름입니다.	✔️	❌
key	상태 저장소 내에서 상태를 저장할 키의 이름입니다.	✔️	✔️
value	Required. 저장되는 값입니다.	❌	✔️

The following table explains the binding configuration properties that you set in the function.json file.

function.json property	Description	특성을 통해 전송 가능	RequestBody를 통해 보낼 수 있음
stateStore	상태를 저장할 상태 저장소의 이름입니다.	✔️	❌
key	상태 저장소 내에서 상태를 저장할 키의 이름입니다.	✔️	✔️
value	Required. 저장되는 값입니다.	❌	✔️

Python v2

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

Property	Description	특성을 통해 전송 가능	RequestBody를 통해 보낼 수 있음
stateStore	상태를 저장할 상태 저장소의 이름입니다.	✔️	❌
key	상태 저장소 내에서 상태를 저장할 키의 이름입니다.	✔️	✔️
value	Required. 저장되는 값입니다.	❌	✔️

Python v1

The following table explains the binding configuration properties that you set in the function.json file.

function.json property	Description	특성을 통해 전송 가능	RequestBody를 통해 보낼 수 있음
stateStore	상태를 저장할 상태 저장소의 이름입니다.	✔️	❌
key	상태 저장소 내에서 상태를 저장할 키의 이름입니다.	✔️	✔️
value	Required. 저장되는 값입니다.	❌	✔️

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

See the Example section for complete examples.

Usage

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

• Dapr 상태 저장소 구성 요소 사양
• 방법: 상태 저장

Python v2

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

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 모델은 상태 저장소 설정 외에 추가 변경이 필요하지 않습니다.

Next steps

Dapr 상태 관리에 관해 자세히 알아봅니다.