Envie mensagens para uma SQS fila da Amazon com Step Functions - AWS Step Functions
Suportado APIsIAMpolíticas

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Envie mensagens para uma SQS fila da Amazon com Step Functions

Aprenda a usar o Step Functions para enviar mensagens para uma SQS fila da Amazon. Esta página lista as SQS API ações suportadas da Amazon e fornece exemplos de Task estados para enviar mensagens para uma fila.

Para saber mais sobre a integração com AWS serviços em Step Functions, consulte e. Integração de produtos da Passando parâmetros para um serviço API em Step Functions

Principais recursos da SQS integração otimizada com a Amazon

Não há otimizações para os padrões de integração Resposta de solicitação ou Aguarde um retorno de chamada com o token de tarefa.

O seguinte inclui um Task estado que envia uma mensagem do Amazon Simple Queue Service (AmazonSQS).

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

O seguinte inclui um Task estado que publica em uma SQS fila da Amazon e, em seguida, espera que o token da tarefa seja retornado. Consulte Aguarde um retorno de chamada com o token de tarefa.

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

Para saber mais sobre o recebimento de mensagens na AmazonSQS, consulte Receber e excluir sua mensagem no Guia do desenvolvedor do Amazon Simple Queue Service.

Amazon compatível SQS APIs

Parâmetros em Step Functions são expressos em PascalCase

Mesmo se o serviço nativo API estiver ativadocamelCase, por exemplo, a API açãostartSyncExecution, você especifica parâmetros em PascalCase, como:StateMachineArn.

nota

Há uma cota para o tamanho máximo de dados de entrada ou resultado para uma tarefa no Step Functions. Isso restringe você a 256 KB de dados como uma string codificada em UTF -8 quando você envia ou recebe dados de outro serviço. Consulte Cotas relacionadas a execuções de máquina de estado.

IAMpolíticas para ligar para a Amazon SQS

Os modelos de exemplo a seguir mostram como AWS Step Functions gera IAM políticas com base nos recursos em sua definição de máquina de estado. Para ter mais informações, consulte Como o Step Functions gera IAM políticas para serviços integrados e Descubra padrões de integração de serviços em Step Functions.

Recursos estáticos

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

Recursos dinâmicos

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