nsqworker:NSQ的异步Python任务工作器

时间:2024-05-30 12:32:09
【文件属性】:

文件名称:nsqworker:NSQ的异步Python任务工作器

文件大小:4KB

文件格式:ZIP

更新时间:2024-05-30 12:32:09

Python

nsqworker-NSQ的异步任务工作程序 当前仅支持线程工作者。 它使用官方的Python / 库处理消息传递,并在执行程序线程池中执行阻止消息处理程序功能。 该软件包背后的动机是用代替执行长期运行任务的 / RabbitMQ辅助进程。 安装 pip install git+https://github.com/bsphere/nsqworker.git 用法 import nsq import time from nsqworker import nsqworker def process_message(message): print "start", message.id time.sleep(2) print "end", message.id def handle_exc(message, e): traceback.print_exc() w.io_


【文件预览】:
nsqworker-master
----setup.py(164B)
----.gitignore(19B)
----nsqworker()
--------errors.py(39B)
--------__init__.py(0B)
--------nsqworker.py(4KB)
----requirements.txt(14B)
----README.md(3KB)

网友评论