1

我正在为rabbtMQ制作消费者。我正在使用 python，经过研究我决定使用 Kombu。使用 Kombu，我已经连接到 rabbit 中的队列并阅读了消息。代码是

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。如果是这样，有没有人有一个很好的例子，我找到了例子，但我不清楚。我也想让我的队列durable=false，但消费者似乎默认有durable =true。我怎样才能改变这个？

谢谢你的帮助！

4

0 回答 0