1

2

3

from celery import Celery

app = Celery('demo')

app.config_from_object('celery_app.celeryconfig')

01

02

03

04

05

06

07

08

09

10

11

12

13

14

15

16

17

18

19

20

21

from datetime import timedelta

from celery.schedules import crontab

# Broker and Backend

BROKER_URL = 'redis://127.0.0.1:6379'

CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/0'

# Timezone

CELERY_TIMEZONE='Asia/Shanghai'    # 指定时区，不指定默认为 'UTC'

# CELERY_TIMEZONE='UTC'

# import

CELERY_IMPORTS = (

    'celery_app.task1',

    'celery_app.task2'

)

# schedules

CELERYBEAT_SCHEDULE = {

    'add-every-30-seconds': {

         'task': 'celery_app.task1.add',

         'schedule': timedelta(seconds=30),       # 每 30 秒执行一次

         'args': (5, 8)                           # 任务函数参数

    }

}

01

02

03

04

05

06

07

08

09

10

11

12

import time

from celery_app import app

@app.task

def add(x, y):

    time.sleep(2)

    return x + y

[mw_shl_code=python,true]import time

from celery_app import app

@app.task

def add(x, y):

    time.sleep(2)

    return x + y