1단계: 활동 생성 2단계: 상태 시스템 만들기 3단계: 작업자 구현 4단계: 상태 시스템 실행 5단계: 작업자 실행 및 중지

Step Functions를 사용하여 Activity 상태 시스템 만들기

이 자습서에서는 Java 및 AWS Step Functions을 사용하여 활동 기반 상태 머신을 생성하는 방법을 소개합니다. 활동을 사용하면 상태 시스템의 다른 위치에서 실행되는 작업자 코드를 제어할 수 있습니다. 개요는 Step Functions 작동 방식의 활동 단원을 참조하십시오.

이 튜토리얼을 완료하려면 다음이 필요합니다.

Java용 SDK. 이 자습서의 예제 활동은 를 사용하여 AWS SDK for Java 통신하는 Java 응용 프로그램입니다 AWS.
AWS 환경 또는 표준 AWS 구성 파일의 자격 증명 자세한 내용은 AWS SDK for Java 개발자 안내서의 AWS 자격 증명 설정을 참조하십시오.

1단계: 활동 생성

Step Functions가 만들려는 작업자(프로그램)의 활동을 인식하게 해야 합니다. Step Functions는 활동 ID를 설정하는 Amazon 리소스 이름(ARN)으로 응답합니다. 이 자격 증명을 사용하면 상태 머신 및 작업자 사이에서 전달되는 정보를 조정할 수 있습니다.

중요

액티비티 태스크가 스테이트 머신과 동일한 AWS 계정에 속하는지 확인하세요.

Step Functions 콘솔 왼쪽에 있는 탐색 창에서 활동을 선택합니다.
활동 생성을 선택합니다.
활동 이름(예: get-greeting)을 입력한 다음 활동 생성을 선택합니다.
활동 작업이 생성되면 다음 예제와 같이 해당 ARN을 적어 둡니다.
```
arn:aws:states:us-east-1:123456789012:activity:get-greeting
```

2단계: 상태 시스템 만들기

활동 호출 시기 및 작업자가 주요 작업을 수행하고 결과를 수집하고 이를 반환해야 하는 시기를 결정하는 상태 머신을 생성합니다. 상태 시스템을 만들려면 Workflow Studio의 코드 편집기를 사용합니다.

Step Functions 콘솔 왼쪽에 있는 탐색 창에서 상태 시스템을 선택합니다.
상태 시스템 페이지에서 상태 시스템 생성을 선택합니다.
템플릿 선택 대화 상자에서 공백을 선택합니다.
선택을 선택하세요. 디자인 모드에서 Workflow Studio가 열립니다.
이 자습서에서는 상태 시스템의 Amazon States Language(ASL) 정의를 코드 편집기에서 작성합니다. 이렇게 하려면 코드를 선택합니다.
기존 보일러플레이트 코드를 제거하고 다음 코드를 붙여넣습니다. 이 코드의 예제 ARN을 Resource 필드에서 이전에 만든 활동 작업의 ARN으로 바꿔야 합니다.
```
{
  "Comment": "An example using a Task state.",
  "StartAt": "getGreeting",
  "Version": "1.0",
  "TimeoutSeconds": 300,
  "States":
  {
    "getGreeting": {
      "Type": "Task",
      "Resource": "arn:aws:states:us-east-1:123456789012:activity:get-greeting",
      "End": true
    }
  }
}
```
이 예제는 Amazon States Language(ASL)를 사용하는 상태 시스템에 대한 설명입니다. 이 예에서는 getGreeting라는 하나의 Task 상태를 정의합니다. 자세한 내용은 상태 머신 구조를 참조하십시오.
그래프 시각화 창에서 추가한 ASL 정의의 워크플로 그래프가 다음 그래프와 비슷한지 확인합니다.
상태 시스템 이름을 지정합니다. 이렇게 하려면 기본 상태 머신 이름 옆에 있는 편집 아이콘을 선택하십시오 MyStateMachine. 그런 다음 상태 머신 구성에서 상태 머신 이름 상자에 이름을 지정합니다.

이 튜토리얼에서는 이름 ActivityStateMachine를 입력합니다.
(선택 사항) 상태 머신 구성에서 상태 시스템 유형 및 실행 역할과 같은 기타 워크플로 설정을 지정합니다.

