Metadata-Version: 2.2
Name: deepfos-celery
Version: 1.1.23
Summary: Distributed Task Queue.
Home-page: http://celeryproject.org
Author: DeepFOS
Author-email: python@deepfinance.com
License: BSD
Project-URL: Documentation, http://docs.celeryproject.org/en/latest/index.html
Project-URL: Code, https://gitee.com/python-development-team/deepfos-celery/
Project-URL: Tracker, https://github.com/celery/celery/issues
Project-URL: Funding, https://opencollective.com/celery
Keywords: task job queue distributed messaging actor
Platform: any
Classifier: Development Status :: 5 - Production/Stable
Classifier: License :: OSI Approved :: BSD License
Classifier: Topic :: System :: Distributed Computing
Classifier: Topic :: Software Development :: Object Brokering
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: Implementation :: CPython
Classifier: Programming Language :: Python :: Implementation :: PyPy
Classifier: Operating System :: OS Independent
Requires-Python: >=3.6,
License-File: LICENSE
Requires-Dist: pytz>0.dev.0
Requires-Dist: billiard<4.0,>=3.6.3.0
Requires-Dist: kombu==5.2.4
Requires-Dist: vine<6.0,>=5.0.0
Requires-Dist: click<8.0,>=7.0
Requires-Dist: click-didyoumean>=0.0.3
Requires-Dist: click-repl>=0.1.6
Requires-Dist: click-plugins>=1.1.1
Provides-Extra: azureblockblob
Requires-Dist: azure-storage==0.36.0; extra == "azureblockblob"
Requires-Dist: azure-common==1.1.5; extra == "azureblockblob"
Requires-Dist: azure-storage-common==1.1.0; extra == "azureblockblob"
Provides-Extra: sqs
Requires-Dist: boto3>=1.9.125; extra == "sqs"
Requires-Dist: pycurl==7.43.0.5; extra == "sqs"
Provides-Extra: pyro
Requires-Dist: pyro4; extra == "pyro"
Provides-Extra: solar
Requires-Dist: ephem; extra == "solar"
Provides-Extra: lzma
Requires-Dist: backports.lzma; python_version < "3.3" and extra == "lzma"
Provides-Extra: pytest
Requires-Dist: pytest-celery; extra == "pytest"
Provides-Extra: memcache
Requires-Dist: pylibmc; platform_system != "Windows" and extra == "memcache"
Provides-Extra: pymemcache
Requires-Dist: python-memcached; extra == "pymemcache"
Provides-Extra: s3
Requires-Dist: boto3>=1.9.125; extra == "s3"
Provides-Extra: slmq
Requires-Dist: softlayer_messaging>=1.0.3; extra == "slmq"
Provides-Extra: gevent
Requires-Dist: gevent>=1.0.0; extra == "gevent"
Provides-Extra: cosmosdbsql
Requires-Dist: pydocumentdb==2.3.2; extra == "cosmosdbsql"
Provides-Extra: django
Requires-Dist: Django>=1.11; extra == "django"
Provides-Extra: couchbase
Requires-Dist: couchbase>=3.0.0; extra == "couchbase"
Provides-Extra: eventlet
Requires-Dist: eventlet>=0.26.1; extra == "eventlet"
Provides-Extra: yaml
Requires-Dist: PyYAML>=3.10; extra == "yaml"
Provides-Extra: zookeeper
Requires-Dist: kazoo>=1.3.1; extra == "zookeeper"
Provides-Extra: brotli
Requires-Dist: brotlipy>=0.7.0; platform_python_implementation == "PyPy" and extra == "brotli"
Requires-Dist: brotli>=1.0.0; platform_python_implementation == "CPython" and extra == "brotli"
Provides-Extra: elasticsearch
Requires-Dist: elasticsearch; extra == "elasticsearch"
Provides-Extra: dynamodb
Requires-Dist: boto3>=1.9.178; extra == "dynamodb"
Provides-Extra: mongodb
Requires-Dist: pymongo[srv]>=3.3.0; extra == "mongodb"
Provides-Extra: librabbitmq
Requires-Dist: librabbitmq>=1.5.0; extra == "librabbitmq"
Provides-Extra: auth
Requires-Dist: cryptography; extra == "auth"
Provides-Extra: arangodb
Requires-Dist: pyArango>=1.3.2; extra == "arangodb"
Provides-Extra: msgpack
Requires-Dist: msgpack; extra == "msgpack"
Provides-Extra: cassandra
Requires-Dist: cassandra-driver<3.21.0; extra == "cassandra"
Provides-Extra: tblib
Requires-Dist: tblib>=1.5.0; python_version >= "3.8.0" and extra == "tblib"
Requires-Dist: tblib>=1.3.0; python_version < "3.8.0" and extra == "tblib"
Provides-Extra: couchdb
Requires-Dist: pycouchdb; extra == "couchdb"
Provides-Extra: zstd
Requires-Dist: zstandard; extra == "zstd"
Provides-Extra: redis
Requires-Dist: redis>=3.2.0; extra == "redis"
Provides-Extra: sqlalchemy
Requires-Dist: sqlalchemy; extra == "sqlalchemy"
Provides-Extra: consul
Requires-Dist: python-consul; extra == "consul"
Dynamic: author
Dynamic: author-email
Dynamic: classifier
Dynamic: description
Dynamic: home-page
Dynamic: keywords
Dynamic: license
Dynamic: platform
Dynamic: project-url
Dynamic: provides-extra
Dynamic: requires-dist
Dynamic: requires-python
Dynamic: summary

.. image:: https://docs.celeryq.dev/en/latest/_images/celery-banner-small.png

|license| |wheel| |pyversion|

:Version: 1.1.23
: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/

