#首先进行一些简单配置

pip install celery

apt-get install erlang

apt-get install rabbitmq-server

#开启rabbitmq-server命令如下

service rabbitmq-server start

vi /var/log/rabbitmq/rabbit\@ubuntu.log

cd /etc/rabbitmq/

vi rabbitmq.config

[{rabbit, [{loopback_users, []}]}].

service rabbitmq-server restart 

rm rabbit@localhost.log

service rabbitmq-server restart

rabbitmq-plugins enable rabbitmq_management

#coding:utf-8

from celery import Celery

import time

app = Celery('tasks',backend='amqp', broker='amqp://guest@127.0.0.1:5672//')

@app.task

def add(x, y):

    print 'hello celery'

    time.sleep(10)

    return x + y

celery -A tasks worker --loglevel=info

from celery import Celery

from celery.schedules import crontab

app = Celery()

@app.on_after_configure.connect

def setup_periodic_tasks(sender, **kwargs):

    # Calls test('hello') every 10 seconds.

    sender.add_periodic_task(10.0, test.s('hello'), name='add every 10')

    # Calls test('world') every 30 seconds

    sender.add_periodic_task(30.0, test.s('world'), expires=10)

    # Executes every Monday morning at 7:30 a.m.

    sender.add_periodic_task(

        crontab(hour=7, minute=30, day_of_week=1),

        test.s('Happy Mondays!'),

    )

@app.task

def test(arg):

    print(arg)