【文件属性】：
文件名称：pika-asynchronous-consumer:异步RabbitMQ使用者
文件大小：7KB
文件格式：ZIP
更新时间：2021-05-17 20:17:21
Python
异步pika消费者
描述
此类实现异步RabbitMQ使用者。 它基于并进行了通用修改。 例如，可以使用此修改后的类将消息插入数据库中，或以其他方式处理它们。
Pika是AMQP 0-9-1协议的纯Python实现，包括RabbitMQ的扩展。
新增功能
接受用于处理消息的回调。 原始邮件将消息写入日志文件。
处理并记录连接到发布者时的错误。
记录读取的消息数和处理失败的消息数。
添加班级成员数据字段以选择
队列的名称。
是否确认收货。
阅读给定数量的消息后关闭连接。
档案文件
—消费者类。
—使用消费者类的示例应用程序。
笔记
对异步消费者原始示例的所有更改都带有注释和两个感叹号!! 。
【文件预览】：
pika-asynchronous-consumer-master
----aconsumer.py(16KB)
----consumer_app.py(2KB)
----LICENSE(2KB)
----README.md(1KB)