Я использовал следующий код для pika для подключения Redis:
channel.basic_qos(prefetch_count=10)
channel.basic_consume(..., queue=...)
channel.start_consuming()
channel.close()
Я пытаюсь использовать Kombu, как я могу использовать этот код для Kombu?
Я изменил соединение с:
pika.connection
на:
kombu.connection
Сначала я выдал ошибку, что не знает функцию basic_qos, затем я изменил ее на " qos ", и я получил" объект канала не имеет атрибута qos ".
Как я могу это исправить?