celery 定时任务

用celery定时任务，定时删除文件夹

tasks.py

from celery import celery
import os
import shutil

app = celery('demo')
app.config_from_object('celeryconfig')

app.conf.beat_schedule = {
    'send-every-10-seconds': {
        'task': 'tasks.my_task',
        'schedule': 100.0,
    },
}

@app.task
def my_task():
    """
    删除文件目录下面的所有文件以及文件中的内容
    :return:
    """

    dellist = []
    deldir = "./prod"
    dellist = os.listdir(deldir)

    for f in dellist:
        filepath = os.path.join(deldir, f)
        if os.path.isfile(filepath):
            os.remove(filepath)
            print(filepath + " was removed!")
        elif os.path.isdir(filepath):
            shutil.rmtree(filepath, true)
        print("directory: " + filepath + " was removed!")

定时任务开启方式

celery -a tasks.py worker --loglevel=info --beat