celery

    4

    3답변

    셀러리 + rabbitmq를 사용하고 있습니다. 셀러리 + rabbitmq에서 큐를 지우는 편리한 방법을 찾을 수 없습니다. 나는 제거하고 가상 호스트를 만듭니다. rabbitmqctl delete_vhost <vhostpath> rabbitmqctl add_vhost <vhostpath> 셀러리 큐를 지우는 것이 더 좋습니까?

    3

    1답변

    지금까지 내가 python manage.py celeryd 만 일한지 이런 식으로 시작 : BinaryExecTask.delay(request.POST["binary_path"]) 그리고 내 settings.py의 코드 : python manage.py celeryd -l info --settings=settings 내보기에서 코드 것은이 수행 이건 :

    3

    1답변

    celeryd이 대기열에 추가 된 새 작업을 가져 오지 못하는 이유를 알 수 없습니다. 작업이 시작된 후에 만 ​​작업을 검색하고 그 후에는 모니터링에 실패합니다. 나는 메시지 브로커에 대해 Django ORM을 사용하여 장고 - 셀러리와 장고 개발 서버를 실행 중이다. 그것은, 내 데이터베이스 백엔드로 원격 MySQL 서버를 사용하고 문제 또한 경우 IN

    5

    1답변

    에서 볼 수 있듯이 top 유틸리티 celery에서 procecess는 많은 CPU 시간을 소비합니다. 그래서 그것을 프로파일 링하고 싶습니다. python -m cProfile -o test-`date +%Y-%m-%d-%T`.prof ./manage.py celeryd -B 을하지만 생산 기계에 프로파일 링 할 필요가 정확한 타이밍을 가지고 : 그래

    9

    3답변

    약 150k 장고 개체에서 작업을 실행해야합니다. 이 작업을 수행하는 가장 좋은 방법은 무엇입니까? 브로커로 Django ORM을 사용하고 있습니다. 데이터베이스 백엔드는 MySQL이고 초크이며 모든 작업의 ​​task.delay() 중에 종료됩니다. 관련하여 양식 제출에서이 문제를 해결하고 싶지만 결과로 응답 시간이 인 매우 응답 시간이 길어졌습니다.

    4

    1답변

    사용자가 내 사이트를 탐색하는 동안 백그라운드에서 일부 작업을 실행하려고하지만 Celery를 사용하여 함수를 호출 할 때마다 비동기로 대신 동 기적으로 실행되는 것처럼 보입니다. 예를 들어 function.delay()를 호출하면 function.delay()가 반환 될 때까지 전체 사이트가 중단됩니다. 비슷한 방식으로 함수를 호출하는 다른 방법 (appl

    0

    3답변

    모든 작업에서 외부 웹 서비스를 쿼리해야하는 많은 작업을 작성해야합니다. 웹 서비스는 항상 202 ACCEPTED 상태로 응답하고 Location 헤더에서 결과를 폴링 할 수있는 URI를 가리 킵니다. 이 웹 서비스가 결과를 전달하는 데 걸리는 시간은 2 초에서 1 분까지 다양합니다. 셀러리 작업을 프로그래밍하는 가장 좋은 방법이 무엇인지 궁금 해서요. 이

    3

    1답변

    브로커가 실행되지 않는 경우 정상적으로 실패하는 작업 하위 클래스를 구현해야합니다. 현재 RabbitMQ를 사용하고 있습니다. 나는 아마 예외 잡으려고 시도 문을 사용할 수 있습니다 try: Mytask.delay(arg1, arg2) except socket.error: # Send an notice to an admin pa

    5

    4답변

    here에서 특정 시간에 특정 간격으로 실행되도록 태스크를 설정할 수 있다는 것을 알았지 만 태스크 선언 중에 만 수행되었습니다. 태스크를 주기적으로 동적으로 실행하도록 설정하려면 어떻게합니까? 당신은 당신이 새로운 만들 나중에 X의 초 동안 뭔가를 실행하려는 예를 들어 D :

    1

    1답변

    내 작업 중 하나에서 ugettext를 사용했습니다. 나는 po 파일을 편집했다. 그러나 그것은 효과가 없었습니다. 아무도 이유를 아나요? 감사! from django.utils.translation import ugettext @task def testtask(): ..... msg = ugettext('test') ...