supervisor配置文件如下:

[program:celery]
; Set full path to celery program if using virtualenv
command=bash celery.sh or python manage.py celery worker or...

directory=/home/ubuntu/python/waterwxapi/
user=root
numprocs=1
stdout_logfile=/var/log/supervisor/celery.log
stderr_logfile=/var/log/supervisor/celery_error.log
autostart=true
autorestart=true
startsecs=10

; Need to wait for currently executing tasks to finish at shutdown.
; Increase this if you have very long running tasks.
stopwaitsecs = 600

; When resorting to send SIGKILL to the program to terminate it
; send SIGKILL to its whole process group instead,
; taking care of its children as well.
killasgroup=true
; Set Celery priority higher than default (999)
; so, if rabbitmq is supervised, it will start first.
priority=1000

django配置

pip install django-celery  Celery  celery-with-redis

settings.py

在INSTALLED_APPS中加入app：

INSTALLED_APPS = (
  ...
  'djcelery',
}

import djcelery
djcelery.setup_loader()

BROKER_URL = 'redis://127.0.0.1:6379/0'
CELERY_ACCEPT_CONTENT = ['pickle', 'json', 'msgpack', 'yaml']

在某个apps的目录下新建一个tasks.py
如果用户是非root用户，而supervisor是 ROOT 用户进行的，所以要在tasks.py中加上

from celery import Celery,platforms
platforms.C_FORCE_ROOT = True

tasks.py

#coding=utf-8
from celery import Celery,platforms
from config import bind_device
app = Celery('tasks', broker='redis://localhost:6379//')
platforms.C_FORCE_ROOT = True
@app.task
def sendMesg(event):
  ...codes

sudo supervisorctl 重新restart项目