celery-api 0.1

给定Celery实例，它检查所有可用的Celery工作者以获取它们所服务的队列和它们所了解的任务信息。

然后它创建一个属性链，允许执行任何任务为queue_name.full_task_name.delay。

通过这个类，你可以将你的Celery安装转换为一系列独立的模块，每个模块都“暴露”它自己的“Celery API”。

为了更清楚地说明，可以将它与http://example.com/users/get?email=john@example.com上的随机HTTP-based API进行比较

• Celery对象（包括代理URL、结果后端设置等）是协议（http://）的类似物

• 队列名称是主机名的类似物（example.com）

• 任务名称是URL路径的类似物（/users/get）

• 任务参数是查询字符串的类似物（?email=john@example.com）

使用示例。

如果我们有一个包含两个队列的Celery安装：“download”（知道如何执行“downloader.download_url”任务）和“parse”（知道如何执行“parser.parse_html”），我们可以实例化API并以下方式使用它

>>> api = celery_api.CeleryApi(celery)
>>> html_page = api.download.downloader.download_html.delay('http://example.com').get()
>>> html_tree = api.parse.parser.parse_html.delay(html_page).get()