Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Elabora messaggi ad alto volume da Amazon SQS con i flussi di lavoro Step Functions Express

Questo progetto di esempio dimostra come utilizzare un AWS Step Functions Express Workflow per elaborare messaggi o dati da una fonte di eventi ad alto volume, come Amazon Simple Queue Service (AmazonSQS). Dal momento che i flussi di lavoro Express possono essere avviati a una velocità molto elevata, sono ideali per i carichi di lavoro di elaborazione eventi o di streaming dei dati a volume elevato.

Di seguito sono indicati due metodi utilizzati comunemente per eseguire la macchina a stati da un'origine evento:

Questo progetto di esempio utilizza il secondo metodo per avviare un'esecuzione ogni volta che la SQS coda Amazon invia un messaggio. Puoi utilizzare una configurazione simile per attivare l'esecuzione di Express Workflows da altre fonti di eventi, come Amazon Simple Storage Service (Amazon S3), Amazon DynamoDB e Amazon Kinesis.

Per ulteriori informazioni sulle integrazioni dei servizi Express Workflows e Step Functions, consulta quanto segue:

Fase 1: Creare la macchina a stati

I passaggi successivi dipendono dalla scelta precedente:

Fase 2: Attivare l'esecuzione della macchina a stati

Esempio di codice di funzione Lambda

Di seguito è riportato il codice della funzione Lambda che mostra come la funzione Lambda di avvio avvia l'esecuzione di una macchina a stati utilizzando AWS SDK.

import boto3

def lambda_handler(event, context):
    message_body = event['Records'][0]['body']
    client = boto3.client('stepfunctions')
    response = client.start_execution(
        stateMachineArn='${ExpressStateMachineArn}',
        input=message_body
    )

Esempio di codice della macchina a stati

Il flusso di lavoro Express in questo progetto di esempio consiste in un insieme di funzioni Lambda per l'elaborazione del testo.

Per ulteriori informazioni su come AWS Step Functions può controllarne altri AWS servizi, vediIntegrazione dei servizi con Step Functions.

{
  "Comment": "An example of using Express workflows to run text processing for each message sent from an SQS queue.",
  "StartAt": "Decode base64 string",
  "States": {
    "Decode base64 string": {
      "Type": "Task",
      "Resource": "arn:<PARTITION>:states:::lambda:invoke",
      "OutputPath": "$.Payload",
      "Parameters": {
        "FunctionName": "<BASE64_DECODER_LAMBDA_FUNCTION_NAME>",
        "Payload.$": "$"
      },
      "Next": "Generate statistics"
    },
    "Generate statistics": {
      "Type": "Task",
      "Resource": "arn:<PARTITION>:states:::lambda:invoke",
      "OutputPath": "$.Payload",
      "Parameters": {
        "FunctionName": "<TEXT_STATS_GENERATING_LAMBDA_FUNCTION_NAME>",
        "Payload.$": "$"
      },
      "Next": "Remove special characters"
    },
    "Remove special characters": {
      "Type": "Task",
      "Resource": "arn:<PARTITION>:states:::lambda:invoke",
      "OutputPath": "$.Payload",
      "Parameters": {
        "FunctionName": "<STRING_CLEANING_LAMBDA_FUNCTION_NAME>",
        "Payload.$": "$"
      },
      "Next": "Tokenize and count"
    },
    "Tokenize and count": {
      "Type": "Task",
      "Resource": "arn:<PARTITION>:states:::lambda:invoke",
      "OutputPath": "$.Payload",
      "Parameters": {
        "FunctionName": "<TOKENIZING_AND_WORD_COUNTING_LAMBDA_FUNCTION_NAME>",
        "Payload.$": "$"
      },
      "End": true
    }
  }
}

IAMEsempio

In questo esempio AWS Identity and Access Management (IAM) la politica generata dal progetto di esempio include il minimo privilegio necessario per eseguire la macchina a stati e le risorse correlate. Ti consigliamo di includere solo le autorizzazioni necessarie nelle tue IAM politiche.

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Action": [
                "lambda:InvokeFunction"
            ],
            "Resource": [
                "arn:aws:lambda:us-east-1:123456789012:function:example-Base64DecodeLambda-wJalrXUtnFEMI",
                "arn:aws:lambda:us-east-1:123456789012:function:example-StringCleanerLambda-je7MtGbClwBF",
                "arn:aws:lambda:us-east-1:123456789012:function:example-TokenizerCounterLambda-wJalrXUtnFEMI",
                "arn:aws:lambda:us-east-1:123456789012:function:example-GenerateStatsLambda-je7MtGbClwBF"
            ],
            "Effect": "Allow"
        }
    ]
}

La seguente politica garantisce che vi siano autorizzazioni sufficienti per i CloudWatch registri.

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Action": [
                "logs:CreateLogDelivery",
                "logs:GetLogDelivery",
                "logs:UpdateLogDelivery",
                "logs:DeleteLogDelivery",
                "logs:ListLogDeliveries",
                "logs:PutResourcePolicy",
                "logs:DescribeResourcePolicies",
                "logs:DescribeLogGroups"
            ],
            "Resource": [
                "*"
            ],
            "Effect": "Allow"
        }
    ]
}

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