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 للحصول على تفاصيل الترخيص.