Pycharm中配置Celery启动

Pycharm中配置Celery启动

前置条件

目录结构
----FerDemo
--------celery_demo
------------tasks.py

tasks.py文件代码

import sys
import time
from celery import Celery

app = Celery('demo',
             backend='redis://:password@127.0.0.1/0',
             broker='redis://:password@127.0.0.1/1',
             broker_connection_retry_on_startup=True,
             )


@app.task
def add(a, b):
    time.sleep(100)
    return a + b


if __name__ == '__main__':
    app.start(argv=sys.argv[1:])

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

pycharm配置

执行就行，实际上就是在项目目录FerDemo下执行了 celery - A celery_demo.tasks worker -l INFO