python采用pika库使用rabbitmq(五)消息持久化存储(Message durability)
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了python采用pika库使用rabbitmq(五)消息持久化存储(Message durability),小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含533字,纯文字阅读大概需要1分钟。
内容图文
![python采用pika库使用rabbitmq(五)消息持久化存储(Message durability)](/upload/InfoBanner/zyjiaocheng/847/d73d3b1e581c437cb3c651de49fd4b1c.jpg)
虽然有了消息反馈机制,但是如果rabbitmq自身挂掉的话,那么任务还是会丢失。所以需要将任务持久化存储起来。声明持久化存储:
重新定义一个队列
1 channel.queue_declare(queue='task_queue', durable=True)
在发送任务的时候,用delivery_mode=2来标记任务为持久化存储:
1 channel.basic_publish(exchange='', 2 routing_key='task_queue', 3 body=message, 4 properties=pika.BasicProperties( 5 delivery_mode=2, # make message persistent 6 )
内容总结
以上是互联网集市为您收集整理的python采用pika库使用rabbitmq(五)消息持久化存储(Message durability)全部内容,希望文章能够帮你解决python采用pika库使用rabbitmq(五)消息持久化存储(Message durability)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。