이 자습서의 경우 상태 머신 설정의 모든 기본 선택 항목을 그대로 둡니다.

상태 시스템에 대한 올바른 권한을 사용하여 이전에 IAM 역할을 만들었고 이를 사용하려면 권한에서 기존 역할 선택을 선택한 다음 목록에서 역할을 선택합니다. 또는 역할 ARN 입력을 선택한 다음 IAM 역할에 대한 ARN을 제공합니다.
역할 생성 확인 대화 상자에서 확인을 선택하여 계속합니다.

역할 설정 보기를 선택하여 상태 머신 구성으로 돌아갈 수도 있습니다.

참고
Step Functions에서 만드는 IAM 역할을 삭제하면 나중에 Step Functions에서 이 역할을 다시 만들 수 없습니다. 마찬가지로, 역할을 수정하면(예: IAM 정책의 주요에서 Step Functions 제거) 나중에 Step Functions에서 해당 원본 설정을 복원할 수 없습니다.

3단계: 작업자 구현

작업자를 생성합니다. 작업자는 다음을 수행하는 프로그램입니다.

GetActivityTask API 작업을 사용하여 활동에 대한 Step Functions 폴링
코드를 사용하여 활동 작업 수행(예: 다음 코드의 getGreeting() 메서드).
SendTaskSuccess, SendTaskFailure 및 SendTaskHeartbeat API 작업을 사용하여 결과 반환.

참고

활동 작업자의 보다 완벽한 예제는 Ruby 활동 작업자 예제를 참조하십시오. 이 예제는 사용자가 활동 작업자에 대한 참조로 사용할 수 있는 모범 사례를 기반으로 한 구현을 제공합니다. 이 코드는 폴러 및 활동 작업자용 스레드 수를 구성할 수 있는 소비자-생산자 패턴을 구현합니다.

작업자를 구현하려면

GreeterActivities.java이라는 이름의 파일을 만듭니다.

파일에 다음 코드를 추가합니다.


import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.EnvironmentVariableCredentialsProvider;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.stepfunctions.AWSStepFunctions;
import com.amazonaws.services.stepfunctions.AWSStepFunctionsClientBuilder;
import com.amazonaws.services.stepfunctions.model.GetActivityTaskRequest;
import com.amazonaws.services.stepfunctions.model.GetActivityTaskResult;
import com.amazonaws.services.stepfunctions.model.SendTaskFailureRequest;
import com.amazonaws.services.stepfunctions.model.SendTaskSuccessRequest;
import com.amazonaws.util.json.Jackson;
import com.fasterxml.jackson.databind.JsonNode;
import java.util.concurrent.TimeUnit;


public class GreeterActivities {

    public String getGreeting(String who) throws Exception {
        return "{\"Hello\": \"" + who + "\"}";
    }

    public static void main(final String[] args) throws Exception {
        GreeterActivities greeterActivities = new GreeterActivities();
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setSocketTimeout((int)TimeUnit.SECONDS.toMillis(70));

        AWSStepFunctions client = AWSStepFunctionsClientBuilder.standard()
                .withRegion(Regions.US_EAST_1)
                .withCredentials(new EnvironmentVariableCredentialsProvider())
                .withClientConfiguration(clientConfiguration)
                .build();

        while (true) {
            GetActivityTaskResult getActivityTaskResult =
                    client.getActivityTask(
                            new GetActivityTaskRequest().withActivityArn(ACTIVITY_ARN));

            if (getActivityTaskResult.getTaskToken() != null) {
                try {
                    JsonNode json = Jackson.jsonNodeOf(getActivityTaskResult.getInput());
                    String greetingResult =
                            greeterActivities.getGreeting(json.get("who").textValue());
                    client.sendTaskSuccess(
                            new SendTaskSuccessRequest().withOutput(
                                    greetingResult).withTaskToken(getActivityTaskResult.getTaskToken()));
                } catch (Exception e) {
                    client.sendTaskFailure(new SendTaskFailureRequest().withTaskToken(
                            getActivityTaskResult.getTaskToken()));
                }
            } else {
                Thread.sleep(1000);
            }
        }
    }
}

참고

