Python AWS SQS Consumer documentation
Write Amazon Simple Queue Service (SQS) consumers in Python with simplified interface. Define your logic to process an SQS message. After you’re done processing, messages are deleted from the queue.
Heavily inspired from https://github.com/bbc/sqs-consumer, a similar JavaScript interface.
Installation
pip install aws-sqs-consumer
Quick Start
from aws_sqs_consumer import Consumer, Message
class SimpleConsumer(Consumer):
def handle_message(self, message: Message):
# Write your logic to handle a single `message`.
print("Received message: ", message.Body)
consumer = SimpleConsumer(
queue_url="https://sqs.eu-west-1.amazonaws.com/12345678901/test_queue",
polling_wait_time_ms=5
)
consumer.start()