dramatiq

драматика

Быстрая и надежная библиотека распределенной обработки задач для Python 3.

---

Журнал изменений : https://dramatiq.io/changelog.html.
Сообщество : https://groups.io/g/dramatiq-users.
Документация : https://dramatiq.io.

---

Спонсоры

Установка

Если вы хотите использовать его с RabbitMQ

 pip install 'dramatiq[rabbitmq, watch]'

или если вы хотите использовать его с Redis

 pip install 'dramatiq[redis, watch]'

Быстрый старт

Убедитесь, что RabbitMQ запущен, затем создайте новый файл с именем 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 ])

В одном терминале запустите своих работников:

 dramatiq example

В другом начните ставить сообщения в очередь:

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

Ознакомьтесь с руководством пользователя, чтобы узнать больше!

Лицензия

Dramatiq распространяется по лицензии LGPL. Подробности о лицензировании см. в разделах COPYING и COPYING.LESSER.