이 예제의 EnvironmentVariableCredentialsProvider 클래스는 AWS_ACCESS_KEY_ID(또는 AWS_ACCESS_KEY) 및 AWS_SECRET_KEY(또는 AWS_SECRET_ACCESS_KEY) 환경 변수가 설정되어 있다고 가정합니다. AWSCredentialsProvider팩토리에 필요한 자격 증명을 제공하는 방법에 대한 자세한 내용은 AWS SDK for Java 개발자 안내서의AWS SDK for Java API 참조 및 개발용 AWS 자격 증명 및 지역 설정을 참조하십시오.

기본적으로 AWS SDK는 모든 작업에 대해 서버로부터 데이터를 수신할 때까지 최대 50초 동안 대기합니다. GetActivityTask 작업은 사용 가능한 다음 작업에 대해 최대 60초 동안 대기하는 긴 폴링 작업입니다. SocketTimeoutException오류 수신을 SocketTimeout 방지하려면 70초로 설정합니다.

GetActivityTaskRequest().withActivityArn() 생성자의 파라미터 목록에서 ACTIVITY_ARN 값을 앞에서 생성한 활동 작업의 ARN으로 바꿉니다.

4단계: 상태 시스템 실행

상태 시스템 실행을 시작하면 작업자가 활동에 대해 Step Functions를 폴링하고 작업을 수행(제공한 입력 사용)하고 결과를 반환합니다.

ActivityStateMachine페이지에서 실행 시작을 선택합니다.

실행 시작 대화 상자가 표시됩니다.
실행 시작 대화 상자에서 다음을 수행합니다.
1. (선택 사항) 실행을 식별하려면 이름 상자에 해당 실행의 이름을 지정하면 됩니다. 기본적으로 Step Functions는 고유한 실행 이름을 자동으로 생성합니다.
  
  참고
  Step Functions를 사용하면 상태 머신, 실행 및 활동의 이름과 ASCII가 아닌 문자가 포함된 레이블을 만들 수 있습니다. 이러한 비 ASCII 이름은 Amazon에서 사용할 수 없습니다. CloudWatch CloudWatch 지표를 추적할 수 있도록 하려면 ASCII 문자만 사용하는 이름을 선택하십시오.
2. 입력 상자에 다음 JSON 입력을 입력하여 워크플로를 실행합니다.
```
{
  "who": "AWS Step Functions"
}
```
3. 실행 시작을 선택합니다.
4. Step Functions 콘솔은 실행 ID가 제목인 페이지로 이동합니다. 이 페이지를 실행 세부 정보 페이지라고 합니다. 실행이 진행되는 동안 또는 완료된 후에 이 페이지에서 실행 결과를 검토할 수 있습니다.
  
  실행 결과를 검토하려면 그래프 보기에서 개별 상태를 선택한 다음 단계 세부 정보 창에서 개별 탭을 선택하여 입력, 출력 및 정의가 포함된 각 상태의 세부 정보를 각각 봅니다. 실행 세부 정보 페이지에서 볼 수 있는 실행 정보에 대한 자세한 내용은 실행 세부 정보 페이지 - 인터페이스 개요 섹션을 참조하세요.

5단계: 작업자 실행 및 중지

작업자가 활동을 위해 상태 머신을 폴링하도록 하려면 작업자를 실행해야 합니다.

명령줄에서 GreeterActivities.java를 생성한 디렉터리로 이동합니다.
AWS SDK를 사용하려면 lib 및 third-party 디렉터리의 전체 경로를 빌드 파일의 종속 항목과 Java에 추가하세요. CLASSPATH 자세한 내용은 AWS SDK for Java 개발자 안내서의 SDK 다운로드 및 추출을 참조하세요.
파일을 컴파일합니다.
```
$ javac GreeterActivities.java
```
파일을 실행합니다.
```
$ java GreeterActivities
```
Step Functions 콘솔에서 실행 세부 정보 페이지로 이동합니다.
실행이 완료되면 실행 결과를 검사합니다.
작업자를 중지합니다.

javascript가 브라우저에서 비활성화되거나 사용이 불가합니다.

AWS 설명서를 사용하려면 Javascript가 활성화되어야 합니다. 지침을 보려면 브라우저의 도움말 페이지를 참조하십시오.

문서 규칙

AWS SAM을 사용하여 Step Functions 상태 시스템 만들기

Lambda를 사용하여 루프를 반복하세요