Metadata-Version: 2.1
Name: deepfos-celery
Version: 1.1.9
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: arangodb
Requires-Dist: pyArango (>=1.3.2) ; extra == 'arangodb'
Provides-Extra: auth
Requires-Dist: cryptography ; extra == 'auth'
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: brotli
Requires-Dist: brotli (>=1.0.0) ; (platform_python_implementation == "CPython") and extra == 'brotli'
Requires-Dist: brotlipy (>=0.7.0) ; (platform_python_implementation == "PyPy") and extra == 'brotli'
Provides-Extra: cassandra
Requires-Dist: cassandra-driver (<3.21.0) ; extra == 'cassandra'
Provides-Extra: consul
Requires-Dist: python-consul ; extra == 'consul'
Provides-Extra: cosmosdbsql
Requires-Dist: pydocumentdb (==2.3.2) ; extra == 'cosmosdbsql'
Provides-Extra: couchbase
Requires-Dist: couchbase (>=3.0.0) ; extra == 'couchbase'
Provides-Extra: couchdb
Requires-Dist: pycouchdb ; extra == 'couchdb'
Provides-Extra: django
Requires-Dist: Django (>=1.11) ; extra == 'django'
Provides-Extra: dynamodb
Requires-Dist: boto3 (>=1.9.178) ; extra == 'dynamodb'
Provides-Extra: elasticsearch
Requires-Dist: elasticsearch ; extra == 'elasticsearch'
Provides-Extra: eventlet
Requires-Dist: eventlet (>=0.26.1) ; extra == 'eventlet'
Provides-Extra: gevent
Requires-Dist: gevent (>=1.0.0) ; extra == 'gevent'
Provides-Extra: librabbitmq
Requires-Dist: librabbitmq (>=1.5.0) ; extra == 'librabbitmq'
Provides-Extra: lzma
Requires-Dist: backports.lzma ; (python_version < "3.3") and extra == 'lzma'
Provides-Extra: memcache
Requires-Dist: pylibmc ; (platform_system != "Windows") and extra == 'memcache'
Provides-Extra: mongodb
Requires-Dist: pymongo[srv] (>=3.3.0) ; extra == 'mongodb'
Provides-Extra: msgpack
Requires-Dist: msgpack ; extra == 'msgpack'
Provides-Extra: pymemcache
Requires-Dist: python-memcached ; extra == 'pymemcache'
Provides-Extra: pyro
Requires-Dist: pyro4 ; extra == 'pyro'
Provides-Extra: pytest
Requires-Dist: pytest-celery ; extra == 'pytest'
Provides-Extra: redis
Requires-Dist: redis (>=3.2.0) ; extra == 'redis'
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: solar
Requires-Dist: ephem ; extra == 'solar'
Provides-Extra: sqlalchemy
Requires-Dist: sqlalchemy ; extra == 'sqlalchemy'
Provides-Extra: sqs
Requires-Dist: boto3 (>=1.9.125) ; extra == 'sqs'
Requires-Dist: pycurl (==7.43.0.5) ; extra == 'sqs'
Provides-Extra: tblib
Requires-Dist: tblib (>=1.3.0) ; (python_version < "3.8.0") and extra == 'tblib'
Requires-Dist: tblib (>=1.5.0) ; (python_version >= "3.8.0") and extra == 'tblib'
Provides-Extra: yaml
Requires-Dist: PyYAML (>=3.10) ; extra == 'yaml'
Provides-Extra: zookeeper
Requires-Dist: kazoo (>=1.3.1) ; extra == 'zookeeper'
Provides-Extra: zstd
Requires-Dist: zstandard ; extra == 'zstd'

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

|license| |wheel| |pyversion|

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



