Acciones de AWS SQS

avance

Todavía estamos trabajando en esta característica, ¡pero nos encantaría que la probaras!

Esta característica se proporciona actualmente como parte de un programa de vista previa de conformidad con nuestras políticas de prelanzamiento.

Esta página proporciona una referencia completa de las acciones de AWS SQS disponibles en el catálogo de acciones de automatización del flujo de trabajo. Estas acciones le permiten poner en cola las operaciones de sqs.

Requisitos previos

Antes de emplear las acciones AWS en la automatización del flujo de trabajo, cerciorar de tener lo siguiente:

Una cuenta de AWS con las licencias adecuadas.
Credenciales de AWS configuradas (credenciales de usuario de IAM, ARN de rol de IAM o credenciales de sesión).
Las licencias IAM necesarios para los servicios específicos de AWS que planea emplear.

Consulte Configurar credenciales AWS para obtener información sobre cómo crear usuarios y roles de IAM, y configurar credenciales AWS estáticas y de sesión para la integración con acciones de automatización de flujo de trabajo AWS.

Envía un mensaje a una cola específica de Amazon SQS.

Campo de entrada	Opcionalidad	Tipo	Ejemplo
awsRoleArn	Opcional	Cadena	`arn:aws:iam::123456789012:role/my-workflow-role`
awsAccessKeyId	Opcional	Cadena	`${{ :secrets:<awsAccessKeyId> }}`
awsSecretAccessKey	Opcional	Cadena	`${{ :secrets:<awsSecretAccessKey> }}`
awsSessionToken	Opcional	Cadena	`${{ :secrets:<awsSessionToken> }}`
región	Requerido	Cadena	`"us-east-2"`
queueUrl	Requerido	Cadena	" `https://sqs.us-east-2.amazonaws.com/123456789012/my-queue` "
messageBody	Requerido	Cadena	`"This is a test message"`
messageDeduplicationId	Opcional	Cadena	`"abc123deduplicationId5678"`
messageGroupId	Opcional	Cadena	`"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	En t	`123`

Campo de salida	Tipo	Ejemplo
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." }}` La sintaxis de respuesta se puede consultar en la documentación de SQS send_message - Boto3
éxito	Booleano	`success: true \| false`
mensaje de error	Cadena	`"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""`

Campo de salida

Tipo

Ejemplo

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

La sintaxis de respuesta se puede consultar en la documentación de SQS send_message - Boto3

éxito

Booleano

success: true | false

mensaje de error

Cadena

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

Ejemplo de flujo de trabajo
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

Ejemplo de flujo de trabajo

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 uno o más mensajes de la cola especificada.

Campo de entrada	Opcionalidad	Tipo	Ejemplo
awsRoleArn	Opcional	Cadena	`arn:aws:iam::123456789012:role/my-workflow-role`
awsAccessKeyId	Opcional	Cadena	`${{ :secrets:<awsAccessKeyId> }}`
awsSecretAccessKey	Opcional	Cadena	`${{ :secrets:<awsSecretAccessKey> }}`
awsSessionToken	Opcional	Cadena	`${{ :secrets:<awsSessionToken> }}`
región	Requerido	Cadena	`"us-east-2"`
queueUrl	Requerido	Cadena	" `https://sqs.us-east-2.amazonaws.com/123456789012/my-queue` "
maxNumberOfMessages	Opcional	En t	`10`
waitTimeSeconds	Opcional	En t	`5`
VisibilityTimeout	Opcional	En t	`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	Cadena	`"req-1234abcd"`

Campo de salida	Tipo	Ejemplo
response	objeto	`{"response":<aws api response> }` La sintaxis de respuesta se puede consultar en la documentación de Boto3 sobre receive_message (https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sqs/client/receive_message.html).
éxito	Booleano	`success: true \| false`
mensaje de error	Cadena	`"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""`

Campo de salida

Tipo

Ejemplo

response

objeto

{"response":<aws api response> }

La sintaxis de respuesta se puede consultar en la documentación de Boto3 sobre receive_message (https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sqs/client/receive_message.html).

éxito

Booleano

success: true | false

mensaje de error

Cadena

"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'],

Te ofrecemos esta traducción automática para facilitar la lectura.

avance

Requisitos previos

Enviar un mensaje a una cola de AWS SQS

Recibe un mensaje de una cola SQS de AWS

Te ofrecemos esta traducción automática para facilitar la lectura.

Acciones de AWS SQS

avance

Requisitos previos.css-21sua1{background:none;border:none;width:0;padding:0;}

Recibe un mensaje de una cola SQS de AWS

Requisitos previos