지속성 함수의 함수 체이닝 - Hello 시퀀스 샘플

• 빠른 시작 문서 완료
• GitHub에서 샘플 프로젝트 복제 또는 다운로드

• 빠른 시작 문서 완료
• GitHub에서 샘플 프로젝트 복제 또는 다운로드

• 빠른 시작 문서 완료
• GitHub에서 샘플 프로젝트 복제 또는 다운로드

• 빠른 시작 문서 완료
• GitHub에서 샘플 프로젝트 복제 또는 다운로드

[FunctionName("E1_HelloSequence")]
public static async Task<List<string>> Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    var outputs = new List<string>();

    outputs.Add(await context.CallActivityAsync<string>("E1_SayHello", "Tokyo"));
    outputs.Add(await context.CallActivityAsync<string>("E1_SayHello", "Seattle"));
    outputs.Add(await context.CallActivityAsync<string>("E1_SayHello_DirectInput", "London"));

    // returns ["Hello Tokyo!", "Hello Seattle!", "Hello London!"]
    return outputs;
}

모든 C# 오케스트레이션 함수에는 Microsoft.Azure.WebJobs.Extensions.DurableTask 어셈블리에 있는 DurableOrchestrationContext 유형 매개 변수가 있어야 합니다. 이 컨텍스트 개체를 사용하면 다른 작업 함수를 호출하고 해당 CallActivityAsync 메서드를 사용하여 입력 매개 변수를 전달할 수 있습니다.

코드에서는 여러 매개 변수 값을 사용하여 E1_SayHello을 순서대로 세 번 호출합니다. 각 호출의 반환 값은 함수의 끝에서 반환되는 outputs 목록에 추가됩니다.

function.json

Visual Studio Code 또는 Azure Portal을 사용하여 개발하는 경우 오케스트레이터 함수에 대한 function.json 파일의 내용이 여기에 있습니다. 대부분의 오케스트레이터 function.json 파일은 거의 이와 비슷합니다.

{
  "bindings": [
    {
      "name": "context",
      "type": "orchestrationTrigger",
      "direction": "in"
    }
  ],
  "disabled": false
}

중요한 것은 orchestrationTrigger 바인딩 형식입니다. 오케스트레이터 함수는 모두 이 트리거 형식을 사용해야 합니다.

index.js

오케스트레이터 함수는 다음과 같습니다.

const df = require("durable-functions");

module.exports = df.orchestrator(function* (context) {
    context.log("Starting chain sample");
    const output = [];
    output.push(yield context.df.callActivity("E1_SayHello", "Tokyo"));
    output.push(yield context.df.callActivity("E1_SayHello", "Seattle"));
    output.push(yield context.df.callActivity("E1_SayHello", "London"));

    return output;
});

모든 JavaScript 오케스트레이션 함수는 durable-functions 모듈을 포함해야 합니다. JavaScript에서 Durable Functions를 작성할 수 있게 해주는 라이브러리입니다. 오케스트레이터 함수 및 다른 JavaScript 함수 사이에는 다음과 같은 세 가지 중요한 차이점이 있습니다.

1. 오케스트레이터 함수는 생성기 함수입니다.
2. 함수가 durable-functions 모듈의 orchestrator 호출에 래핑됩니다(여기서는 df).
3. 동기 함수여야 합니다. '오케스트레이터' 메서드가 'context.done'에 대한 최종 호출을 처리하므로 함수는 단순히 '반환'만 하면 됩니다.

context 개체에는 다른 작업 함수를 호출하고 해당 callActivity 메서드를 사용하여 입력 매개 변수를 전달할 수 있는 df 지속형 오케스트레이션 컨텍스트 개체가 포함되어 있습니다. 코드는 다른 매개 변수 값을 사용하여 E1_SayHello를 순차적으로 3번 호출하고, yield를 사용하여 비동기 작업 함수 호출이 반환될 때까지 실행을 대기해야 함을 나타냅니다. 각 호출의 반환 값은 함수의 끝에서 반환되는 outputs 배열에 추가됩니다.

