文件名称：pika-asynchronous-consumer:异步RabbitMQ使用者
文件大小：7KB
文件格式：ZIP
更新时间：2024-06-06 14:04:01
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)