Я использую kombu для управления RabbitMQ через модель производителя/потребителя. Я запустил своего производителя, который поставил в очередь 100 заданий (у меня только одна очередь и один обмен). Я хотел бы запустить несколько потребителей...

Я запускаю приложение с django, и я хотел использовать сельдерей для выполнения некоторых запланированных задач. Согласно официальной документации , в мой файл settings.py я установил транспорт брокера BROKER_URL = 'django://' и добавил...

Я использую kombu для получения сообщений rabbitmq из нескольких очередей. Можно ли для любого заданного сообщения определить, какая очередь его доставила?

У меня есть очень простой код: celery = Celery(broker="amqp://guest:[email protected]:5672/")...