const df = require("durable-functions");

const helloActivityName = "sayHello";

df.app.orchestration("helloSequence", function* (context) {
    context.log("Starting chain sample");

    const output = [];
    output.push(yield context.df.callActivity(helloActivityName, "Tokyo"));
    output.push(yield context.df.callActivity(helloActivityName, "Seattle"));
    output.push(yield context.df.callActivity(helloActivityName, "Cairo"));

    return output;
});

모든 JavaScript 오케스트레이션 함수는 durable-functions 모듈을 포함해야 합니다. 이 모듈에서는 JavaScript에서 Durable Functions를 작성할 수 있습니다. V4 노드 프로그래밍 모델을 사용하려면 durable-functions의 미리 보기 v3.x 버전을 설치해야 합니다.

오케스트레이터 함수 및 다른 JavaScript 함수 사이에는 다음과 같은 두 가지 중요한 차이점이 있습니다.

1. 오케스트레이터 함수는 생성기 함수입니다.
2. 동기 함수여야 합니다. 함수는 단순히 ‘return’이어야 합니다.

context 개체에는 다른 작업 함수를 호출하고 해당 callActivity 메서드를 사용하여 입력 매개 변수를 전달할 수 있는 df 지속형 오케스트레이션 컨텍스트 개체가 포함되어 있습니다. 코드는 다른 매개 변수 값을 사용하여 sayHello를 순차적으로 3번 호출하고, yield를 사용하여 비동기 작업 함수 호출이 반환될 때까지 실행을 대기해야 함을 나타냅니다. 각 호출의 반환 값은 함수의 끝에서 반환되는 outputs 배열에 추가됩니다.

function.json

Visual Studio Code 또는 Azure Portal을 사용하여 개발하는 경우 오케스트레이터 함수에 대한 function.json 파일의 내용이 여기에 있습니다. 대부분의 오케스트레이터 function.json 파일은 거의 이와 비슷합니다.

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "context",
      "type": "orchestrationTrigger",
      "direction": "in"
    }
  ]
}

중요한 것은 orchestrationTrigger 바인딩 형식입니다. 오케스트레이터 함수는 모두 이 트리거 형식을 사용해야 합니다.

__init__.py

오케스트레이터 함수는 다음과 같습니다.

import azure.functions as func
import azure.durable_functions as df


def orchestrator_function(context: df.DurableOrchestrationContext):
    result1 = yield context.call_activity('E1_SayHello', "Tokyo")
    result2 = yield context.call_activity('E1_SayHello', "Seattle")
    result3 = yield context.call_activity('E1_SayHello', "London")
    return [result1, result2, result3]

main = df.Orchestrator.create(orchestrator_function)

모든 Python 오케스트레이션 함수는 durable-functions 패키지를 포함해야 합니다. Python에서 Durable Functions을 작성할 수 있게 해주는 라이브러리입니다. 오케스트레이터 함수 및 다른 Python 함수 사이에는 다음과 같은 두 가지 중요한 차이점이 있습니다.

1. 오케스트레이터 함수는 생성기 함수입니다.
2. 파일은 파일 끝에 main = df.Orchestrator.create(<orchestrator function name>)를 지정하여 오케스트레이터 함수를 오케스트레이터로 등록해야 합니다. 이를 통해 파일에 선언된 다른 도우미 함수와 구별할 수 있습니다.

context 개체를 사용하면 다른 작업 함수를 호출하고 해당 call_activity 메서드를 사용하여 입력 매개 변수를 전달할 수 있습니다. 코드는 다른 매개 변수 값을 사용하여 E1_SayHello를 순차적으로 3번 호출하고, yield를 사용하여 비동기 작업 함수 호출이 반환될 때까지 실행을 대기해야 함을 나타냅니다. 각 호출의 반환 값은 함수의 끝에 반환됩니다.

