Ações do AWS SQS

visualização

Ainda estamos trabalhando nesse recurso, mas adoraríamos que você experimentasse!

Atualmente, esse recurso é fornecido como parte de um programa de visualização de acordo com nossas políticas de pré-lançamento.

Esta página fornece uma referência completa para as ações do AWS SQS disponíveis no catálogo de ações de automação de fluxo de trabalho. Essas ações permitem enfileirar operações no SQS.

Pré-requisitos

Antes de usar as ações AWS na automação do fluxo de trabalho, certifique-se de ter:

Uma conta da AWS com as permissões apropriadas.
Credenciais da AWS configuradas (credenciais de usuário do IAM, ARN da função do IAM ou credenciais de sessão).
As permissões IAM necessárias para os serviços específicos da AWS que você planeja usar.

Consulte Configurar credenciais AWS para obter informações sobre como criar usuários e funções do IAM e configurar credenciais estáticas e de sessão AWS para integração com as ações de automação de fluxo de trabalho AWS.

Envia uma mensagem para uma fila específica do Amazon SQS.

Campo de entrada	Opcionalidade	Tipo	Exemplo
awsRoleArn	Opcional	Corda	`arn:aws:iam::123456789012:role/my-workflow-role`
awsAccessKeyId	Opcional	Corda	`${{ :secrets:<awsAccessKeyId> }}`
awsSecretAccessKey	Opcional	Corda	`${{ :secrets:<awsSecretAccessKey> }}`
awsSessionToken	Opcional	Corda	`${{ :secrets:<awsSessionToken> }}`
região	Obrigatório	Corda	`"us-east-2"`
queueUrl	Obrigatório	Corda	" `https://sqs.us-east-2.amazonaws.com/123456789012/my-queue` "
messageBody	Obrigatório	Corda	`"This is a test message"`
messageDeduplicationId	Opcional	Corda	`"abc123deduplicationId5678"`
messageGroupId	Opcional	Corda	`"group1"`
messageAttributes	Opcional	Mapa	`{ "my_attribute_name_1": { "DataType": "String", "StringValue":"my_attribute_value_1"},` `"my_attribute_name_2": { "DataType": "String", "StringValue":"my_attribute_value_2"}}`
delaySeconds	Opcional	Interno	`123`

Campo de saída	Tipo	Exemplo
response	objeto	`{"statusCode":200, "payload":{"status":"success","data":{"MessageId":"e9b73a52-d018-4a73-9fcd-8efb682fba43","MD5OfMessageBody":"fae535c7f7c5687a1c3d8bc52288e33a","MD5OfMessageAttributes":"3ae3c4f59958e031d0d53af2d157e834", }, "message":"Message sent successfully to the SQS queue." }}` A sintaxe de resposta pode ser consultada na documentação do Boto3 sobre o comando `send_message` do SQS.
sucesso	Boleano	`success: true \| false`
mensagem de erro	Corda	`"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""`

Campo de saída

Tipo

Exemplo

response

objeto

{"statusCode":200, "payload":{"status":"success","data":{"MessageId":"e9b73a52-d018-4a73-9fcd-8efb682fba43","MD5OfMessageBody":"fae535c7f7c5687a1c3d8bc52288e33a","MD5OfMessageAttributes":"3ae3c4f59958e031d0d53af2d157e834", }, "message":"Message sent successfully to the SQS queue." }}

A sintaxe de resposta pode ser consultada na documentação do Boto3 sobre o comando `send_message` do SQS.

sucesso

Boleano

success: true | false

mensagem de erro

Corda

"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""

Exemplo de fluxo de trabalho
name: sqs-send-message-test description: Sends a message to an SQS queue workflowInputs: arnRole: type: String steps: - name: aws_sqs_sendMessage_1 type: action action: aws.sqs.sendMessage version: '1' inputs: awsRoleArn: ${{ .workflowInputs.arnRole }} region: us-east-2 queueUrl: https://sqs.us-east-2.amazonaws.com/123456789012/workflow-test-queue messageBody: "This is a test message" messageAttributes: my_attribute_name_1: DataType: "String" StringValue: "my_attribute_value_1" my_attribute_name_2: DataType: "String" StringValue: "my_attribute_value_2" next: end

Exemplo de fluxo de trabalho

name: sqs-send-message-test
description: Sends a message to an SQS queue
workflowInputs:
  arnRole:
    type: String
