本文首發于公眾號：Hunter后端
原文鏈接：celery筆記七之周期/定時任務及crontab定義

periodic task，即為周期，或者定時任務，比如說每天晚上零點零分需要運行一遍某個函數，或者每隔半小時運行一遍該函數，都是這種任務的范疇。

在第一篇筆記的時候我們就介紹過 celery 的組件構成，其中有一個組件叫做 beat，就是我們定時任務的調度器。

所有的定時任務都由 beat 發出，這種情況下，你必須確保在同一個時間點只有一個 beat 任務調度器在運行，假設有兩個 beat 同時在運行，那么在檢測定時任務的時候，系統的任務就可能會被重復發起、調用、執行。

1. beat_schedule 定義
2. beat 啟動
3. crontab介紹

1、beat_schedule 定義

我們來定義兩個定時任務，一個是 blog.tasks.add，定義為每隔 30s 執行一次，現在晚上11點45分，我們定義每天11點50分執行一次。

在進行這些操作前，我們還需要對時區有一些設置，因為我們設置的晚上11點是北京時間，而 Django 和 celery 默認是格林威治時間。

時區設置

我們使用 Django 系統，一些配置在 settigns.py 中定義，詳情可以見前幾篇筆記的 celery 與 Django 系統使用。

關于時區，Django 系統和 celery 的時區我們都設置成北京時間：

# settings.py

# django 時區設置
TIME_ZONE = "Asia/Shanghai"
USE_TZ = False

# celery 時區設置 
CELERY_TIMEZONE = "Asia/Shanghai"
CELERY_ENABLE_UTC = False
DJANGO_CELERY_BEAT_TZ_AWARE = False

定時任務定義

接下來，我們定義定時任務：

from celery.schedules import crontab

app.conf.beat_schedule = {
    'add-every-30-seconds': {
        'task': 'blog.tasks.add',
        'schedule': 30,
        'args': (16, 16),
    },
    'schedule_test_add': {
        'task': 'blog.tasks.minus',
        'schedule': crontab(minute="50", hour="23"),
    },
}

定時任務的定義是我們通過 app.conf.beat_schedule 來操作，一個任務我們定義一個 name 作為 key

在每個 task 下，分別有以下選項：

task：指向我們定義的任務，比如我們這個是指向 blog application 下 tasks.add 任務

schedule：定時任務的策略，如果直接定義一個整數，比如定義的 add-every-30-seconds task 的這個參數定義為 30，就會每隔30s 執行一次

而如果使用 crontab() 函數，則可以更自由的定義到每個月，每周，每天，每時每秒，在示例中我們定義 minute="50", hour="23" 表示每天 23點50分執行一次

更詳細的策略我們下面再詳細介紹。

args：定時任務的參數，比如 add() 函數，我們每隔 30s 執行一次，給定的兩個參數是 (16, 16)，對應 add(x, y) 輸入的兩個值

2、beat 啟動

beat 的啟動方式和 worker 啟動方式一致，將 worker 改成 beat 即可：

celery -A hunter beat -l INFO

也可以指定日志的輸出文件：

celery -A hunter beat -l INFO --logfile=/Users/hunter/python/celery_log/beat.log

當我們啟動 beat 的時候，會發現啟動的文件夾下會有一個名為 celerybeat-schedule.db 的文件，這個是 beat 保存在本地的上一次任務運行的時間的數據，我們也可以指定該文件的輸出地址：

celery -A hunter beat -l INFO -s /Users/hunter/python/celery_log/celerybeat-schedule

如果我們需要運行定時任務，我們需要額外啟動兩個服務，一個是 beat，一個是 worker

一般來說我們會先啟動 worker，再啟動 beat，這樣 beat 有一些立即發出的任務就可以直接被 worker 接收然后運行。

3、crontab介紹

我們使用 crontab() 函數制定定時任務的時間策略，比如每天運行一次，或者指定周幾運行都可以實現。

如果你之前接觸過 Linux 服務器上的 crontab 服務，那么就不用擔心理解它的使用方式，如果沒有，我們可以看看下面官方文檔對著的介紹。

在 celery 里，crontab 函數通過 from celery.schedules import crontab 引入，在 beat_schedule 的定義里作為 schedule 的值，這個前面給過一個示例。

