Actions AWS SQS

Aperçu

Nous travaillons toujours sur cette fonctionnalité, mais nous aimerions que vous l'essayiez !

Cette fonctionnalité est actuellement fournie dans le cadre d'un programme d'aperçu conformément à nos politiques de pré-sortie.

Cette page fournit une référence complète des actions aws sqs disponibles dans le catalogue des actions d'automatisation des workflows. Ces actions vous permettent d'effectuer des opérations sur les files d'attente sqs.

Prérequis

Avant d'utiliser AWS Actions dans l'automatisation workflow, assurez-vous de disposer des éléments suivants :

Un compte AWS disposant des autorisations appropriées.
Informations d'identification AWS configurées (informations d'identification de l'utilisateur IAM, ARN du rôle IAM ou informations d'identification de session).
Les autorisations IAM nécessaires pour les services AWS spécifiques que vous prévoyez d'utiliser.

Consultez la section Configurer les informations d'identification AWS pour savoir comment créer un utilisateur IAM et des rôles IAM, et comment configurer les informations d'identification AWS statiques et de session pour l'intégration avec les actions AWS d'automatisation workflow.

Envoie un message à une file d'attente Amazon SQS spécifiée.

Champ de saisie	optionnalité	Type	Exemple
awsRoleArn	Facultatif	Chaîne	`arn:aws:iam::123456789012:role/my-workflow-role`
awsAccessKeyId	Facultatif	Chaîne	`${{ :secrets:<awsAccessKeyId> }}`
awsSecretAccessKey	Facultatif	Chaîne	`${{ :secrets:<awsSecretAccessKey> }}`
awsSessionToken	Facultatif	Chaîne	`${{ :secrets:<awsSessionToken> }}`
région	Requis	Chaîne	`"us-east-2"`
queueUrl	Requis	Chaîne	" `https://sqs.us-east-2.amazonaws.com/123456789012/my-queue` "
messageBody	Requis	Chaîne	`"This is a test message"`
messageDeduplicationId	Facultatif	Chaîne	`"abc123deduplicationId5678"`
messageGroupId	Facultatif	Chaîne	`"group1"`
messageAttributes	Facultatif	Carte	`{ "my_attribute_name_1": { "DataType": "String", "StringValue":"my_attribute_value_1"},` `"my_attribute_name_2": { "DataType": "String", "StringValue":"my_attribute_value_2"}}`
delaySeconds	Facultatif	Int	`123`

Champ de sortie	Type	Exemple
response	objet	`{"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 syntaxe de réponse peut être consultée dans la documentation Boto3 relative à la fonction SQS send_message.
succès	Booléen	`success: true \| false`
message d'erreur	Chaîne	`"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""`

Champ de sortie

Type

Exemple

response

objet

{"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 syntaxe de réponse peut être consultée dans la documentation Boto3 relative à la fonction SQS send_message.

succès

Booléen

success: true | false

message d'erreur

Chaîne

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

Exemple de workflow
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

Exemple de workflow

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

Récupère un ou plusieurs messages de la file d'attente spécifiée.

Champ de saisie	optionnalité	Type	Exemple
awsRoleArn	Facultatif	Chaîne	`arn:aws:iam::123456789012:role/my-workflow-role`
awsAccessKeyId	Facultatif	Chaîne	`${{ :secrets:<awsAccessKeyId> }}`
awsSecretAccessKey	Facultatif	Chaîne	`${{ :secrets:<awsSecretAccessKey> }}`
awsSessionToken	Facultatif	Chaîne	`${{ :secrets:<awsSessionToken> }}`
région	Requis	Chaîne	`"us-east-2"`
queueUrl	Requis	Chaîne	" `https://sqs.us-east-2.amazonaws.com/123456789012/my-queue` "
maxNumberOfMessages	Facultatif	Int	`10`
waitTimeSeconds	Facultatif	Int	`5`
VisibilityTimeout	Facultatif	Int	`123`
AttributeNames	Facultatif	List	`[ 'All'\|'Policy'\|'VisibilityTimeout'\|'MaximumMessageSize'\|'MessageRetentionPeriod'\|'ApproximateNumberOfMessages'\|'ApproximateNumberOfMessagesNotVisible'\|'CreatedTimestamp'\|'LastModifiedTimestamp'\|'QueueArn'\|'ApproximateNumberOfMessagesDelayed'\|'DelaySeconds'\|'ReceiveMessageWaitTimeSeconds'\|'RedrivePolicy'\|'FifoQueue'\|'ContentBasedDeduplication'\|'KmsMasterKeyId'\|'KmsDataKeyReusePeriodSeconds'\|'DeduplicationScope'\|'FifoThroughputLimit'\|'RedriveAllowPolicy'\|'SqsManagedSseEnabled', ]`
messageAttributeNames	Facultatif	List	`[ 'message_attribute_name', ],`
messageSystemAttributeNames	Facultatif	List	`['SenderId', 'SentTimestamp']`
receiveRequestAttemptId	Facultatif	Chaîne	`"req-1234abcd"`

Champ de sortie	Type	Exemple
response	objet	`{"response":<aws api response> }` La syntaxe de réponse peut être consultée dans la documentation Boto3 relative à receive_message](https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sqs/client/receive_message.html)
succès	Booléen	`success: true \| false`
message d'erreur	Chaîne	`"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""`

Champ de sortie

Type

Exemple

response

objet

{"response":<aws api response> }

La syntaxe de réponse peut être consultée dans la documentation Boto3 relative à receive_message](https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sqs/client/receive_message.html)

succès

Booléen

success: true | false

message d'erreur

Chaîne

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

Cette traduction automatique est fournie pour votre commodité.

Aperçu

Prérequis

Envoyer un message à une file d'attente AWS SQS

Reçoit un message d'une file d'attente AWS SQS

Cette traduction automatique est fournie pour votre commodité.

Actions AWS SQS

Aperçu

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

Reçoit un message d'une file d'attente AWS SQS

Prérequis