芹菜客户定义自定义生产商（auto_declare）

Question

在KOMBU生产商中关闭auto_declare（ docs ）。正如我在芹菜init正确理解的那样＃Celery-Application-Objects“ rel =” nofollow noreferrer“> docs ），但我对此并不成功。具有使用文档中可以使用的默认KOMBU生产者的功能。

def celery_app(
        service_name: str
) -> Celery:

    return Celery(
        __name__,
        result_backend=settings.CELERY_RESULT_URL,
        broker="%s/%s" % (settings.BASE_CELERY_BROKER_URL, service_name),
        task_create_missing_queues=False,
        celery_queue_ha_policy="all",
        task_acks_late=True,
        set_as_current=False,
        result_extended=True,
    )

我希望只通过amqp = ampq（producer（...））喜欢吗？ ：

    return Celery(
        __name__,
        result_backend=settings.CELERY_RESULT_URL,
        broker="%s/%s" % (settings.BASE_CELERY_BROKER_URL, service_name),
        task_create_missing_queues=False,
        celery_queue_ha_policy="all",
        task_acks_late=True,
        set_as_current=False,
        result_extended=True,
        amqp=AMQP(Producer(
            channel="%s/%s" % (settings.BASE_CELERY_BROKER_URL,
                               service_name), # (amqp://...)?
            exchange=...
            auto_declare=False
        ))

    )

但是可悲的是，这不是它的工作方式。谁能帮忙？

谢谢！