[FunctionName("E1_SayHello")]
public static string SayHello([ActivityTrigger] IDurableActivityContext context)
{
    string name = context.GetInput<string>();
    return $"Hello {name}!";
}

작업은 ActivityTrigger 특성을 사용합니다. 제공된 IDurableActivityContext를 사용하여 GetInput<T>을 사용해 입력 값에 액세스하는 것과 같은 작업 관련 조치를 수행합니다.

E1_SayHello의 구현은 비교적 간단한 문자열 형식 지정 작업입니다.

IDurableActivityContext에 바인딩하는 대신 작업 함수로 전달되는 형식에 직접 바인딩할 수 있습니다. 예시:

[FunctionName("E1_SayHello_DirectInput")]
public static string SayHelloDirectInput([ActivityTrigger] string name)
{
    return $"Hello {name}!";
}

E1_SayHello/function.json

E1_SayHello 작업 함수에 대한 function.json 파일은 orchestrationTrigger 바인딩 형식 대신 activityTrigger 바인딩 형식을 사용한다는 점을 제외하고는 E1_HelloSequence의 것과 비슷합니다.

{
  "bindings": [
    {
      "name": "name",
      "type": "activityTrigger",
      "direction": "in"
    }
  ],
  "disabled": false
}

E1_SayHello의 구현은 비교적 간단한 문자열 형식 지정 작업입니다.

E1_SayHello/index.js

module.exports = function (context) {
    context.done(null, `Hello ${context.bindings.name}!`);
};

오케스트레이션 함수와 달리 작업 함수에는 특별한 설정이 필요하지 않습니다. 오케스트레이터 함수에 의해 전달되는 입력은 activityTrigger 바인딩 이름(이 경우 context.bindings.name) 아래의 context.bindings 개체에 있습니다. 바인딩 이름은 내보낸 함수의 매개 변수로 설정되고 직접 액세스될 수 있습니다. 샘플 코드는 이 작업을 수행합니다.

sayHello의 구현은 비교적 간단한 문자열 형식 지정 작업입니다.

const df = require("durable-functions");

const helloActivityName = "sayHello";

df.app.activity(helloActivityName, {
    handler: function (input) {
        return `Hello ${input}`;
    },
});

오케스트레이션 함수와 달리 작업 함수에는 특별한 설정이 필요하지 않습니다. 오케스트레이터 함수에서 전달된 입력은 함수의 첫 번째 인수입니다. 두 번째 인수는 호출 컨텍스트이며 이 예제에서는 사용되지 않습니다.

E1_SayHello/function.json

E1_SayHello 작업 함수에 대한 function.json 파일은 orchestrationTrigger 바인딩 형식 대신 activityTrigger 바인딩 형식을 사용한다는 점을 제외하고는 E1_HelloSequence의 것과 비슷합니다.

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "name",
      "type": "activityTrigger",
      "direction": "in"
    }
  ]
}

E1_SayHello의 구현은 비교적 간단한 문자열 형식 지정 작업입니다.

E1_SayHello/__init__.py

def main(name: str) -> str:
    return f"Hello {name}!"

오케스트레이터 함수와 달리 작업 함수에는 특별한 설정이 필요하지 않습니다. 오케스트레이터 함수에서 전달된 입력은 함수에 대한 매개 변수로 직접 액세스할 수 있습니다.

public static class HttpStart
{
    [FunctionName("HttpStart")]
    public static async Task<HttpResponseMessage> Run(
        [HttpTrigger(AuthorizationLevel.Function, methods: "post", Route = "orchestrators/{functionName}")] HttpRequestMessage req,
        [DurableClient] IDurableClient starter,
        string functionName,
        ILogger log)
    {
        // Function input comes from the request content.
        object eventData = await req.Content.ReadAsAsync<object>();
        string instanceId = await starter.StartNewAsync(functionName, eventData);

        log.LogInformation($"Started orchestration with ID = '{instanceId}'.");

        return starter.CreateCheckStatusResponse(req, instanceId);
    }
}

