olist-loafer 3.0.3

Asynchronous message dispatcher for concurrent tasks processing

---

Loafer is an asynchronous message dispatcher for concurrent tasks processing.

Currently, only AWS SQS is supported

Features:

• Encourages decoupling from message providers and consumers

• Easy to extend and customize

• Easy error handling, including integration with sentry

• Easy to create one or multiple services

• Generic Handlers

• Amazon SQS integration

It requires Python 3.7+

Example

A simple message forwader, from source-queue to destination-queue:

from loafer.ext.aws.handlers import SQSHandler
from loafer.ext.aws.routes import SQSRoute
from loafer.managers import LoaferManager


routes = [
    SQSRoute('source-queue', handler=SQSHandler('destination-queue')),
]


if __name__ == '__main__':
    manager = LoaferManager(routes)
    manager.run()

Documentation

Check out the latest Loafer full documentation at Read the Docs website.

Changelog:

3.0.3 (2020-11-05)

• Supress RuntimeError

3.0.2 (2020-11-04)

• Fix ProviderRuntimeError

3.0.1 (2020-10-29)

• Reraise RuntimeError as ProviderRuntimeError

3.0.0 (2020-10-20)

• Add support for python 3.9

• Drop support for python 3.5 and 3.6

2.0.0 (2020-07-02)

• Inicial fork release(test)

2.0.0+post1 (2020-05-26)

• Use sentry_sdk

1.3.2+post3 (2020-04-27)

• Improve shut down methods

1.3.2+post2 (2020-04-14)

• Update aiobotocore client

1.3.2+post1 (2019-04-27)

• Update dependencies

• Update makefile for olist build

1.3.2 (2019-04-27)

• Improve message processing (#48 by @lamenezes)

• Improve error logging (#39 by @wiliamsouza)

• Refactor in message dispatcher and event-loop shutdown

• Minor fixes and improvements

1.3.1 (2017-10-22)

• Improve performance (#35 by @allisson)

• Fix requirement versions resolution

• Minor fixes and improvements

1.3.0 (2017-09-26)

• Refactor tasks dispatching, it should improve performance

• Refactor SQSProvider to ignore HTTP 404 errors when deleting messages

• Minor fixes and improvements

1.2.1 (2017-09-11)

• Bump boto3 version (by @daneoshiga)

1.2.0 (2017-08-15)

• Enable provider parameters (boto client options)

1.1.1 (2017-06-14)

• Bugfix: fix SNS prefix value in use for topic name wildcard (by @lamenezes)

1.1.0 (2017-05-01)

• Added initial contracsts for class-based handlers

• Added generic handlers: SQSHandler/SNSHander

• Improve internal error handling

• Improve docs

1.0.2 (2017-04-13)

• Fix sentry error handler integration

1.0.1 (2017-04-09)

• Add tox and execute tests for py36

• Update aiohttp/aiobotocore versions

• Minor fixes and enhancements

1.0.0 (2017-03-27)

• Major code rewrite

• Remove CLI

• Add better support for error handlers, including sentry/raven

• Refactor exceptions

• Add message metadata information

• Update message lifecycle with handler/error handler return value

• Enable execution of one service iteration (by default, it still runs “forever”)

0.0.3 (2016-04-24)

• Improve documentation

• Improve package metadata and dependencies

• Add loafer.aws.message_translator.SNSMessageTranslator class

• Fix ImportError exceptions for configuration that uses loafer.utils.import_callable

0.0.2 (2016-04-18)

• Fix build hardcoding tests dependencies

0.0.1 (2016-04-18)

• Initial release