Chiama Amazon SQS con Step Functions - AWS Step Functions

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

Chiama Amazon SQS con Step Functions

Step Functions può controllare determinati AWS servizi direttamente da Amazon States Language (ASL). Per ulteriori informazioni, consultare Uso di altri servizi e Passa i parametri a un'API di servizio.

In che modo l'integrazione ottimizzata di Amazon SQS è diversa dall'integrazione con Amazon SQS SDK AWS

Non ci sono ottimizzazioni per i modelli di integrazione. Richiesta e risposta Attendere un callback con il token dell’attività

API Amazon SQS supportate:

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 si inviano o si ricevono dati da un altro servizio. Per informazioni, consulta Quote relative alle esecuzioni di macchine a stati.

I parametri in sono espressi in Step Functions PascalCase

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

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 Attendere un callback con il token dell’attività.

{  
   "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.

Per informazioni su come configurare le IAM autorizzazioni quando vengono utilizzate Step Functions con altri AWS servizi, consulta. Politiche IAM per servizi integrati