나는 장고 셀러리 + rabbitmq를 사용하여 일부 asyn 작업을 실행하기 위해 대기열 'sendmail'을 정의하여 메일 보내기 작업을 실행하고 특정 작업 (이 작업에는 자체 대기열이 있음) 하지만 지금은 문제가 발생했습니다. 특정 작업이 끝난 후 메일이 가끔씩 전송되기도하고 때로는 5 ~ 20 분이 필요하기도합니다. 어떤 이유로 인해 문제가 발생했는
셀러리를 사용하여 보초를 비동기 적으로 기록하도록 까마귀를 설정하려고합니다. 내가 올바르게 설정 한 것 같아요,하지만 CeleryClient의 send_raw 함수는 호출되지 않습니다 (센트리 나 셀러리에서 아무것도 가져 오지 않았습니다). 아래 SENTRY_CLIENT 설정을 변경하지 않으면 모든 작업이 작동합니다 (로그는 보초에 나타납니다). 내 설정은
그래서 우선 순위가 다른 동일한 셀러리 작업을 어디에서 실행하는지 꽤 재미있는 시나리오가 있습니다. 예를 들어 프리미엄 사용자를위한 작업을 실행하고 싶습니다 프리미엄이 아닌 사용자보다 우선 순위가 높습니다. docs를 사용하여 여러 대기열을 설정할 수 있었고 .apply_async 호출에 대한 모든 .delay 호출을 변경하고 우선 순위 대기열을 지정하는
와주기적인 작업은 내가 나는 등 수상자를 anounce 활성 캠페인과 함께 응용 프로그램을 가지고 있고, 캠페인에 대한 알림을 보내 .. 일을 함께 맞는 방법 없습니다 확신합니다. 캠페인은 django로 생성되며, 캠페인 모델에는 매 X 일 또는 주 또는 시간마다 승자에게 알리는 필드가 있습니다. 따라서 이번 캠페인에서는 매주 금요일에 수상자를 발표해야합니
약간의 배경으로. 나는 관리자를 사용하여 장고 - 셀러리 프로세스를 모니터하고 있습니다. virutalenv를 설정하고 celeryd 프로세스를 시작할 수 있어야합니다. 나는 현재 그 일을하고 방법은 다음 worker.sh에 나는이 일종의 작품 /bin/su - username -c "source /srv/virtualenvs/bin/activate; py
현재 약 43,000,000 개 요소의 전체 몽고 컬렉션을 거쳐 오랜 기간 실행되는 (Python + Celery에서 실행되는) 작업이 있으며 해당 요소를 변경하지 않고 요소에 대한 분석을 수행합니다 . 이 컬렉션이 늘어남에 따라 작업이 더 길어지기 시작했으며 (이제) 다른 데이터베이스에 대한 시간 초과로 인해 일반적으로 주기적으로 실패합니다. 이 작업을
dotcloud 배포 중 하나에서 셀리가 실패하고 수정 방법을 잘 모르겠습니다. 배포는 기존의 dotcloud 배포 (파일 diff를 통해 확인 됨)와 거의 동일하며 제대로 작동하는 것 같습니다. 내가 djcelery 로그에 얻는 오류 :
[email protected]:/var/log/supervisor$ more djcelery_error.log
저는 Redis와 함께 Celery를 중개인으로 사용하고 있습니다. 큐가 실제로 직렬화 된 작업을 항목으로 갖는 redis 목록이라는 것을 알 수 있습니다. 제 질문은 <task>.delay()을 호출 한 결과 AsyncResult 객체가있는 경우 대기열에서 항목의 위치를 결정하는 방법이 있습니까? 이 모든 근로자와 통신해야하기 때문에 from cele
내 문제는 상당히 단순해야하며 필사적으로 해결해야하는 것보다 더 중요한 관심사입니다. Google은 내가 찾던 답변을 내게 줄 수 없기 때문에 귀하의 전문 지식이 나를 도울 수 있기를 바랍니다. Django 1.4
Celery 2.5.5
Redis 2.4.10 (latest version on homebrew?)
그리고 나는 follwing을 명령하