python pika 消费mq basic

2021-12-14

channel1.basic_consume(on_message_callback=ConsumerCallback, queue=rabbitmq_queue, auto_ack=True)

如果要消费1条出来看下，会把堆积全部清空的情况

使用

method_frame, header_frame, body = channel1.basic_get(rabbitmq_queue)  # basic_get方法  参数queue名

if method_frame:
    # print(method_frame, header_frame, body)  # 收到的全部数据  就要body
    print(body)          # 是b'xxx'的格式
    # channel1.basic_ack(method_frame.delivery_tag)  用自动应答 这个应该不要
else:
    print('消费单条 没有收到消息')

官方文档： 

# https://pika.readthedocs.io/en/stable/examples/blocking_basic_get.html