오프라인 처리를 위해 django-celery, celery 및 rabbitmq를 사용하는 장고 응용 프로그램이 있습니다. 이제는 네트워크의 다른 노드 (장고 웹 응용 프로그램이 호스팅 된 곳과 다름)에서 샐러리 작업 (셀러리 작업자)을 실행해야합니다. 이 작업을 수행하려면 모든 별도의 서버에 장고 코드를 모두 넣어야합니다. 뿐만 아니라 장고 앱이 필요로하
--concurrency=1 (Workers Guide 기준)을 사용하여 샐러리에서 다른 수의 동시 스레드를 설정하려고합니다. 어쨌든 데몬 (celeryd ... --concurrency=1)을 실행할 때 실행중인 스레드 수를 보는 방법을 모르겠습니다. 이들은 각각 ps -ef에 표시된 행에 해당합니까?
내가 this- @task(base=MyBaseTask)
@my_custom_decorator
def my_task(*args, **kwargs):
my_task.ltc.some_func() #fails - attribute ltc doesn't exist on the object
처럼 보이는 my_custom_decorator 내가 실제
내가이 내 프로젝트 폴더 구조 api
-- __init__.py
--jobs/
-- __init__.py
-- celery.py
-- celeyconfig.py
-- tasks.py
--api_helpers/
--views/
작업이 예상대로 작동하지 않는 것은 ExamineC
장고 셀러리가 설치되어 있으며 rabbitmq에서 브로커로 SQS를 사용하도록 전환하고 있습니다. routing_key 값으로 장식 된 작업이 브로커에서 메시지를 생성하지 않는다는 것을 알고 있습니까? 설정 은 다음과 같습니다 CELERY_QUEUES = {
"default": {
"exchange": "default",
"b
에서 celery 나는 특정 작업 이름에 대한 모든 작업에 대한 작업 상태를 가져오고 싶습니다. 그것을 위해 아래 코드를 시도했다. import celery.events.state
# Celery status instance.
stat = celery.events.state.State()
# task_by_type will return list o
스레드에서 현재 셀러리 작업 ID를 가져옵니다. 을 (나는 https://stackoverflow.com/a/8096086/245024를 사용할 수없는 이유입니다) 내가 이런 식으로 뭔가 싶습니다 : @task
def my_task():
foo()
def foo():
logger.log(current_task_id)
이 패턴은 여