__init__.py 添加注释

celery_tasks/__init__.py

@@ -10,7 +10,7 @@ celery_app = Celery(
     broker='redis://:test@127.0.0.1:6379/0',
     # backend='redis://:test@127.0.0.1:6379/1',
     backend='db+sqlite:///celeryresults.sqlite3',
-    include=[
+    include=[  # 执行任务库，代表所能执行的所有任务，即通过@celery_app.task修饰的所有函数
         'celery_tasks.commonprocess',
         # 'celery_tasks.business_part',
         # 'celery_tasks.technical_part'

gunicorn_config.py

@@ -0,0 +1,17 @@
+workers = 1 # 创建进程数 每个进程占用一个CPU核心
+bind = "0.0.0.0:8000"  # celery和flask连接端口
+backlog = 2048
+loglevel = "INFO"
+daemon = True
+pidfile = "/var/run/backend.pid"
+accesslog = "/var/log/backend/access.log"
+errorlog = "/var/log/backend/error.log"
+
+
+# 启动命令
+'''
+gunicorn --config gunicorn_config.py make_celery
+celery multi start worker -A make_celery:celery_app -P prefork -E --
+loglevel=INFO --logfile=/var/log/celery/%n%I.log --pidfile=/run/celery/%n.pid
+celery -A make_celery:celery_app events
+'''

make_celety.py

@@ -0,0 +1,3 @@
+from celery_tasks import celery_app,create_app
+
+app = create_app() # 同步创建了celery和flask