Skip to main content

Background Processing for Python 3.

Project description

dramatiq

Build Status PyPI version Documentation Discourse

A fast and reliable distributed task processing library for Python 3.


Changelog: https://dramatiq.io/changelog.html
Community: https://reddit.com/r/dramatiq
Documentation: https://dramatiq.io
Support Dramatiq via Patreon
Support Dramatiq via Tidelift


Installation

If you want to use it with RabbitMQ

pip install 'dramatiq[rabbitmq, watch]'

or if you want to use it with Redis

pip install 'dramatiq[redis, watch]'

Supporting the Project

If you use and love Dramatiq and want to make sure it gets the love and attention it deserves then you should consider supporting the project. There are three ways in which you can do this right now:

  1. If you're a company that uses Dramatiq in production then you can get a Tidelift subscription. Doing so will give you an easy route to supporting both Dramatiq and other open source projects that you depend on.
  2. If you're an individual or a company that doesn't want to go through Tidelift then you can support the project via Patreon.
  3. If you're a company and neither option works for you and you would like to receive an invoice from me directly then email me at bogdan@defn.io and let's talk.

Quickstart

Make sure you've got RabbitMQ running, then create a new file called example.py:

import dramatiq
import requests
import sys


@dramatiq.actor
def count_words(url):
    response = requests.get(url)
    count = len(response.text.split(" "))
    print(f"There are {count} words at {url!r}.")


if __name__ == "__main__":
    count_words.send(sys.argv[1])

In one terminal, run your workers:

dramatiq example

In another, start enqueueing messages:

python example.py http://example.com
python example.py https://github.com
python example.py https://news.ycombinator.com

Check out the user guide to learn more!

License

dramatiq is licensed under the LGPL. Please see COPYING and COPYING.LESSER for licensing details.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

dramatiq-1.7.0.tar.gz (63.3 kB view details)

Uploaded Source

Built Distribution

dramatiq-1.7.0-py3-none-any.whl (103.4 kB view details)

Uploaded Python 3

File details

Details for the file dramatiq-1.7.0.tar.gz.

File metadata

  • Download URL: dramatiq-1.7.0.tar.gz
  • Upload date:
  • Size: 63.3 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/1.15.0 pkginfo/1.5.0.1 requests/2.22.0 setuptools/41.2.0 requests-toolbelt/0.9.1 tqdm/4.36.0 CPython/3.7.4

File hashes

Hashes for dramatiq-1.7.0.tar.gz
Algorithm Hash digest
SHA256 6d4b21b52baa275c4664126237b3f0029545815b84553904814e43b3b2f58b31
MD5 976c0c24c725d905c434b91303330f68
BLAKE2b-256 038a923c7731c42fe1573253524af0a870bf13a953c43984ef3f58f63c032151

See more details on using hashes here.

Provenance

File details

Details for the file dramatiq-1.7.0-py3-none-any.whl.

File metadata

  • Download URL: dramatiq-1.7.0-py3-none-any.whl
  • Upload date:
  • Size: 103.4 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/1.15.0 pkginfo/1.5.0.1 requests/2.22.0 setuptools/41.2.0 requests-toolbelt/0.9.1 tqdm/4.36.0 CPython/3.7.4

File hashes

Hashes for dramatiq-1.7.0-py3-none-any.whl
Algorithm Hash digest
SHA256 9cec395ac460eb804e3cca6021cb274011b085843fa85d48d94e9339f7bc2ac3
MD5 a2dcba6f3bcfceefe50b8354986393f8
BLAKE2b-256 38a5453c2974965a7adf77773afa9f63df13c1401a2fcdc3858d234ab33e014c

See more details on using hashes here.

Provenance

Supported by

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