crontab 接受五個參數：

• minute 表示分鐘，接收整數或者整數列表，范圍在0-59，或者字符串表示配置的時間模式
• hour 表示小時，接收整數或者整數列表，范圍在0-23，或者接收字符串表示配置的時間模式
• day_of_week 表示周幾，接收整數或者整數列表，范圍在0-6，其中周日是0，周六是6，或者接收字符串表示配置的時間模式
• day_of_month 表示一個月的第幾天，接收整數或者整數列表，范圍在1-31，或者接收字符串表示配置的時間模式
• month_of_year 表示一年的第幾個月，接收整數或者整數列表，范圍在1-12，或者接收字符串表示配置的時間模式

minute 和 hour

minute 和 hour 直接指向一天的某個時間點，所以，這兩個參數相當于是必填，除非是某些特殊的情況，比如默認的每分鐘執行一次：

crontab()

上面的命令，什么參數也不傳，表示的是每隔一分鐘執行一次

如果我們想指定特定的時間點，比如每天晚上11點23分執行一次：

crontab(minute=23, hour=23)

如果我們想指定某一些分鐘，比如分別在 23點11分，23點25分，23點44分鐘分別執行一次，可以如下操作：

crontab(minute="11,25,44", hour=23)

如果是上面這種沒有特殊關系的時間點，我們可以這樣通過逗號分隔連接起來，如果是有特殊關系的，比如說，每隔一分鐘，或者每隔三分鐘，我們可以通過 */n 的方式來連接。

23點之內，每隔三分鐘執行一次函數可以如下操作：

crontab(minute="*/3", hour=23)

這里的每隔 n 分鐘，其實是 n 的倍數，比如說 */3 就是在 0,3,6,9,12... 等這些分鐘數上執行。

還有一種是范圍內的操作方式，比如說，23點的 10-20分鐘內每分鐘執行一次：

crontab(minute="10-20", hour=23)

那么上面的方式合并起來可不可以，比如說在23點的第5分鐘，11分鐘，51分鐘，31-40分鐘，并且每隔兩分鐘執行一次

也可以實現，把上面的方式都添加在一起，就是一個或的操作：

crontab(minute="5,11,51,10-20,*/2", hour=23)

對于分鐘的這些操作，對于小時數是同樣生效的，不過范圍在 0-23 之間，比如說指定0點，5點，8點，16點的零分執行一次，那就是：

crontab(minute=0, hour="0,5,8,16")

如果是每個小時執行一次呢，就是：

crontab(minute=0, hour="*/1")

# 當 n = 1 的時候 1可以省略，即為
crontab(minute=0, hour="*")

hour 的范圍參數和指定的小時點，像 minute 參數一樣，也是可以或操作功能那樣生效的。

day_of_week

day_of_week 參數表示周幾，當我們使用這個參數的時候，minute 和 hour 參數是同樣生效的，這里我們只演示 day_of_week 參數的作用，小時和分鐘我們都定為 0點0分。

當我們不指定這個參數的時候，即為每天，只有指定了這個參數的時候，定義的周幾才會生效，比如我們定義在周一，周三，周五三天的零點執行一次：

crontab(minute=0, hour=0, day_of_week="1,3,5")

這里，周日是0，周一是1，周二是2，依次類推。

day_of_week 的參數還可以使用英文的簡寫，這里不做介紹，因為我個人認為還是直接使用數字方便一點。

另一個需要注意的是，day_of_week 也可以使用 */n 的形式，但是周幾總共只有7個，所以我這里推薦直接用數字寫出來。

day_of_month

表示一個月的第幾天，范圍是1-31。

其使用方法和 minute、hour 使用的方式是一致的，使用范圍和 */n 的形式都可以實現。

比如我們想實現在1號，5號，7號，8號，以及每個偶數日的零點零分執行一次，可以這樣操作：

crontab(minute=0, hour=0, day_of_month="1,5,7,8,*/2")

month_of_year

表示一年的某幾個月，范圍是1-12。

和前面的使用方式一致，如果需要使用，只有12個數字，還是推薦直接定義。

如果想獲取更多后端相關文章，可掃碼關注閱讀：