Source
yaml
id: sqs-publish-message
namespace: company.team
inputs:
- id: message
type: STRING
defaults: Hi from Kestra!
tasks:
- id: publish_message
type: io.kestra.plugin.aws.sqs.Publish
accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
secretKeyId: "{{ secret('AWS_SECRET_ACCESS_KEY') }}"
region: "{{ secret('AWS_DEFAULT_REGION') }}"
queueUrl: https://sqs.eu-central-1.amazonaws.com/123456789/kestra
from:
data: "{{ inputs.message }}"
About this blueprint
AWS Inputs Queue
This flow publishes a message to an SQS queue. The queue URL points to an already existing queue.
This flow assumes AWS credentials stored as secrets AWS_ACCESS_KEY_ID,
AWS_SECRET_ACCESS_KEY and AWS_DEFAULT_REGION.