Consume
Consume
yaml
type: "io.kestra.plugin.aws.sqs.Consume"Examples
yaml
id: aws_sqs_consume
namespace: company.team
tasks:
- id: consume
type: io.kestra.plugin.aws.sqs.Consume
accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
region: "eu-central-1"
queueUrl: "https://sqs.eu-central-1.amazonaws.com/000000000000/test-queue"
Properties
queueUrl *Requiredstring
accessKeyId string
autoDelete booleanstring
Default
truecompatibilityMode booleanstring
connectionAcquisitionTimeout string
Default
PT5SFormat
durationendpointOverride string
forcePathStyle booleanstring
maxConcurrency integerstring
Default
50maxDuration string
Format
durationmaxRecords integerstring
region string
secretKeyId string
serdeType string
Default
STRINGPossible Values
STRINGJSONsessionToken string
stsEndpointOverride string
stsRoleArn string
stsRoleExternalId string
stsRoleSessionDuration string
Default
PT15MFormat
durationstsRoleSessionName string
visibilityTimeout integerstring
Default
30Outputs
count integer
uri string
Format
uriMetrics
sqs.consume.messages counter
Unit
messages