```python BROKER_URL = 'redis://localhost/1' CELERY_RESULT_BACKEND = 'redis://localhost/2' CELERYD_NODES = 'w1 w2 w3' CELERYD_MULTI = 'celery multi' CELERY_TIMEZONE = 'Asia/Shanghai' CELERY_ACCEPT_CONTENT = ['pickle', 'json'] CELERYD_LOG_FILE="/var/log/celery/%N.log" CELERYD_PID_FILE="/var/run/celery/%N.pid" from datetime import timedelta CELERYBEAT_SCHEDULE = { 'update-access-token-every-5-min': { 'task': 'myproject.tasks.workerfunc', 'schedule': timedelta(minutes=5), 'args': [], }, } ``` * 开发环境的命令行: `celery -A wxtest worker -l info -B` * 发布环境的命令行: `celery -A wxtest beat -s celery_beat_file` {{codemaxh}}