我已经安装了芹菜4.1.1并设置了队列和路由,但是工作人员只接受名称'celery'的数据 .
BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_DEFAULT_QUEUE = 'default'
CELERY_TASK_SERIALIZER = 'json'
CELERY_DEFAULT_ROUTING_KEY = "default"
CELERY_DEFAULT_EXCHANGE = "default"
CELERY_DEFAULT_EXCHANGE_TYPE = "direct"
CELERY_QUEUES = {
'default': {
"exchange": "default",
"binding_key": "default"
},
'recon_queue': {
"exchange": "recon_queue",
"routing_key": "recon_queue"
}
}
CELERY_ROUTES = {
'reconciliation.tasks.sync_bag': {'queue': 'default'},
'common.consumer.kafka_consumer': {'queue': 'recon_queue'}
}
CELERYBEAT_SCHEDULE = {
"kafka_consumer": {
'task': 'kafka_consumer',
'schedule': crontab(minute='*/01'),
},
}
定期任务通过芹菜节拍运行 . 这个命令工作正常 - 芹菜 - 一个地狱 Worker -l info -Q celery -c1这个 Worker 自己完成所有任务 .
但这些命令对芹菜没有任何影响 - 一个地狱 Worker -l info -Q default -c1 celery -A inferno worker -l info -Q recon_queue -c1