steps:
  - name: aws_sqs_sendMessage_1
    type: action
    action: aws.sqs.sendMessage
    version: '1'
    inputs:
      awsRoleArn: ${{ .workflowInputs.arnRole }}
      region: us-east-2
      queueUrl: https://sqs.us-east-2.amazonaws.com/123456789012/workflow-test-queue
      messageBody: "This is a test message"
      messageAttributes:
        my_attribute_name_1:
          DataType: "String"
          StringValue: "my_attribute_value_1"
        my_attribute_name_2:
          DataType: "String"
          StringValue: "my_attribute_value_2"
    next: end

Recupera uma ou mais mensagens da fila especificada.

Campo de entrada	Opcionalidade	Tipo	Exemplo
awsRoleArn	Opcional	Corda	`arn:aws:iam::123456789012:role/my-workflow-role`
awsAccessKeyId	Opcional	Corda	`${{ :secrets:<awsAccessKeyId> }}`
awsSecretAccessKey	Opcional	Corda	`${{ :secrets:<awsSecretAccessKey> }}`
awsSessionToken	Opcional	Corda	`${{ :secrets:<awsSessionToken> }}`
região	Obrigatório	Corda	`"us-east-2"`
queueUrl	Obrigatório	Corda	" `https://sqs.us-east-2.amazonaws.com/123456789012/my-queue` "
maxNumberOfMessages	Opcional	Interno	`10`
waitTimeSeconds	Opcional	Interno	`5`
VisibilityTimeout	Opcional	Interno	`123`
AttributeNames	Opcional	Lista	`[ 'All'\|'Policy'\|'VisibilityTimeout'\|'MaximumMessageSize'\|'MessageRetentionPeriod'\|'ApproximateNumberOfMessages'\|'ApproximateNumberOfMessagesNotVisible'\|'CreatedTimestamp'\|'LastModifiedTimestamp'\|'QueueArn'\|'ApproximateNumberOfMessagesDelayed'\|'DelaySeconds'\|'ReceiveMessageWaitTimeSeconds'\|'RedrivePolicy'\|'FifoQueue'\|'ContentBasedDeduplication'\|'KmsMasterKeyId'\|'KmsDataKeyReusePeriodSeconds'\|'DeduplicationScope'\|'FifoThroughputLimit'\|'RedriveAllowPolicy'\|'SqsManagedSseEnabled', ]`
messageAttributeNames	Opcional	Lista	`[ 'message_attribute_name', ],`
messageSystemAttributeNames	Opcional	Lista	`['SenderId', 'SentTimestamp']`
receiveRequestAttemptId	Opcional	Corda	`"req-1234abcd"`

Campo de saída	Tipo	Exemplo
response	objeto	`{"response":<aws api response> }` A sintaxe de resposta pode ser consultada em receive_message - documentação do Boto3](https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sqs/client/receive_message.html)
sucesso	Boleano	`success: true \| false`
mensagem de erro	Corda	`"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""`

Campo de saída

Tipo

Exemplo

response

objeto

{"response":<aws api response> }

A sintaxe de resposta pode ser consultada em receive_message - documentação do Boto3](https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sqs/client/receive_message.html)

sucesso

Boleano

success: true | false

mensagem de erro

Corda

"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""

name: sqs-receive-message-test
  description: 'Receives a message from an SQS queue'
  steps:
    - name: aws_sqs_receiveMessage_1
      type: action
      action: aws.sqs.receiveMessage
      version: '1'
      inputs:
        awsRoleArn: ${{ :secrets:awsRoleArn }}
        region: us-east-1
        queueUrl: https://sqs.us-east-1.amazonaws.com/123456789012/workflow-test-queue
        waitTimeSeconds: 5
        maxNumberOfMessages: 10
        messageAttributeNames: ['message_attribute_name'],

Esta tradução de máquina é fornecida para sua comodidade.

visualização

Pré-requisitos

Enviar uma mensagem para uma fila do AWS SQS

Recebe uma mensagem de uma fila AWS SQS.

Esta tradução de máquina é fornecida para sua comodidade.

Ações do AWS SQS

visualização

Pré-requisitos.css-21sua1{background:none;border:none;width:0;padding:0;}

Recebe uma mensagem de uma fila AWS SQS.

Pré-requisitos