Invia messaggi a una coda Amazon SQS con Step Functions - AWS Step Functions
Supportato APIsPolicy IAM

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à.

Invia messaggi a una coda Amazon SQS con Step Functions

Scopri come utilizzare Step Functions per inviare messaggi a una coda Amazon SQS. Questa pagina elenca le azioni dell'API Amazon SQS supportate e fornisce esempi di Task stati per inviare messaggi a una coda.

Per ulteriori informazioni sull'integrazione con AWS i servizi in Step Functions, vedere Integrazione dei servizi ePassaggio di parametri a un'API di servizio in Step Functions.

Caratteristiche principali dell'integrazione ottimizzata con Amazon SQS

Non sono previste ottimizzazioni per i modelli Richiesta e risposta di Attendi una richiamata con Task Token integrazione.

Quanto segue include uno Task stato che invia un messaggio Amazon Simple Queue Service (Amazon SQS).

{
 "StartAt": "Send to SQS",
 "States": {
   "Send to SQS": {
     "Type": "Task",
     "Resource": "arn:aws:states:::sqs:sendMessage",
     "Parameters": {
       "QueueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/myQueue",
       "MessageBody.$": "$.input.message",
       "MessageAttributes": {
         "my_attribute_no_1": {
           "DataType": "String",
           "StringValue": "attribute1"
         },
         "my_attribute_no_2": {
           "DataType": "String",
           "StringValue": "attribute2"
         }
       }
     },
     "End": true
    }
  }
}

Quanto segue include uno Task stato che pubblica su una coda Amazon SQS e quindi attende la restituzione del token dell'attività. Per informazioni, consulta Attendi una richiamata con Task Token.

{  
   "StartAt":"Send message to SQS",
   "States":{  
      "Send message to SQS":{  
         "Type":"Task",
         "Resource":"arn:aws:states:::sqs:sendMessage.waitForTaskToken",
         "Parameters":{  
            "QueueUrl":"https://sqs.us-east-1.amazonaws.com/123456789012/myQueue",
            "MessageBody":{  
               "Input.$":"$",
               "TaskToken.$":"$$.Task.Token"
            }
         },
         "End":true
      }
   }
}

Per ulteriori informazioni sulla ricezione di messaggi in Amazon SQS, consulta Receive and Delete Your Message nella Amazon Simple Queue Service Developer Guide.

Amazon SQS ottimizzato APIs

Parametri in Step Functions sono espressi in PascalCase

Anche se l'API del servizio nativo è in CamelCase, ad esempio l'startSyncExecutionazione API, si specificano parametri PascalCase in, ad esempio:. StateMachineArn

Nota

Esiste una quota per la dimensione massima dei dati di input o risultato per un'attività in Step Functions. Ciò limita a 256 KB di dati come stringa con codifica UTF-8 quando invii o ricevi dati da un altro servizio. Per informazioni, consulta Quote relative alle esecuzioni di macchine a stati.

Politiche IAM per le chiamate ad Amazon SQS

I seguenti modelli di esempio mostrano come AWS Step Functions generare le politiche IAM in base alle risorse nella definizione della macchina a stati. Per ulteriori informazioni, consulta In che modo Step Functions genera policy IAM per servizi integrati e Scopri i modelli di integrazione dei servizi in Step Functions.

Risorse statiche

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "sqs:SendMessage"
            ],
            "Resource": [
                "arn:aws:sqs:[[region]]:[[accountId]]:[[queueName]]"
            ]
        }
    ]
}

Risorse dinamiche

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "sqs:SendMessage"
            ],
            "Resource": "*"
        }
    ]
}