我已经安装了芹菜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