1.抽取配置信息

2.一条命令启动worker和beat：

• celery -A task worker -l INFO -B

3.代码

Queue('beat_task',routing_key='beat_task')


from datetime import timedelta
from celery.schedules import crontab
CELERYBEAT_SCHEDULE = {
'my_beat':{
    'task':'task.task4',

    'schedule':timedelta(seconds=5),

    'args':(116,2),

    'options':{

        'queue':'beat_task',

        'routing_key':'beat_task'

    }

}
}