Welcome to sqspy’s documentation!

Introduction

Code coverage Updates Documentation Status Build status Language grade:: Python

A more pythonic approach to SQS producer/consumer utilities. Heavily inspired from the the pySqsListener package.

Install

pip install sqspy

Usage

from sqspy import Consumer

class MyWorker(Consumer):
    def handle_message(self, body, attributes, message_attributes):
        print(body)

listener = MyWorker('Q1', error_queue='EQ1')
listener.listen()

More documentation coming soon.

Why

The mentioned project had a few issues which I faced while trying to implement at my organisation. The local environment testing setup was very flaky. The signatures for sqs_listener and sqs_producer were very different from each other.

This rewrite supports python 3.6+ versions only, and makes use of a lot of newer python features. It also makes use of service resources (for lazy calls) from the boto3 library instead of making calls via the low level client.

Indices and tables