zoukankan      html  css  js  c++  java
  • (九)9-2celery简介

    Celery 是一个python开发的一部分布式任务调度模块
    Celery本身不提供消息服务,使用第三方服务,borker传递任务,目前支持redis,mysql等

    安装celery,redis
    pip install celery
    pip install redis
    安装redis服务,并启动redis

    使用celery的例子
    服务端:

    celery_service.py
    #coding:utf8
    from celery import  Celery
    import  redis
    
    broker = "redis://172.16.61.158:6379/5"
    backend = "redis://172.16.61.158:6379/6"
    app = Celery("test",broker=broker,backend=backend)
    
    @app.task
        def add(x,y):

    在服务器执行:

    celery -A celery_service  worker  --loglevel=info

    客户端:test_celery.py

    #coding:utf8
    
    
    import  time
    from celery_service import add
    a = add.delay(10,20)
    time.sleep(1)
    print a
    print type(a)
    print a.result
    print  a.status

    执行结果:python  test_celery.py

    9d0c53e7-67ce-4e87-a823-35ffc004444f
    <class 'celery.result.AsyncResult'>
    30
    SUCCESS

    在服务端查看:

  • 相关阅读:
    js使用笔记
    rabbit-mq使用官方文档
    tomcat Enabling JMX Remote
    Venom的简单使用
    Random模块
    时间模块
    shulti模块简述
    Python的os模块
    Python压缩及解压文件
    Kali的内网穿透
  • 原文地址:https://www.cnblogs.com/pythonlx/p/8072109.html
Copyright © 2011-2022 走看看