首页 » Ubuntu » celery的配置和使用

celery的配置和使用

原文 http://blog.csdn.net/zhaobig/article/details/78745062

2017-12-08 02:01:42阅读(605)

环境:ubuntu环境

下载必要的包:

pip install celery

apt-get install erlang

apt-get install rabbitmq-server

开启rabbitmq-server

service rabbitmq-server start

celery的<a href=配置和使用" src="http://img.blog.csdn.net/20171207194813301?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvemhhb2JpZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center" alt="">

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

celery的配置和使用

找到config file(s)这一行,默认应该是个None,修改为/etc/rabbitmq/rabbitmq.config

celery的配置和使用

显示没有找到配置文件.需要我们自己创建这个文件

cd /etc/rabbitmq/
vi rabbitmq.config
编辑内容如下
[{rabbit, [{loopback_users, []}]}].
这里的意思是开放使用,rabbitmq默认创建的用户guest,密码也是guest,这个用户默认只能是本机访问,localhost或者127.0.0.1,从外部访问需要添加上面的配置。

保存配置后重启服务:

service rabbitmq-server restart

此时就可以从外部访问了,但此时再看log文件,发现内容还是原来的,还是显示没有找到配置文件,可以手动删除这个文件再重启服务,不过这不影响使用

rm rabbit@localhost.log 

service rabbitmq-server restart

这时查看log,发现没问题

celery的配置和使用

开启管理UI:

rabbitmq-plugins enable rabbitmq_management

service rabbitmq-server restart

在Windows下打开地址:

http://192.168.24.179:15672
celery的配置和使用

用户名密码都是guest

celery的配置和使用

利用celery执行异步任务

创建tasks.py文件

写入以下代码

# 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服务

celery -A tasks worker --loglevel=info

celery的配置和使用

执行任务

celery的配置和使用

也可以循环执行add函数来测试同步和异步的特点,例如执行10000次看他们的区别

利用celery执行定时任务

创建time_task.py文件.主要职责是每隔10秒输出hello,每隔30秒输出world,每周一早上7点半输出Happy Mondays.你也可以改造成根据用户生日定时发送生日贺卡邮件或者每周一备份数据库等功能

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)

新建一个终端

celery的配置和使用

celery的配置和使用

最新发布

CentOS专题

关于本站

5ibc.net旗下博客站精品博文小部分原创、大部分从互联网收集整理。尊重作者版权、传播精品博文,让更多编程爱好者知晓!

小提示

按 Ctrl+D 键,
把本文加入收藏夹