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

Step Functions 콘솔 왼쪽에 있는 탐색 창에서 활동을 선택합니다.

활동 생성을 선택합니다.

활동 이름(예: get-greeting)을 입력한 다음 활동 생성을 선택합니다.

활동 작업이 생성되면 다음 예제와 같이 해당 ARN을 적어 둡니다.

arn:aws:states:us-east-1:123456789012:activity:get-greeting

Step Functions 콘솔 왼쪽에 있는 탐색 창에서 상태 시스템을 선택합니다.

상태 시스템 페이지에서 상태 시스템 생성을 선택합니다.

템플릿 선택 대화 상자에서 공백을 선택합니다.

선택을 선택하여 디자인 모드에서 Workflow Studio를 엽니다.

이 자습서에서는 상태 시스템의 Amazon States Language(ASL) 정의를 코드 편집기에서 작성합니다. 이렇게 하려면 코드를 선택합니다.

기존 보일러플레이트 코드를 제거하고 다음 코드를 붙여넣습니다. Resource 필드의 예제 ARN을 앞에서 생성한 활동 작업의 ARN으로 바꿔야 합니다1단계: 활동 생성.

{
  "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을 제공합니다.

역할 생성 확인 대화 상자에서 확인을 선택하여 계속합니다.

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

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);
            }
        }
    }
}

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

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

실행 시작 대화 상자가 표시됩니다.

실행 시작 대화 상자에서 다음을 수행합니다.

1. (선택 사항) 생성된 기본값을 재정의하려면 사용자 지정 실행 이름을 입력합니다.

   비 ASCII 이름 및 로깅

   Step Functions는 비 ASCII 문자가 포함된 상태 시스템, 실행, 활동 및 레이블 이름을 허용합니다. 이러한 문자는 Amazon CloudWatch에서 작동하지 않으므로 CloudWatch에서 지표를 추적할 수 있도록 ASCII 문자만 사용하는 것이 좋습니다.

2. 입력 상자에 다음 JSON 입력을 입력하여 워크플로를 실행합니다.

   {
     "who": "AWS Step Functions"
   }

3. 실행 시작을 선택합니다.

4. Step Functions 콘솔은 실행 ID가 제목인 페이지로 이동합니다. 이 페이지를 실행 세부 정보 페이지라고 합니다. 실행이 진행되는 동안 또는 완료된 후에 이 페이지에서 실행 결과를 검토할 수 있습니다.

   실행 결과를 검토하려면 그래프 보기에서 개별 상태를 선택한 다음 단계 세부 정보 창에서 개별 탭을 선택하여 입력, 출력 및 정의가 포함된 각 상태의 세부 정보를 각각 봅니다. 실행 세부 정보 페이지에서 볼 수 있는 실행 정보에 대한 자세한 내용은 실행 세부 정보 개요 섹션을 참조하세요.

명령줄에서 GreeterActivities.java를 생성한 디렉터리로 이동합니다.

AWS SDK를 사용하려면 lib 및 third-party 디렉터리의 전체 경로를 빌드 파일의 종속성과 Java에 추가합니다CLASSPATH. 자세한 내용은 AWS SDK for Java 개발자 안내서의 SDK 다운로드 및 추출을 참조하세요.

파일을 컴파일합니다.

$ javac GreeterActivities.java

파일을 실행합니다.

$ java GreeterActivities

Step Functions 콘솔에서 실행 세부 정보 페이지로 이동합니다.

실행이 완료되면 실행 결과를 검사합니다.

작업자를 중지합니다.