dramatiq
v1.17.1
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
자세한 내용은 사용자 가이드를 확인하세요!
드라마틱은 LGPL에 따라 라이선스가 부여됩니다. 라이센스 세부사항은 COPYING 및 COPYING.LESSER를 참조하십시오.