Java로 첫 번째 지속형 함수 만들기

아티클
02/26/2024

Durable Functions는 서버리스 환경에서 상태 저장 함수를 작성할 수 있게 하는 Azure Functions의 확장입니다. 확장은 상태, 검사점 및 다시 시작을 관리합니다.

이 빠른 시작에서는 Java에서 'Hello World' Durable Functions 앱을 만들고 테스트하는 방법을 알아봅니다. 가장 기본적인 Durable Functions 앱에는 다음의 세 가지 함수가 포함되어 있습니다.

Orchestrator 함수 - 다른 함수를 오케스트레이션하는 워크플로를 설명합니다.
작업 함수 - 오케스트레이터 함수에 의해 호출되며, 작업을 수행하고 경우에 따라 반환합니다.
클라이언트 함수 - 오케스트레이터 함수를 시작하는 일반 Azure 함수입니다. 이 예제에서는 HTTP 트리거 함수를 사용합니다.

이 빠른 시작에서는 이 'Hello World' 앱을 만드는 방법을 보여 줍니다. 이는 다양한 방법으로 수행할 수 있습니다. 위의 선택기를 사용하여 원하는 접근 방식을 선택합니다.

필수 조건

이 자습서를 완전히 학습하려면 다음이 필요합니다.

Java 개발자 키트 버전 8 이상
Apache Maven 버전 3.0 이상
Azure Functions Core Tools의 최신 버전.
- Azure Functions 4.x의 경우 Core Tools v4.0.4915 이상이 필요합니다.
Azure 구독이 필요한 Azure Storage 계정.

Azure를 구독하고 있지 않다면 시작하기 전에 Azure 체험 계정을 만듭니다.

프로젝트에 필요한 종속성 및 플러그인 추가

다음을 pom.xml에 추가합니다.

<properties>
  <azure.functions.maven.plugin.version>1.18.0</azure.functions.maven.plugin.version>
  <azure.functions.java.library.version>3.0.0</azure.functions.java.library.version>
  <durabletask.azure.functions>1.0.0</durabletask.azure.functions>
  <functionAppName>your-unique-app-name</functionAppName>
</properties>

<dependencies>
  <dependency>
    <groupId>com.microsoft.azure.functions</groupId>
    <artifactId>azure-functions-java-library</artifactId>
    <version>${azure.functions.java.library.version}</version>
  </dependency>
  <dependency>
    <groupId>com.microsoft</groupId>
    <artifactId>durabletask-azure-functions</artifactId>
    <version>${durabletask.azure.functions}</version>
  </dependency>
</dependencies>

<build>
  <plugins>
    <plugin>
      <groupId>org.apache.maven.plugins</groupId>
      <artifactId>maven-compiler-plugin</artifactId>
      <version>3.8.1</version>
    </plugin>
    <plugin>
      <groupId>com.microsoft.azure</groupId>
      <artifactId>azure-functions-maven-plugin</artifactId>
      <version>${azure.functions.maven.plugin.version}</version>
      <configuration>
        <appName>${functionAppName}</appName>
        <resourceGroup>java-functions-group</resourceGroup>
        <appServicePlanName>java-functions-app-service-plan</appServicePlanName>
        <region>westus</region>
        <runtime>
          <os>windows</os>
          <javaVersion>11</javaVersion>
        </runtime>
        <appSettings>
          <property>
            <name>FUNCTIONS_EXTENSION_VERSION</name>
            <value>~4</value>
          </property>
        </appSettings>
      </configuration>
      <executions>
        <execution>
          <id>package-functions</id>
          <goals>
            <goal>package</goal>
          </goals>
        </execution>
      </executions>
    </plugin>
    <plugin>
      <artifactId>maven-clean-plugin</artifactId>
      <version>3.1.0</version>
    </plugin>
  </plugins>
</build>

필요한 JSON 파일 추가

프로젝트 디렉터리에 host.json 파일을 추가합니다. 다음과 유사하게 나타납니다.

