Step Functions와 SNS Amazon을 사용하여 AWS Batch 작업 결과를 알리십시오.

이 샘플 프로젝트는 SNS Amazon을 사용하여 성공 또는 Step Functions 실패에 대한 알림을 제공하는 오류 처리 기능을 갖춘 상태 머신을 사용하여 AWS Batch 작업을 실행하는 방법을 보여줍니다.

이 프로젝트에서 Step Functions은 상태 시스템을 사용하여 AWS Batch 작업을 동기식으로 호출합니다. 그런 다음 작업이 성공 또는 실패하기까지 기다리고 작업이 실패하면 오류를 재시도 및 포착한 다음 작업 성공 또는 실패 여부에 대한 메시지와 함께 Amazon SNS 주제를 전송합니다.

1단계: 상태 시스템 만들기 및 리소스 프로비저닝

2단계: 상태 시스템 실행

예제 상태 머신 코드

이 샘플 프로젝트의 상태 머신은 매개변수를 해당 리소스에 직접 SNS 전달하여 AWS Batch Amazon과 통합됩니다.

이 예제 상태 머신을 살펴보고 Resource 필드의 Amazon 리소스 이름 (ARN) SNS 에 연결하고 서비스에 전달하여 Step Functions가 Parameters Amazon을 제어하는 AWS Batch 방법을 살펴봅니다API.

다른 AWS 서비스를 제어하는 방법에 AWS Step Functions 대한 자세한 내용은 을 참조하십시오Step Functions와 다른 서비스 통합.

{
  "Comment": "An example of the Amazon States Language for notification on an AWS Batch job completion",
  "StartAt": "Submit Batch Job",
  "TimeoutSeconds": 3600,
  "States": {
    "Submit Batch Job": {
      "Type": "Task",
      "Resource": "arn:aws:states:::batch:submitJob.sync",
      "Parameters": {
        "JobName": "BatchJobNotification",
        "JobQueue": "arn:aws:batch:us-west-2:123456789012:job-queue/BatchJobQueue-123456789abcdef",
        "JobDefinition": "arn:aws:batch:us-west-2:123456789012:job-definition/BatchJobDefinition-123456789abcdef:1"
      },
      "Next": "Notify Success",
      "Retry": [
        {
          "ErrorEquals": [
            "States.ALL"
          ],
          "IntervalSeconds": 30,
          "MaxAttempts": 2,
          "BackoffRate": 1.5
        }
      ],
      "Catch": [
        {
          "ErrorEquals": [ "States.ALL" ],
          "Next": "Notify Failure"
        }
      ]
    },
    "Notify Success": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "Message": "Batch job submitted through Step Functions succeeded",
        "TopicArn": "arn:aws:sns:us-west-2:123456789012:StepFunctionsSample-BatchJobManagement12345678-9abc-def0-1234-567890abcdef-SNSTopic-A2B3C4D5E6F7G"
      },
      "End": true
    },
    "Notify Failure": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sns:publish",
      "Parameters": {
        "Message": "Batch job submitted through Step Functions failed",
        "TopicArn": "arn:aws:sns:us-west-2:123456789012:StepFunctionsSample-BatchJobManagement12345678-9abc-def0-1234-567890abcdef-SNSTopic-A2B3C4D5E6F7G"
      },
      "End": true
    }
  }
}

IAM예시

샘플 프로젝트에서 생성된 이 예제 AWS Identity and Access Management (IAM) 정책에는 스테이트 머신 및 관련 리소스를 실행하는 데 필요한 최소 권한이 포함되어 있습니다. IAM정책에 필요한 권한만 포함하는 것이 좋습니다.

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Action": [
                "sns:Publish"
            ],
            "Resource": [
                "arn:aws:sns:us-west-2:123456789012:StepFunctionsSample-BatchJobManagement12345678-9abc-def0-1234-567890abcdef-SNSTopic-A2B3C4D5E6F7G"
            ],
            "Effect": "Allow"
        },
        {
            "Action": [
                "batch:SubmitJob",
                "batch:DescribeJobs",
                "batch:TerminateJob"
            ],
            "Resource": "*",
            "Effect": "Allow"
        },
        {
            "Action": [
                "events:PutTargets",
                "events:PutRule",
                "events:DescribeRule"
            ],
            "Resource": [
                "arn:aws:events:us-west-2:123456789012:rule/StepFunctionsGetEventsForBatchJobsRule"
            ],
            "Effect": "Allow"
        }
    ]
}

Step Functions를 다른 AWS 서비스와 함께 사용할 IAM 때 구성하는 방법에 대한 자세한 내용은 을 참조하십시오Step Functions가 통합 서비스를 위한 IAM 정책을 생성하는 방법.