dramatiq

dramatis

Pustaka pemrosesan tugas terdistribusi yang cepat dan andal untuk Python 3.

---

Log Perubahan : https://dramatiq.io/changelog.html
Komunitas : https://groups.io/g/dramatiq-users
Dokumentasi : https://dramatiq.io

---

Sponsor

Instalasi

Jika Anda ingin menggunakannya dengan RabbitMQ

 pip install 'dramatiq[rabbitmq, watch]'

atau jika Anda ingin menggunakannya dengan Redis

 pip install 'dramatiq[redis, watch]'

Mulai cepat

Pastikan Anda menjalankan RabbitMQ, lalu buat file baru bernama 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 ])

Di satu terminal, jalankan pekerja Anda:

 dramatiq example

Di tempat lain, mulailah memasukkan pesan ke dalam antrean:

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

Lihat panduan pengguna untuk mempelajari lebih lanjut!

Lisensi

dramatiq dilisensikan di bawah LGPL. Silakan lihat COPYING dan COPYING.LESSER untuk detail lisensi.