.. image:: https://docs.celeryq.dev/en/latest/_images/celery-banner-small.png
|license| |wheel| |pyversion|
:Version: 1.1.11
:Web: http://celeryproject.org/
:Download: https://pypi.org/project/deepfos-celery/
:Source: https://gitee.com/python-development-team/deepfos-celery/
:Keywords: task, queue, job, async, rabbitmq, amqp, redis,
python, distributed, actors
What is this?
=============
本项目基于 ``celery-5.0.5`` 开发，主要功能：
* 添加 ``asyncio`` 支持，更容易集成到异步web框架
* 支持 ``redis`` 集群
**注：项目是 ``celery`` 的超集，但并非所有功能都支持 ``asyncio`` ，并且目前仅完成了 ``redis`` 作为 ``broker`` 和 ``backend`` 的支持。**
Get Started
===========
创建任务和官方 ``celery`` 一样:
.. code-block:: python
from celery import Celery
app = Celery('hello', broker='redis://:@localhost/')
@app.task(aio_variant=True)
def hello():
return 'hello world'
但增加了 ``aio_variant`` 这一参数，相较于普通的任务发送和获取结果的方式：
.. code-block:: python
task = hello.apply_async()
result = task.get()
可以使用:
.. code-block:: python
task = await hello.aio.apply_async()
result = await task.get()
**注意**
这不只是一个简单的语法糖，而是确实使用 ``aioredis`` 替换了原有 ``redis-py`` 的同步网络请求。
.. _license:
License
=======
This software is licensed under the `New BSD License`. See the ``LICENSE``
file in the top distribution directory for the full license text.
.. # vim: syntax=rst expandtab tabstop=4 shiftwidth=4 shiftround
.. |license| image:: https://img.shields.io/pypi/l/celery.svg
:alt: BSD License
:target: https://opensource.org/licenses/BSD-3-Clause
.. |wheel| image:: https://img.shields.io/pypi/wheel/celery.svg
:alt: Celery can be installed via wheel
:target: https://pypi.org/project/celery/
.. |pyversion| image:: https://img.shields.io/pypi/pyversions/celery.svg
:alt: Supported Python versions.
:target: https://pypi.org/project/celery/
Raw data
{
"_id": null,
"home_page": "http://celeryproject.org",
"name": "deepfos-celery",
"maintainer": null,
"docs_url": null,
"requires_python": ">=3.6",
"maintainer_email": null,
"keywords": "task job queue distributed messaging actor",
"author": "DeepFOS",
"author_email": "python@deepfinance.com",
"download_url": null,
"platform": "any",
"description": ".. image:: https://docs.celeryq.dev/en/latest/_images/celery-banner-small.png\n\n|license| |wheel| |pyversion|\n\n:Version: 1.1.11\n:Web: http://celeryproject.org/\n:Download: https://pypi.org/project/deepfos-celery/\n:Source: https://gitee.com/python-development-team/deepfos-celery/\n:Keywords: task, queue, job, async, rabbitmq, amqp, redis,\n python, distributed, actors\n\nWhat is this?\n=============\n\n\u672c\u9879\u76ee\u57fa\u4e8e ``celery-5.0.5`` \u5f00\u53d1\uff0c\u4e3b\u8981\u529f\u80fd\uff1a\n\n* \u6dfb\u52a0 ``asyncio`` \u652f\u6301\uff0c\u66f4\u5bb9\u6613\u96c6\u6210\u5230\u5f02\u6b65web\u6846\u67b6\n* \u652f\u6301 ``redis`` \u96c6\u7fa4\n\n**\u6ce8\uff1a\u9879\u76ee\u662f ``celery`` \u7684\u8d85\u96c6\uff0c\u4f46\u5e76\u975e\u6240\u6709\u529f\u80fd\u90fd\u652f\u6301 ``asyncio`` \uff0c\u5e76\u4e14\u76ee\u524d\u4ec5\u5b8c\u6210\u4e86 ``redis`` \u4f5c\u4e3a ``broker`` \u548c ``backend`` \u7684\u652f\u6301\u3002**\n\nGet Started\n===========\n\n\u521b\u5efa\u4efb\u52a1\u548c\u5b98\u65b9 ``celery`` \u4e00\u6837:\n\n.. code-block:: python\n\n from celery import Celery\n\n app = Celery('hello', broker='redis://:@localhost/')\n\n @app.task(aio_variant=True)\n def hello():\n return 'hello world'\n\n\n\u4f46\u589e\u52a0\u4e86 ``aio_variant`` \u8fd9\u4e00\u53c2\u6570\uff0c\u76f8\u8f83\u4e8e\u666e\u901a\u7684\u4efb\u52a1\u53d1\u9001\u548c\u83b7\u53d6\u7ed3\u679c\u7684\u65b9\u5f0f\uff1a\n\n.. code-block:: python\n\n task = hello.apply_async()\n result = task.get()\n\n\n\u53ef\u4ee5\u4f7f\u7528:\n\n.. code-block:: python\n\n task = await hello.aio.apply_async()\n result = await task.get()\n\n\n**\u6ce8\u610f**\n\n \u8fd9\u4e0d\u53ea\u662f\u4e00\u4e2a\u7b80\u5355\u7684\u8bed\u6cd5\u7cd6\uff0c\u800c\u662f\u786e\u5b9e\u4f7f\u7528 ``aioredis`` \u66ff\u6362\u4e86\u539f\u6709 ``redis-py`` \u7684\u540c\u6b65\u7f51\u7edc\u8bf7\u6c42\u3002\n\n\n.. _license:\n\nLicense\n=======\n\nThis software is licensed under the `New BSD License`. See the ``LICENSE``\nfile in the top distribution directory for the full license text.\n\n.. # vim: syntax=rst expandtab tabstop=4 shiftwidth=4 shiftround\n\n.. |license| image:: https://img.shields.io/pypi/l/celery.svg\n :alt: BSD License\n :target: https://opensource.org/licenses/BSD-3-Clause\n\n.. |wheel| image:: https://img.shields.io/pypi/wheel/celery.svg\n :alt: Celery can be installed via wheel\n :target: https://pypi.org/project/celery/\n\n.. |pyversion| image:: https://img.shields.io/pypi/pyversions/celery.svg\n :alt: Supported Python versions.\n :target: https://pypi.org/project/celery/\n\n\n\n",
"bugtrack_url": null,
"license": "BSD",
"summary": "Distributed Task Queue.",
"version": "1.1.11",
"project_urls": {
"Code": "https://gitee.com/python-development-team/deepfos-celery/",
"Documentation": "http://docs.celeryproject.org/en/latest/index.html",
"Funding": "https://opencollective.com/celery",
"Homepage": "http://celeryproject.org",
"Tracker": "https://github.com/celery/celery/issues"
},
"split_keywords": [
"task",
"job",
"queue",
"distributed",
"messaging",
"actor"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "8a3ac29926038e272f05708e578eb8b86755a77083c88541ecd628fb7544fe0d",
"md5": "99104491d78161d8bc81f66c0d238f59",
"sha256": "aec5110041d780cf42c7070f0fec8269e1422476a4e3b4771dceae0b5e55cdbc"
},
"downloads": -1,
"filename": "deepfos_celery-1.1.11-py3-none-any.whl",
"has_sig": false,
"md5_digest": "99104491d78161d8bc81f66c0d238f59",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": ">=3.6",
"size": 440075,
"upload_time": "2024-04-02T02:38:55",
"upload_time_iso_8601": "2024-04-02T02:38:55.338032Z",
"url": "https://files.pythonhosted.org/packages/8a/3a/c29926038e272f05708e578eb8b86755a77083c88541ecd628fb7544fe0d/deepfos_celery-1.1.11-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2024-04-02 02:38:55",
"github": true,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"github_user": "celery",
"github_project": "celery",
"travis_ci": false,
"coveralls": false,
"github_actions": true,
"tox": true,
"lcname": "deepfos-celery"
}
JSON
