Celery（2） celery快速上手使用

github：

碼雲：

# coding=utf-8

from celery import celery
# celery 的相關配置
celery = celery('tasks', broker='redis://localhost:6379/0')
# 具體任務(執行兩個數相加)
@celery.task
defadd
(x, y):
return x + y

$ celery -a tasks worker -l info  ### -l info表示loglevel等級為info級，也可以設為debug級

# 開啟python互動式環境

$ python
# 輸入一下兩行**
# tasks 為tasks.py 的路徑(樣例是在同一目錄下)
>>> 
from tasks import add
>>> add.delay(2,5)
# 返回結果的編號
>>>5dc2624e-c898-4702-b510-08b3aec3a440>

執行成功，耗時0.000605990000622 結果為15

celerytasks/

├── celery.py
├── config.py
├── __init__.py
└── tasks.py

celery.py

from __future__ import absolute_import 

from celery import celery

config.py

# config file

from __future__ import absolute_import
celery_result_backend = 'redis:'
broker_url = 'redis:'

tasks.py

from __future__ import absolute_import

defadd
(x, y):
return x + y

$ celery -a mycelerytasks worker -l info

# 進入mycelerytasks同級目錄

$ python #開啟python互動式環境
>>>from mycelerytasks import add
>>>add.delay(1,2)

celery系列 一 celery 相關配置

celery result backend amqp 官網優化的地方也推薦使用c的librabbitmq celery task result expires 1200 celery任務執行結果的超時時間，我的任務都不需要返回結果,只需要正確執行就行 celeryd concurrency 50 c...

celery 執行celery定時任務

場景 在虛擬機器上執行 python django celery redis 的定時任務 可能遇到的問題 如果在執行過程中，定時任務突然退出，並報以下錯誤，錯誤顯示，沒有許可權訪問一些目錄檔案 解決方案 1 關閉當前redis服務 在step 3中有描述如何關閉 2 以root使用者執行啟動redi...

使用celery之怎麼讓celery跑起來

celery 官網幫助文件 前言自從發了上次的文章使用celery之深入celery配置,有一些再問我怎麼讓celery跑起來.其實說來也是,celery在新手眼裡真的是比較重量級,不好懂,今天先讓他跑起來吧 本文大部分 和使用方法都可以在celery官網看到 我想要的效果 我想實現乙個定時任務,每...