Trasferisci i record di dati con LambdaDynamoDB, e Amazon SQS

Questo progetto di esempio dimostra come leggere iterativamente gli elementi da una Amazon DynamoDB tabella e inviarli a una Amazon SQS coda utilizzando una macchina a stati. Step Functions L'implementazione di questo progetto di esempio creerà una macchina a Step Functions stati, una DynamoDB tabella, una AWS Lambda funzione e una coda. Amazon SQS

In questo progetto, Step Functions utilizza la Lambda funzione per popolare la tabella. DynamoDB La macchina a stati utilizza anche un for ciclo per leggere ciascuna voce e quindi invia ogni voce a una Amazon SQS coda.

Fase 1: Creare la macchina a stati e fornire risorse

Fase 2: Eseguire la macchina a stati

Esempio di codice della macchina a stati

La macchina a stati di questo progetto di esempio si integra con DynamoDB e SQS Amazon passando i parametri direttamente a tali risorse.

Sfoglia questo esempio di macchina a stati per vedere come Step Functions controlla DynamoDB e SQS Amazon connettendosi ad Amazon Resource ARN Name () Resource sul campo e Parameters passando al servizio. API

Per ulteriori informazioni su come AWS Step Functions controllare altri AWS servizi, consulta. Integrazione di altri servizi con 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"
    }
  }
}

Per ulteriori informazioni sul trasferimento di parametri e sulla gestione dei risultati, consultare i seguenti argomenti:

IAMEsempio

Questa politica di esempio AWS Identity and Access Management (IAM) generata dal progetto di esempio include il minimo privilegio necessario per eseguire la macchina a stati e le risorse correlate. È consigliabile includere solo le autorizzazioni necessarie nelle politiche. 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"
        }
    ]
}

Per informazioni su come configurare l'IAMutilizzo di Step Functions con altri AWS servizi, vedereIn che modo Step Functions genera IAM politiche per servizi integrati.