django-signalqueue

장고 프레임 워크는 질문을 것입니다 그들 자신에 관한 시간 사람의 일정 금액 후 : 내가 참으로, 장고의 신호를 좋아한다. 하지만 내가 만약 비동기을 파견 할 수있다. 마찬가지로, 다른 스레드 또는 뭔가, 난 정말 몰라 .... 그게 어떻게 든 할 수 있습니까?
자, 이제 당신은 쉽게 장고 - signalqueue와 것을 할 수 있습니다.
시계, 난 당신을 보여 드리죠. 첫째, 장고 - signalqueue를 설치 :
$이 설치됩니다 장고 - signalqueue 번호 ​​설치 핍 토네이도와 장고 - 대리인 필요한 경우
당신은 이미이없는 경우 ... 당신은 또한이 옵션 패키지의 일부를 할 수 있습니다 :
$ 양조는 레디 스는 # 1 S / 양조 / apt-get을 / 취향에 yajl 설치
레디 스를 설치 PIP $는 #을 추천 hiredis
$ # ujson 권장 설치를 핍
$ 너무 czjson yajl simplejson # 이러한 작업 설치 핍
$는 테스트를 위해 코 장고 코 #을 설치 PIP
당신이 당신의 settings.py에있는 동안, 당신의 INSTALLED_APPS 및 큐의 설정에 장고 - signalqueue 추가 :
# 1 settings.py
INSTALLED_APPS = [
& NBSP; 'signalqueue', # ...
]
SQ_QUEUES의 = {
& NBSP; '기본값은'{# 당신은 SQ_QUEUES에서 '기본'라는 이름의 적어도 하나의 DICT 필요
& NBSP; 'NAME': 'signalqueue_default', 옵션 # - 'signalqueue_default'기본값
& NBSP; '엔진': 'signalqueue.worker.backends.RedisSetQueue'필요 # - 이것은 대기열의 드라이버입니다
& NBSP; '간격': 30, # 1/3 초
& NBSP; '옵션'DICT ()를,
& NBSP;}
}
기본적으로 SQ_RUNMODE은 = 'SQ_ASYNC_REQUEST'# 사용 비동기 파견
SQ_WORKER_PORT = 11231 # 대기열 작업자 프로세스가 바인딩 포트
모든 게다가, 당신은 단지 루트 URLConf에 () signalqueue.autodiscover에 대한 호출이 필요합니다
# 1 urls.py
수입 signalqueue
signalqueue.autodiscover ()
당신은 비동기 신호를 정의 할 수 있습니다!
비동기 신호는 다음과 같은 장소 중 하나에서 정의한 signalqueue.dispatch.AsyncSignal의 인스턴스입니다 :
- your_app / signals.py (이미이 파일을 사용하는 경우는 괜찮습니다, 많은 할)
- settings.SQ_ADDITIONAL_SIGNALS 목록 또는 튜플에 이름 모듈
- 출시 예정 : signalqueue.register 것은 () - 그래서 당신은 다른 곳을 넣을 수 있습니다.
AsyncSignals 훨씬 익숙한 당신이 알고 django.dispatch.Signal의 인스턴스와 사랑을 다음과 같이 정의된다 :
# yourapp / signals.py
signalqueue.dispatch 수입 AsyncSignal에서
signalqueue.mappings에서 ModelInstanceMap를 가져
#이 두 생성자는 같은 일을
my_signal = AsyncSignal (providing_args = [ '예']) 유게 #
my_other_signal = AsyncSignal (providing_args = { '예'ModelInstanceMap}) 매핑으로 #
# 다음은 어디든지 갈 수 있습니다 - 인스턴스 만이 yourapp / signals.py에있을 필요가 :
데프 콜백 (보낸 사람, ** kwargs로) :
& NBSP; 인쇄 "나는 % s이 (가), 이에 감사 장고 signalqueue을 위해 % s에 의해 비동기 적으로 발송되었습니다." % (
& NBSP; STR (kwargs로 [ '예'),
& NBSP; 보낸 사람 .__ name__)
my_signal.connect (콜백)
... 주요 차이점은 매핑 대신 클래스 일반 목록 DICT providing_args로 지정 번째 정의된다. 우리는 나중에 매핑 클래스를 설명 할 것이다, 그러나 당신이 당신의 신호에 장고 모델 인스턴스를 전달하는 경우, 당신은이에 대해 걱정할 필요가 없습니다.
작업자가 실행되면, 당신은 너무 같은 큐에 신호를 보낼 수 있습니다 :
>>> my_signal.send (발신자 = AModelClass 예 = a_model_instance)
일반 장고 신호처럼 신호를 발사하려면이 작업을 수행 할 수 있습니다 :
>>> my_signal.send_now (발신자 = AModelClass 예 = a_model_instance)
의 ... 장고 - signalqueue의 README 놀라운 결론 내일의 조정 !!!!!!

이 요구 사항 :

이 파이썬
장고