PyCon US is happening May 14th-22nd in Pittsburgh, PA USA.  Learn more

Asynchronous message dispatcher for concurrent tasks processing

Navigation

Verified details

These details have been verified by PyPI
Project links
GitHub Statistics
Maintainers
Avatar for hartungstenio from gravatar.com hartungstenio Avatar for olist from gravatar.com olist

Unverified details

These details have not been verified by PyPI
Meta
  • License: MIT License (The MIT License (MIT))
  • Author: Olist
  • Tags asyncio, dispatcher, message, microservices, tasks
  • Requires: Python >=3.11
  • Provides-Extra: sentry
Classifiers
Report project as malware

Project description

PyPI latest Python versions License CircleCI Olist Sponsor

olist-loafer is an asynchronous message dispatcher for concurrent tasks processing, with the following 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

:information_source: Currently, only AWS SQS is supported

How to use

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()

How to contribute

Fork this repository, make changes and send us a pull request. We will review your changes and apply them. Before sending us your pull request please check if you wrote and ran tests:

make test

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page