오케스트레이터와 상호 작용하려면 함수에 DurableClient 입력 바인딩이 포함되어야 합니다. 클라이언트를 사용하여 오케스트레이션을 시작합니다. 또한 새 오케스트레이션의 상태를 확인하기 위해 URL이 포함된 HTTP 응답을 반환하는 데 도움이 될 수 있습니다.

HttpStart/function.json

{
    "bindings": [
      {
        "authLevel": "anonymous",
        "name": "req",
        "type": "httpTrigger",
        "direction": "in",
        "route": "orchestrators/{functionName}",
        "methods": ["post"]
      },
      {
        "name": "$return",
        "type": "http",
        "direction": "out"
      },
      {
        "name": "starter",
        "type": "orchestrationClient",
        "direction": "in"
      }
    ],
    "disabled": false
  }

오케스트레이터와 상호 작용하려면 함수에 durableClient 입력 바인딩이 포함되어야 합니다.

HttpStart/index.js

const df = require("durable-functions");

module.exports = async function (context, req) {
    const client = df.getClient(context);
    const instanceId = await client.startNew(req.params.functionName, undefined, req.body);

    context.log(`Started orchestration with ID = '${instanceId}'.`);

    return client.createCheckStatusResponse(context.bindingData.req, instanceId);
};

df.getClient 개체를 가져오려면 DurableOrchestrationClient를 사용합니다. 클라이언트를 사용하여 오케스트레이션을 시작합니다. 또한 새 오케스트레이션의 상태를 확인하기 위해 URL이 포함된 HTTP 응답을 반환하는 데 도움이 될 수 있습니다.

const df = require("durable-functions");
const { app } = require("@azure/functions");

app.http("httpStart", {
    route: "orchestrators/{orchestratorName}",
    extraInputs: [df.input.durableClient()],
    handler: async (request, context) => {
        const client = df.getClient(context);
        const body = await request.json();
        const instanceId = await client.startNew(request.params.orchestratorName, { input: body });

        context.log(`Started orchestration with ID = '${instanceId}'.`);

        return client.createCheckStatusResponse(request, instanceId);
    },
});

오케스트레이터를 관리하고 상호 작용하려면 함수에 durableClient 입력 바인딩이 있어야 합니다. 함수를 등록할 때 extraInputs 인수에 이 바인딩을 지정해야 합니다. durableClient 입력은 df.input.durableClient()를 호출하여 가져올 수 있습니다.

df.getClient 개체를 가져오려면 DurableClient를 사용합니다. 클라이언트를 사용하여 오케스트레이션을 시작합니다. 또한 새 오케스트레이션의 상태를 확인하기 위해 URL이 포함된 HTTP 응답을 반환하는 데 도움이 될 수 있습니다.

HttpStart/function.json

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "anonymous",
      "name": "req",
      "type": "httpTrigger",
      "direction": "in",
      "route": "orchestrators/{functionName}",
      "methods": [
        "post",
        "get"
      ]
    },
    {
      "name": "$return",
      "type": "http",
      "direction": "out"
    },
    {
      "name": "starter",
      "type": "durableClient",
      "direction": "in"
    }
  ]
}

오케스트레이터와 상호 작용하려면 함수에 durableClient 입력 바인딩이 포함되어야 합니다.

HttpStart/__init__.py

import logging

import azure.functions as func
import azure.durable_functions as df


async def main(req: func.HttpRequest, starter: str) -> func.HttpResponse:
    client = df.DurableOrchestrationClient(starter)
    instance_id = await client.start_new(req.route_params["functionName"], None, None)

    logging.info(f"Started orchestration with ID = '{instance_id}'.")

    return client.create_check_status_response(req, instance_id)

DurableOrchestrationClient 생성자를 사용하여 Durable Functions 클라이언트를 가져옵니다. 클라이언트를 사용하여 오케스트레이션을 시작합니다. 또한 새 오케스트레이션의 상태를 확인하기 위해 URL이 포함된 HTTP 응답을 반환하는 데 도움이 될 수 있습니다.