对模块进行改名优化

README.md

@@ -1,7 +1,7 @@
-# flask_celery_context
+# celery_context
 
 ## Documentation
-The documentation is hosted at [https://github.com/BingerYang/logger_app](https://github.com/BingerYang/flask_celery_context)
+The documentation is hosted at [https://github.com/BingerYang/celery_context](https://github.com/BingerYang/celery_context)
 
 ## Installation
 ```shell
@@ -12,15 +12,15 @@ The documentation is hosted at [https://github.com/BingerYang/logger_app](https:
 ```python
 # -*- coding: utf-8 -*- 
 from flask import Flask
-from flask_celery import Celery
+from celery_context import Celery
 from flask import request
 
 config = dict(redis={"host": "*****", "port": 31320, "password": "lab@2019"})
 redis_url = "redis:https://:{password}@{host}:{port}".format(**config["redis"])
 app = Flask("example.run")
 app.config['CELERY_BROKER_URL'] = "{}/1".format(redis_url)
 app.config['CELERY_RESULT_BACKEND'] = "{}/2".format(redis_url)
-celery = Celery(app)
+celery = Celery(app=app)
 celery.setup_task_context(lambda: dict(path=request.path))
 
 
@@ -40,4 +40,4 @@ def index():
 if __name__ == "__main__":
  app.run()
 
-```
+```

README.rst

@@ -1,18 +1,18 @@
-flask_celery_context
-====================
+celery_context
+==============
 
 Documentation
 -------------
 
-The documentation is hosted at https://github.com/BingerYang/flask_celery_context
+The documentation is hosted at https://github.com/BingerYang/celery_context
 
 
 Installation
 ------------
 
 .. code:: shell
 
- pip install flask_celery_context
+ pip install celery_context
 
 Usage
 -----
@@ -24,15 +24,15 @@ example:
 
  # -*- coding: utf-8 -*-
  from flask import Flask
- from flask_celery import Celery
+ from celery_context import Celery
  from flask import request
 
  config = dict(redis={"host": "*****", "port": 31320, "password": "lab@2019"})
  redis_url = "redis:https://:{password}@{host}:{port}".format(**config["redis"])
  app = Flask("example.run")
  app.config['CELERY_BROKER_URL'] = "{}/1".format(redis_url)
  app.config['CELERY_RESULT_BACKEND'] = "{}/2".format(redis_url)
- celery = Celery(app)
+ celery = Celery(app=app)
  celery.setup_task_context(lambda: dict(path=request.path))
 
 

flask_celery/__init__.py → celery_context/__init__.py

@@ -2,9 +2,9 @@
 # @Time : 2020-02-07 11:26
 # @Author : binger
 
-name = "flask_celery_context"
-version_info = (0, 0, 1, 20040717)
+name = "celery_context"
+version_info = (0, 0, 2, 20052710)
 __version__ = ".".join([str(v) for v in version_info])
-__description__ = '实现celery在flask下的上下文一致性的简单扩展'
+__description__ = '实现celery在flask/django下的上下文一致性的简单扩展'
 
 from .model import Celery, reload_celery_task

flask_celery/model.py → celery_context/model.py

@@ -3,6 +3,7 @@
 # @Author : binger
 
 __all__ = ["reload_celery_task", "Celery"]
+
 from celery import Celery as CeleryBase
 
 # 在异步处理时使用，如下：
@@ -69,8 +70,9 @@ def retry(self, args=None, kwargs=None, task_id=None, **rest):
 class Celery(CeleryBase):
  _setup_task_context_cb = None
 
- def __init__(self, app=None, *args, **kwargs):
+ def __init__(self, *args, **kwargs):
  super(Celery, self).__init__(*args, **kwargs)
+ app = kwargs.get("app", None)
  if app:
  self.init_app(app)
 

setup.py

@@ -1,6 +1,6 @@
 import os
 from setuptools import setup, find_packages
-from flask_celery import name, __description__, __version__
+from celery_context import name, __description__, __version__
 
 # read dev requirements
 fname = os.path.join(os.path.dirname(__file__), 'requirements.txt')