IMPORTANTE: Esta documentação foi descontinuada. Leia a documentação SQS (AWS) - NEW atualizada no nosso novo portal de documentação.

O componente SQS (AWS) permite o envio de mensagens para filas do serviço da AWS SQS, tanto do tipo standard como do tipo FIFO.

Dê uma olhada nos parâmetros de configuração do componente:

Account: necessário para o componente se autenticar na cloud da AWS. Este deve ser do tipo BASIC.

Message: corpo da mensagem que deseja enviar. Este parâmetro aceita Double Braces.
Name of the Queue: nome da fila na AWS.

Connection String: URL de destino da fila SQS na AWS.
Region: região na qual a fila está registrada no serviço na AWS.

Queue Type: tipo de fila que receberá a mensagem. Este pode ser do tipo STANDARD ou FIFO. Ao selecionar FIFO, outro parâmetro é necessário

- Message Group ID: em filas do tipo FIFO, este é o ID do message group desta fila.

failOnError: se a opção estiver habilitada, a execução do pipeline com erro será interrompida; do contrário, a execução do pipeline continua, mas o resultado vai mostrar um valor falso para a propriedade "success".

Alguns dos parâmetros acima aceitam Double Braces. Para entender melhor como funciona essa linguagem, leia o nosso artigo clicando aqui.

Fluxo de mensagens

1. Fila AWS SQS Standard (envio sem erro):

Entrada

{
            "url": "https://sqs.sa-east-1.amazonaws.com/123456789012/digibee-test",
            "typeQueue":"STANDARD",
            "queue": "digibee-test",
            "messageBody": "{
     "test": "Test encryption"
  }",
            "region": "sa-east-1",
            "failOnError": false
 }

Saída

{
"messageId":"c959b1da-6650-46c2-8baf-62302789dd61",
"messageBodyMD5":"c35f05f412ea94ef45bf103ba96b7b0e",
"sequenceNumber":null,
"success":true,
"requestId":"6c950c3a-d081-5685-893b-55cf8c1b51e0"
}

2. Fila AWS SQS FIFO (envio sem erro):

Entrada

{
            "url": "https://sqs.sa-east-1.amazonaws.com/123456789012/digibee-test.fifo",
            "typeQueue":"FIFO",
            "messageGroupId":"mygroup",
            "queue": "digibee-test.fifo",
            "messageBody": "{
     "test": "Test encryption"
  }",
            "region": "sa-east-1",
            "failOnError": false
 }

Saída

{
"messageId":"c959b1da-6650-46c2-8baf-62302789dd61",
"messageBodyMD5":"c35f05f412ea94ef45bf103ba96b7b0e",
"sequenceNumber":"18865425420279279616",
"success":true,
"requestId":"6c950c3a-d081-5685-893b-55cf8c1b51e0"
}

3. Fila AWS SQS FIFO (envio sem messageGroupId):

Entrada

{
            "url": "https://sqs.sa-east-1.amazonaws.com/123456789012/digibee-test.fifo",
            "typeQueue":"FIFO",
            "queue": "digibee-test.fifo",
            "messageBody": "{
     "test": "Test encryption"
  }",
            "region": "sa-east-1",
            "failOnError": false
 }

Saída

{
"success":false,
"message":"There is an invalid pipeline configuration",
"error":"com.digibee.pipelineengine.exception.PipelineEngineConfigurationException: Configuration parameter 'messageGroupId' cannot be null for connector sqs-connector"

}

4. Fila AWS SQS (envio com região inválida):

Entrada

{
            "url": "https://sqs.sa-east-1.amazonaws.com/123456789012/digibee-test",
            "typeQueue":"STANDARD",
            "queue": "digibee-test",
            "messageBody": "{
     "test": "Test encryption"
  }",
            "region": "wrong-region",
            "failOnError": false
 }

Saída

{
"success":false,
"message":"Something went wrong while trying to execute SQS CONNECTOR",
"error":"com.amazonaws.services.sqs.model.AmazonSQSException: Credential should be scoped to a valid region, not 'wrong-region'. (Service: AmazonSQS; Status Code: 403; Error Code: SignatureDoesNotMatch; Request ID: bf47d091-2129-5320-a332-89647ef0d86b)"
}

Para entender melhor o fluxo das mensagens na Plataforma, clique aqui e leia o nosso artigo.