麻雀任务发送者
sparrow-task-sender的Python项目详细描述
麻雀任务发送者
简介
sparrow task sender是用于python的rabbitmq（amqp 0-9-1）生产者端库。专门为麻雀项目设计。
- 支持Python3.5+。
安装
在requirements.txt中添加sparrow task sender==0.0.x，0.0.x应该是最新版本
pip install sparrow_task_sender
示例
下面是最简单的使用示例
# 发送非延时任务
from task_sender import TaskSender
# 接收消息的api地址
message_backend = "sparrow-task-test-svc:8001/api/sparrow_task/producer/send/"
task_sender = TaskSender(message_backend)
task_sender.send_task(
exchange=exchange,
routing_key=routing_key,
message_code=message_code,
*args,
**kwargs
)
# 发送延时任务
from task_sender import TaskSender
# 接收消息的api地址
message_backend = "sparrow-task-test-svc:8001/api/sparrow_task/producer/send/"
task_sender = TaskSender(message_backend)
task_sender.send_delayed_task(
exchange=exchange,
routing_key=routing_key,
message_code=message_code,
delay=delay,
delay_time=delay_time,
*args,
**kwargs
)
注： args和kwargs为执行任务时需要的变量
欢迎加入QQ群-->： 979659372
