优先级队列

channel.queue_declare(
    queue='priority_queue',
    arguments={'x-max-priority': 10}
)

channel.basic_publish(
    exchange='',
    routing_key='priority_queue',
    body='message',
    properties=pika.BasicProperties(priority=5)
)