Хочешь сделать потребителя, не уверен, достаточно ли комбу или мне нужно также внедрить сельдерей

Я нахожусь в процессе создания потребителя для 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. Если да, то есть ли у кого-нибудь хороший пример, я нашел примеры, но они мне не понятны. Также я хочу сделать мою очередь долговечной = ложной, но потребитель, кажется, имеет длительную = истинную по умолчанию. Как я могу это изменить?

Спасибо за любую помощь!

0 ответов

Другие вопросы по тегам