LambdaDynamoDB, 및 를 사용하여 데이터 레코드 전송 Amazon SQS

이 샘플 프로젝트에서는 Step Functions 상태 시스템을 사용하여 Amazon DynamoDB 테이블에서 항목을 반복해서 읽고 이러한 항목을 Amazon SQS 대기열로 보내는 방법을 보여줍니다. 이 샘플 프로젝트를 배포하면 Step Functions 상태 시스템, DynamoDB 테이블, AWS Lambda 함수 및 Amazon SQS 대기열이 생성됩니다.

이 프로젝트에서 Step Functions는 Lambda 함수를 사용하여 DynamoDB 테이블을 채웁니다. 또한 상태 시스템은 for 루프를 사용하여 각 항목을 읽은 다음 각 항목을 Amazon SQS 대기열로 보냅니다.

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

2단계: 상태 시스템 실행

예제 상태 머신 코드

이 샘플 프로젝트의 상태 머신은 파라미터를 해당 리소스에 직접 전달하여 DynamoDB 및 SQS Amazon과 통합됩니다.

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

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

{
  "Comment" : "An example of the Amazon States Language for reading messages from a DynamoDB table and sending them to SQS",
  "StartAt": "Seed the DynamoDB Table",
  "TimeoutSeconds": 3600,
  "States": {
    "Seed the DynamoDB Table": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:sqsconnector-SeedingFunction-T3U43VYDU5OQ",
      "ResultPath": "$.List",
      "Next": "For Loop Condition"
    },
    "For Loop Condition": {
      "Type": "Choice",
      "Choices": [
        {
          "Not": {
            "Variable": "$.List[0]",
            "StringEquals": "DONE"
          },
          "Next": "Read Next Message from DynamoDB"
        }
      ],
      "Default": "Succeed"
    },
    "Read Next Message from DynamoDB": {
      "Type": "Task",
      "Resource": "arn:aws:states:::dynamodb:getItem",
      "Parameters": {
        "TableName": "sqsconnector-DDBTable-1CAFOJWP8QD6I",
        "Key": {
          "MessageId": {"S.$": "$.List[0]"}
        }
      },
      "ResultPath": "$.DynamoDB",
      "Next": "Send Message to SQS"
    },
    "Send Message to SQS": {
      "Type": "Task",
      "Resource": "arn:aws:states:::sqs:sendMessage",
      "Parameters": {
        "MessageBody.$": "$.DynamoDB.Item.Message.S",
        "QueueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/sqsconnector-SQSQueue-QVGQBW134PWK"
      },
      "ResultPath": "$.SQS",
      "Next": "Pop Element from List"
    },
    "Pop Element from List": {
      "Type": "Pass",
      "Parameters": {
        "List.$": "$.List[1:]"
      },
      "Next": "For Loop Condition"
    },
    "Succeed": {
      "Type": "Succeed"
    }
  }
}

파라미터 전달 및 결과 관리에 대한 자세한 내용은 다음을 참조하십시오.

IAM예시

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

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Action": [
                "dynamodb:GetItem"
            ],
            "Resource": [
                "arn:aws:dynamodb:ap-northeast-1:123456789012:table/TransferDataRecords-DDBTable-3I41R5L5EAGT"
            ],
            "Effect": "Allow"
        },
        {
            "Action": [
                "sqs:SendMessage"
            ],
            "Resource": [
                "arn:aws:sqs:ap-northeast-1:123456789012:TransferDataRecords-SQSQueue-BKWXTS09LIW1"
            ],
            "Effect": "Allow"
        },
        {
            "Action": [
                "lambda:invokeFunction"
            ],
            "Resource": [
                "arn:aws:lambda:ap-northeast-1:123456789012:function:TransferDataRecords-SeedingFunction-VN4KY2TPAZSR"
            ],
            "Effect": "Allow"
        }
    ]
}

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