Хочешь сделать потребителя, не уверен, достаточно ли комбу или мне нужно также внедрить сельдерей
Я нахожусь в процессе создания потребителя для rabbtMQ. Я использую Python и после исследования я решил использовать Kombu. С Комбу я уже подключился к очереди в кролике и прочитал сообщения. Код
queue = Queue('someQueue')
def process(body, message):
# Something
message.ack()
# connections
with Connection(hostname="localhost", userid="****", password="****", port=****, virtualhost="/") as conn:
# consume
with conn.Consumer(queue, callbacks=[process]) as consumer:
# Process messages and handle events on all channels
while True:
conn.drain_events()
Кажется, это работает, но я часто вижу, что сельдерей и комбу используются вместе. Мне нужно только принимать сообщения из очереди, достаточно ли Kombu или я должен также интегрировать Celery. Если да, то есть ли у кого-нибудь хороший пример, я нашел примеры, но они мне не понятны. Также я хочу сделать мою очередь долговечной = ложной, но потребитель, кажется, имеет длительную = истинную по умолчанию. Как я могу это изменить?
Спасибо за любую помощь!