{
  "version": "2.0",
  "logging": {
    "logLevel": {
      "DurableTask.AzureStorage": "Warning",
      "DurableTask.Core": "Warning"
    }
  },
  "extensions": {
    "durableTask": {
      "hubName": "JavaTestHub"
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  }
}

참고 항목

현재 Azure Functions v4 확장 번들만 Java용 Durable Functions에 필요한 지원 기능을 제공합니다. Java용 Durable Functions는 v3 및 초기 확장 번들에서 지원되지 않습니다. 확장 번들에 대한 자세한 내용은 확장 번들 설명서를 참조하세요.

Durable Functions에서 런타임 상태를 저장하려면 저장소 공급자가 필요합니다. local.settings.json 파일을 프로젝트 디렉터리에 추가하여 저장소 공급자를 구성합니다. Azure Storage를 공급자로 사용하려면 AzureWebJobsStorage의 값을 Azure Storage 계정의 연결 문자열로 설정합니다.

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "<your storage account connection string>",
    "FUNCTIONS_WORKER_RUNTIME": "java"
  }
}

함수 만들기

아래 샘플 코드는 각각에 대한 간단한 예제를 보여줍니다.

import com.microsoft.azure.functions.annotation.*;
import com.microsoft.azure.functions.*;
import java.util.*;

import com.microsoft.durabletask.*;
import com.microsoft.durabletask.azurefunctions.DurableActivityTrigger;
import com.microsoft.durabletask.azurefunctions.DurableClientContext;
import com.microsoft.durabletask.azurefunctions.DurableClientInput;
import com.microsoft.durabletask.azurefunctions.DurableOrchestrationTrigger;

public class DurableFunctionsSample {
    /**
     * This HTTP-triggered function starts the orchestration.
     */
    @FunctionName("StartOrchestration")
    public HttpResponseMessage startOrchestration(
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
            @DurableClientInput(name = "durableContext") DurableClientContext durableContext,
            final ExecutionContext context) {
        context.getLogger().info("Java HTTP trigger processed a request.");

        DurableTaskClient client = durableContext.getClient();
        String instanceId = client.scheduleNewOrchestrationInstance("Cities");
        context.getLogger().info("Created new Java orchestration with instance ID = " + instanceId);
        return durableContext.createCheckStatusResponse(request, instanceId);
    }

    /**
     * This is the orchestrator function, which can schedule activity functions, create durable timers,
     * or wait for external events in a way that's completely fault-tolerant.
     */
    @FunctionName("Cities")
    public String citiesOrchestrator(
            @DurableOrchestrationTrigger(name = "taskOrchestrationContext") TaskOrchestrationContext ctx) {
        String result = "";
        result += ctx.callActivity("Capitalize", "Tokyo", String.class).await() + ", ";
        result += ctx.callActivity("Capitalize", "London", String.class).await() + ", ";
        result += ctx.callActivity("Capitalize", "Seattle", String.class).await() + ", ";
        result += ctx.callActivity("Capitalize", "Austin", String.class).await();
        return result;
    }

    /**
     * This is the activity function that gets invoked by the orchestrator function.
     */
    @FunctionName("Capitalize")
    public String capitalize(@DurableActivityTrigger(name = "name") String name, final ExecutionContext context) {
        context.getLogger().info("Capitalizing: " + name);
        return name.toUpperCase();
    }
}

Maven 명령을 사용하여 로컬 프로젝트 만들기

다음 명령을 실행하여 Durable Functions 앱의 기본 함수로 프로젝트를 생성합니다.

mvn archetype:generate -DarchetypeGroupId=com.microsoft.azure -DarchetypeArtifactId=azure-functions-archetype -DarchetypeVersion=1.51 -Dtrigger=durablefunctions

mvn archetype:generate "-DarchetypeGroupId=com.microsoft.azure" "-DarchetypeArtifactId=azure-functions-archetype" "-DarchetypeVersion=1.51" "-Dtrigger=durablefunctions"

