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() 可以送引數,把引數直接放進去。郵箱地址。