Loads bytes from Amazon SQS queues.
load_sqs queue:str, [poll_time=duration]Description
Section titled “Description”Amazon Simple Queue Service (Amazon SQS) is a fully managed message
queuing service to decouple and scale microservices, distributed systems, and
serverless applications. The load_sqs operator reads bytes from messages of an
SQS queue.
The load_sqs operator uses long polling, which helps reduce your cost of using SQS
by reducing the number of empty responses when there are no messages available
to return in reply to a message request. Use the poll_time option to adjust
the timeout.
The operator requires the following AWS permissions:
sqs:GetQueueUrlsqs:ReceiveMessagesqs:DeleteMessage
queue: str
Section titled “queue: str”The name of the queue to use.
poll_time = duration (optional)
Section titled “poll_time = duration (optional)”The long polling timeout per request.
The value must be between 1 and 20 seconds.
Defaults to 3s.
Examples
Section titled “Examples”Read JSON messages from the SQS queue tenzir:
load_sqs "tenzir"Read JSON messages with a 20-second long poll timeout:
load_sqs "tenzir", poll_time=20s