저는 Python의 itertools를 통해 많은 제품 목록을 생성하는 프로그램을 가지고 있습니다. 기본적으로 단어의 다양한 조합의 큰 세트. products() 함수를 통해 실행할 여러 세트가 있습니다. 제가하고 싶은 것은 Celery가 각 세트에 다른 Celery Task를 부여한 다음,이를 결국 결합하는 것입니다. 나의 이해는 화음이 이것을하는 방법이
3 개의 메소드가 정의 된 tasks.py 파일이 있습니다. 내 views.py 파일에서보기에서 호출 할 수 있도록 이러한 메서드를 가져 오려고합니다. 나는이 작업을 호출하는 뷰를 호출 할 때 from app.tasks import generate_standalone_view, generate_primary_investment_management_view,
그래서 작업 디렉토리를 만들고 모든 작업을 수행합니다. 작업이 서버 A에서 호출되고 작업자 서버에서 실행됩니다. 일단 작업이 완료되면/이 취소되었음을 확인해야합니다.. 나는 작업 취소 처리기를 추가는 다음과 같습니다 @task
def my_task(value):
task_id = current_task.request.id
work_di
나는 즉시 셀프 작업을 비동기식으로 만들려고합니다. 비동기 적으로 시작되는 1000 개의 작업이 있고 작업을 실행하기 위해 하나의 celeryd 프로세스 만 실행한다고 가정 해보십시오. 이러한 작업을 처리하기 위해 샐러리가 작성하는 스레드는 몇 개입니까? 셀러 리가 자동으로 작업 대기열을 처리하기 시작하는 스레드가 여러 개있는 경우 주어진 시점에서 100
저는 Redis와 함께 Celery를 중개인으로 사용하고 있습니다. 큐가 실제로 직렬화 된 작업을 항목으로 갖는 redis 목록이라는 것을 알 수 있습니다. 제 질문은 <task>.delay()을 호출 한 결과 AsyncResult 객체가있는 경우 대기열에서 항목의 위치를 결정하는 방법이 있습니까? 이 모든 근로자와 통신해야하기 때문에 from cele
django에서 셀러리를 사용하고 있습니다. 사용자가 실패한 작업을 검사하고, 필요한 경우 실패한 작업 데이터를 수정 한 다음 다시 제출할 수있는 옵션을 제공해야합니다. 이 스레드를 보았습니다 - Celery Storing unrecoverable task failures for later resubmission. 그래서 샐러리는 원래 args 및 작업을
파란색으로 셀 라이브러리 및 셀러리로 내 dev 서버를 시작하려고 할 때 다음 오류가 발생합니다. 어느 날이 일은 다음 날에 작동하지 않습니다. 나는 이것을 설명 할 수있는 어떤 것도 변경하지 않았습니다. Procfile : 나는 내 서버 사용 주임 등과 같은 Procfile.dev을 시작 web: python manage.py runserver
cele