SQS

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

O componente SQS 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	Para o componente se autenticar na cloud da AWS, é necessário usar uma conta tipo Basic. Para saber mais sobre essas contas e outros tipos existentes, leia a doumentação.	N/A	String
Message	Corpo da mensagem que deseja enviar.	{{ message.$ }}	String
Connection String (DB)	URL de destino da fila SQS na AWS.	https://sqs.sa-east-1.amazonaws.com/838874755216/digibee-test	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.