Digibee.comDigibee Academy

SQS (AWS)

Descubra mais sobre o componente SQS (AWS) e saiba como utilizá-lo na Digibee Integration Platform.

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.

Parâmetros

Dê uma olhada nas opções de configuração do componente. Parâmetros suportados por expressões Double Braces estão marcados com (DB).

Parâmetro
Descrição
Valor padrão
Tipo de dado

Account

N/A

String

Message

Corpo da mensagem que deseja enviar.

{{ message.$ }}

String

Connection String (DB)

URL de destino da fila SQS na AWS.

String

Region

Região na qual a fila está registrada no serviço na AWS.

South America (Sao Paulo)

String

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:

Standard

String

Message Group ID

Em filas do tipo FIFO, este é o ID do message group desta fila.

N/A

String

Fail on Error

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

False

Booleano

Fluxo de mensagens

Fila AWS SQS Standard (envio sem erro)

Payload

{
    "queueTest": "MyTestQueue"
}

Entrada

{
    "url": "https://sqs.sa-east-1.amazonaws.com/381492217694/{{message.queueTest}}",
    "typeQueue": "STANDARD",
    "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"
}

Fila AWS SQS FIFO (envio sem erro)

Entrada

{
    "url": "https://sqs.sa-east-1.amazonaws.com/123456789012/digibee-test.fifo",
    "typeQueue":"FIFO",
    "messageGroupId":"mygroup",
    "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"
}

Fila AWS SQS FIFO (envio sem messageGroupId)

Entrada

{
    "url": "https://sqs.sa-east-1.amazonaws.com/123456789012/digibee-test.fifo",
    "typeQueue": "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"
}

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

Entrada

{
    "url": "https://sqs.sa-east-1.amazonaws.com/123456789012/digibee-test",
    "typeQueue":"STANDARD",
    "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)"
}

Leia nosso artigo sobre Processamento de mensagens para entender como a Digibee Integration Platform processa o fluxo de mensagens.

AnteriorRabbitMQPróximoSecurity components

Atualizado