почему сельдерей создает новую очередь в кроличьем mq?

Question

введите описание изображения здесь

функция, которая отправляет сельдерей, использует декоратор, указывающий на очередь, которую я хочу использовать, например:

@app.task(queue="celery")
def compare_from_database(row_id=None, database_name=None, table_name=None):
    ....

Я создал сценарий, чтобы проверить, сколько задач у меня еще есть в очереди, всего лишь некоторое время l oop команды

 rabbitmqctl list_queues

и анализ строки с помощью «сельдерея»

, но поскольку сельдерей создает случайные очереди, я не могу это использовать. почему сельдерей создает новые очереди, а не отправляет их в ту, которую я хочу?

Answer 1

Думаю, вы используете rpc в качестве celery_result_backend. Вы можете проверить эту ссылку - https://tech.labs.oliverwyman.com/blog/2015/04/30/making-celery-play-nice-with-rabbitmq-and-bigwig/, где он объясняет, что серверная часть RP C будет создавать очереди для результатов задачи.

Вы можете проверить мой ответ, чтобы узнать больше о result-backend здесь => { ссылка }