1. 程式人生 > >Python-celery的使用

Python-celery的使用

安裝:pip install celery 

pip install eventlet

 

需要提前安裝redis。

(Download, extract and compile Redis with:

$ wget http://download.redis.io/releases/redis-4.0.11.tar.gz
$ tar xzf redis-4.0.11.tar.gz
$ cd redis-4.0.11
$ make

The binaries that are now compiled are available in the src directory. Run Redis with:

啟動服務

$ src/redis-server

You can interact with Redis using the built-in client:

執行redis,rebitmq或者其他。src/redis-server redis.conf  利用配置檔案執行,配置檔案內修改ip和埠

 

 

 

建立一個tasks.py檔案。

from celery import Celery
import time


app = Celery('tasks', broker='redis://192.168.118.130:6379/0',
             backend="redis://192.168.118.130:6379/0")


@app.task
def send_mail():
    print('hello world')

 

建立一個需要執行的檔案。T1.py

from tasks import send_mail

if __name__ == '__main__':
    send_mail.delay() #括號裡面可以放參數,把要要傳送的郵件的地址放進去。

 

pycharm裡面命令列執行:

 

celery -A tasks worker --loglevel=info -P eventlet

 

執行需要執行的檔案,然後會收到相關問題。返回的問題等。

 

 

send_mail.delay()  可以送引數,把引數直接放進去。郵箱地址。