麻雀兔MQ消费者
sparrow-rabbitmq-consumer的Python项目详细描述
麻雀RabbitMQ消费者
简介
sparrow rabbitmq consumer是用于python的rabbitmq（amqp 0-9-1）客户机消费者库。
- 支持Python3.5+。
安装
pip install sparrow_rabbitmq_consumer
示例
下面是最简单的使用示例
from rabbitmq_consumer import RabbitMQConsumer
message_broker = "amqp://admin:12345@localhost:5672"
message_backend = "http://127.0.0.1:8001/api/sparrow_task/task/update/"
consumer = RabbitMQConsumer(
queue="product",
message_broker=message_broker,
message_backend=message_backend
)
# 需要定义queue中订阅的任务对应的执行函数
target_func_map = {
"order_paid": "task.order_paid",
"order_shipped": "task.order_shipped",
"add_favorite": "task.add_favorite",
}
consumer.target_func_map = target_func_map
consumer.consume()
参数说明：
queue: rabbitmq队列名称
message_broker: rabbitmq连接设置
message_backend: 选填的配置，如果设置了message_backend,则在任务执行完成之后会向该设置里的url发送任务执行完成结果
在调用consumer.consume()之前需要给 target_func_map赋值，
target_func_map字典中的键为message code，对应的值为执行该消息的任务函数路径字符串
欢迎加入QQ群-->： 979659372
