做項(xiàng)目時(shí)遇到一個(gè)需要定時(shí)啟動(dòng)特定任務(wù)的需求滥壕，記錄下從配置到在服務(wù)器中啟動(dòng)完成需求的全程娩鹉。
1.下載安裝：
apt-get install rabbitmq-server
pip install celery
2.配置：
在settings中加入如下代碼：
CELERY_ACCEPT_CONTENT = ['pickle', 'json', 'msgpack', 'yaml'] #接受的文件類型
CELERYD_MAX_TASKS_PER_CHILD = 10 #每個(gè)worker執(zhí)行多少次任務(wù)后死亡轧拄，防止內(nèi)存泄漏用的
在settings的同級目錄下新建celery.py文件卓鹿，進(jìn)入后輸入以下代碼：
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery, platforms
from celery.schedules import crontab
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', '你的項(xiàng)目名稱.settings')
app = Celery('你的項(xiàng)目名稱')
# Using a string here means the worker don't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
# should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings')
# Load task modules from all registered Django app configs.
# app.autodiscover_tasks()
# 允許root 用戶運(yùn)行celery
platforms.C_FORCE_ROOT = True
#以下是定時(shí)任務(wù)模塊留荔，可以添加一個(gè)或多個(gè)定時(shí)任務(wù)存谎， 如只是部署異步任務(wù)既荚，可以把這段代碼注釋掉
app.conf.update(
CELERYBEAT_SCHEDULE = {
'任務(wù)名稱（自定義）': {
'task': '你的項(xiàng)目app.tasks.你要執(zhí)行的腳本或代碼函', # 這個(gè)task任務(wù)在app下的tasks.py文件內(nèi)
'schedule': timedelta(seconds=幾秒),
'args': （想傳的參數(shù)）#不傳參也可去除此項(xiàng)
},
'任務(wù)名稱（自定義）': {
'task': '你的項(xiàng)目app.tasks.你要執(zhí)行的腳本或代碼函數(shù)', # 這個(gè)task任務(wù)在app下的tasks.py文件內(nèi)
'schedule': crontab(hour=幾點(diǎn), minute=幾分),
'args': （想傳的參數(shù)）#不傳參也可去除此項(xiàng)
}
}
)
@app.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))
以上代碼添加完后句各，需要去你的app下新建一個(gè)tasks.py文件（名字必須要是tasks，不能隨意修改）初厚，在tasks文件中寫入你要執(zhí)行的代碼函數(shù)
from __future__ import absolute_import
import os
from datetime import datetime, timedelta
from celery import shared_task
from django.http import HttpResponse
from system.models import LogVisitTimes, TotalVisitTimes
#函數(shù)如果需要傳參产禾，那么在celery.py下的定時(shí)任務(wù)模塊中添加args項(xiàng)亚情。
@shared_task
def 函數(shù)(傳參):
return 返回值
@shared_task
def 函數(shù)(傳參):
return 返回值
#可以寫多個(gè)
然后在此app下的views.py文件中調(diào)用下tasks.py里的函數(shù)衫生，添加如下代碼：
from .tasks import 函數(shù)1, 函數(shù)2
def post(request):
result1 = 函數(shù)1.delay(可傳參) #加上delay()表示開啟異步執(zhí)行
result2 = 函數(shù)2(可傳參) #不開啟異步執(zhí)行罪针，
到此，項(xiàng)目中的異步或者定時(shí)任務(wù)或者異步定時(shí)任務(wù)就配置完成了
接下來是執(zhí)行階段：
在終端中進(jìn)入到你的項(xiàng)目目錄下西篓，輸入如下命令：
sudo rabbitmq-server -detached #開啟 rabbitmq服務(wù)
celery -A 你的項(xiàng)目名稱 worker -l info --beat 開啟定時(shí)任務(wù)
如果一切順利那么會(huì)顯示如下
注：出現(xiàn)的這個(gè)warning是因?yàn)槲翼?xiàng)目還在開發(fā)階段，所settings中DEBUG設(shè)置為True吮成，可設(shè)置為False。
這樣的話茶宵，在本地配置和執(zhí)行都沒有問題了乌庶，再接下來就是如何在服務(wù)器中運(yùn)行這個(gè)定時(shí)任務(wù)，這里用到screen會(huì)話透敌，大部分服務(wù)器上都是自帶screen會(huì)話功能的。
把項(xiàng)目部署到服務(wù)器上去后，或者服務(wù)器更新git了你寫的代碼德绿，終端執(zhí)行如下操作：
screen -S 隨意命名（但請記住這個(gè)名字）
按下回車后雖然屏幕上變化不大蕴纳，但是其實(shí)已經(jīng)是screen會(huì)話中了，進(jìn)入你的項(xiàng)目目錄下稻薇，執(zhí)行如下操作：
celery -A 你的項(xiàng)目名稱 worker -l info --beat
之后會(huì)出現(xiàn)和本地運(yùn)行時(shí)一樣的一段提示，那么就全部OK了。
如果你是用xshell進(jìn)入服務(wù)器操作的骂铁，那么你可以關(guān)上窗口了。
下次要再進(jìn)入這個(gè)screen窗口名段，只需要screen -ls 查看已有的會(huì)話泣懊，然后screen -r 窗口名稱伸辟，就可以重新進(jìn)入會(huì)話窗口馍刮，screen -X -S 會(huì)話進(jìn)程編號 quit，可以退出并刪除該會(huì)話卡啰。
-----完
參考：screen相關(guān)https://www.cnblogs.com/ywl925/p/3604530.html
異步定時(shí)任務(wù)相關(guān)https://blog.csdn.net/weixin_42578481/article/details/81047030