mvn archetype:generate "-DarchetypeGroupId=com.microsoft.azure" "-DarchetypeArtifactId=azure-functions-archetype" "-DarchetypeVersion=1.51" "-Dtrigger=durablefunctions"

프롬프트에 따라 다음 정보를 제공합니다.

prompt	값
groupId	`com.function`
artifactId	`myDurableFunction`
version	`1.0-SNAPSHOT`
패키지	`com.function`
예	Enter 키를 눌러 확인합니다.

이제 기본 Durable Functions 앱에 필요한 세 가지 함수를 사용하여 로컬 프로젝트가 생성되었습니다.

pom.xml에 대한 종속성으로 com.microsoft:durabletask-azure-functions가 있는지 확인합니다.

백 엔드 저장소 공급자 구성

Durable Functions에서 런타임 상태를 저장하려면 저장소 공급자가 필요합니다. Azure Storage 계정의 연결 문자열을 AzureWebJobsStorage에 값으로 제공하여 local.settings.json에서 Azure Storage를 저장소 공급자로 사용하도록 구성할 수 있습니다.

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "<your storage account connection string>",
    "FUNCTIONS_WORKER_RUNTIME": "java"
  }
}

로컬 프로젝트 만들기

Visual Studio Code에서 F1(또는 Ctrl/Cmd+Shift+P)을 눌러 명령 팔레트를 엽니다. 명령 팔레트에서 Azure Functions: Create New Project...을 검색하여 선택합니다.
프로젝트에 대한 빈 폴더 위치를 선택하고, 선택을 누릅니다.

프롬프트에 따라 다음 정보를 제공합니다.

prompt	값
언어 선택	`Java`을 선택합니다.
Java 버전 선택	Azure에서 함수가 실행되는 Java 버전, `Java 8` 이상을 선택합니다. 로컬로 확인한 Java 버전을 선택합니다.
그룹 ID 제공	`com.function`.
아티팩트 ID 제공	`myDurableFunction`.
버전 제공	`1.0-SNAPSHOT`.
패키지 이름 제공	`com.function`.
앱 이름 제공	`myDurableFunction`.
Java 프로젝트에 대한 빌드 도구 선택	`Maven`을 선택합니다.
프로젝트를 여는 방법 선택	`Open in new window`을 선택합니다.

이제 예제 HTTP 함수가 포함된 프로젝트가 있습니다. 다음 단계에서 Durable Functions 앱의 기본 함수를 추가하므로, 원하는 경우 이 함수를 제거할 수 있습니다.

프로젝트 항목에 함수 추가

명령 팔레트에서 Azure Functions: Create Function...을 검색하여 선택합니다.
Change template filter를 All로 선택합니다.
프롬프트에 따라 다음 정보를 제공합니다.

prompt 값

함수의 템플릿 선택 DurableFunctionsOrchestration

패키지 이름 제공 com.function

함수 이름 입력 DurableFunctionsOrchestrator
스토리지 계정 정보를 설정하라는 팝업 창에서 Select storage account을 선택하고 프롬프트에 따릅니다.

prompt	값
함수의 템플릿 선택	DurableFunctionsOrchestration
패키지 이름 제공	`com.function`
함수 이름 입력	`DurableFunctionsOrchestrator`

이제 Durable Functions 앱에 대한 세 가지 기본 함수가 생성되어 있어야 합니다.

pom.xml 및 host.json 구성

pom.xml에 다음 종속성을 추가합니다.

<dependency>
  <groupId>com.microsoft</groupId>
  <artifactId>durabletask-azure-functions</artifactId>
  <version>1.0.0</version>
</dependency>

extensions 속성을 host.json에 추가합니다.

"extensions": { "durableTask": { "hubName": "JavaTestHub" }}

로컬에서 함수 테스트

Azure Functions Core Tools를 사용하면 로컬 개발 컴퓨터에서 Azure Functions 프로젝트를 실행할 수 있습니다.