文件名称：ndkale:Kale是python任务工作程序库，支持Amazon SQS上的优先级队列
文件大小：65KB
文件格式：ZIP
更新时间：2024-05-24 08:33:24
Python
羽衣甘蓝：来自Nextdoor的分布式任务工作者 Kale是python任务工作程序库，支持Amazon SQS上的优先级队列。 查看我们的博客文章 它是如何工作的？ 像其他分布式任务队列系统一样，发布者将任务消息发送到队列，而工作人员从队列中获取消息。 目前，Kale队列仅支持Amazon SQS。 发行人 发布者可以是导入基于羽衣甘蓝的任务类并调用该类的发布功能的任何python程序。 例如，如果任务类如下所示： # tasks.py class MyTask: def run_task(self, arg1, arg2, *args, **kwargs): # Do something 然后，发布者将任务发布到Amazon SQS，通常需要10毫秒才能返回： import tasks tasks.MyTask.publish(None, arg1,
【文件预览】：
ndkale-master
----setup.py(3KB)
----.gitignore(95B)
----.travis.yml(1KB)
----setup.cfg(67B)
----LICENSE.txt(1KB)
----README.md(8KB)
----example()
--------worker.py(197B)
--------publisher.py(468B)
--------run_worker.sh(77B)
--------__init__.py(22B)
--------run_publisher.sh(106B)
--------README.md(671B)
--------taskworker()
--------run_elasticmq.sh(95B)
----docs()
--------Makefile(7KB)
--------index.rst(425B)
--------example.taskworker.rst(541B)
--------conf.py(8KB)
--------modules.rst(54B)
--------make.bat(7KB)
--------kale.rst(2KB)
--------example.rst(511B)
----kale()
--------worker.py(15KB)
--------publisher.py(4KB)
--------consumer.py(3KB)
--------__init__.py(3KB)
--------default_settings.py(2KB)
--------utils.py(829B)
--------crypt.py(7KB)
--------scripts()
--------task.py(11KB)
--------tests()
--------test_utils.py(3KB)
--------queue_info.py(8KB)
--------sqs.py(3KB)
--------version.py(627B)
--------message.py(8KB)
--------exceptions.py(2KB)
--------timeout.py(1KB)
--------queue_selector.py(5KB)