셀러리를 시작하고 이미 시작된 celeryd 프로세스에 모듈을 추가 할 수 있는지 알고 싶습니다. 대신 전에 CELERY_IMPORTS = ("tasks", "additional_module")
가 근로자를 시작 같이 celeryconfig.py를 통해 모듈을 추가하는 즉, 나는 작업자 프로세스가 시작 나중에 어떻게 든 후 additional_modul
프로젝트에서 Python과 celery을 사용하고 있습니다. 프로젝트에서, 나는 두 개의 파일이 있습니다 celeryconfig.py BROKER_URL = "amqp://guest:[email protected]:5672//"
CELERY_RESULT_BACKEND = "amqp"
CELERY_IMPORTS = ("example",)
CELERYD_
샐러리를 사용하고 있는데 셀프 프로세스 중 일부가 메모리 사용량이 많아서 max-tasks-per-child-setting 을 사용하고 싶습니다. 내가 변경하기 전에이 설정에 대한 기본값을 찾으려고하지만 해당 정보를 찾을 수 없습니다. 나는 here을 보았지만 모든 작업을 다시 시작하기를 원하지 않기 때문에 1으로 설정하고 싶지 않습니다. 기본적으로
업데이트하지 않습니다 내가 작업을 킥오프. 실행 중 태스크는 update_state (...)를 호출하여 진행 상태를 나타내는 작업 상태를 설정합니다. 작업이 완료됩니다. 로그를 통해 확인합니다. 그러나,이보기 (HTTP : // myapp와/작업/37d9a3ac-5bd2-4791-9729-2234ff3be762/상태) 작업이 완료된 후에도 시간의 변수 금
카운트 다운 후 샐러리 작업을 실행해야하지만 특정 조건에서 카운트 다운을 재설정 할 수 있어야합니다. 예를 들어, apply_async을 countdown=15으로 호출하려고하지만 작업이 실행되기 전에 특정 이벤트가 발생하면 해당 카운트 다운을 다시 15 초로 설정하고 싶습니다. 문서 및 검색에서 작업 ID를 저장하고 이벤트가 발생하면 작업을 취소하고 다시