Celery 收下這捆芹菜

目錄celery使用

django配置celery

celery是乙個強大的分布式任務佇列的非同步處理框架，它可以讓任務的執行完全脫離主程式，甚至可以被分配到其他主機上執行。我們通常使用它來實現非同步任務（async task）和定時任務（crontab）

celery 官網：

celery 官方文件英文版：

celery 官方文件中文版：

任務模組, 包含非同步任務和定時任務,非同步任務通常在業務邏輯中被觸發併發往broker任務佇列, 定時任務由celery beat 程序周期性地發往broker任務佇列

訊息中介軟體, 就是任務排程佇列,用來接收任務, 將任務儲存到佇列中, 就像是生產者與消費者模型中的佇列一樣

celery本身不提供broker, 官方推薦使用rabbitmq和redis

任務的執行單元,它實時監控broker佇列, 獲取佇列中的任務, 並執行, 可以看做是生產者與消費者模型中的消費者

任務執行結果的儲存單元,用來儲存任務結果, 以便查詢

celery本身不提供backend, 官方推薦使用rabbitmq和redis

python安裝celery:pip install celery

我們使用redis作為broker和backend, 因此確保你的裝置配置了redis環境

""" project ├── celery_task # celery包 │ ├── __init__.py # 包檔案 │ ├── celery.py # celery連線和配置相關檔案，且名字必須是celery.py │ └── tasks.py # 所有任務函式 ├── add_task.py # 新增任務 └── get_result.py # 獲取結果

"""

""" 1.執行add_task.py將任務新增到佇列 2.cmd切換至所在檔案目錄celery_task下執行worker: >: celery worker -a celery_task -l info -p eventlet 3.執行get_result.py獲取任務結果

"""

# celery.py
from celery import celery
# 配置訊息中介軟體, 用來接收任務
broker = 'redis:'
# 配置backend, 用來儲存任務執行結果
backend = 'redis:'
# worker, 任務執行單元

# tasks.py
# 定義任務
def add(x, y):
res = x + y
print(f'+=')
return res
def minus(x, y):
res = x - y
print(f'-=')
return res

# add_task.py
from .tasks import add, minus
# 在業務邏輯中觸發非同步任務
add_results = add.delay(10, 20)
# 任務執行結果的id
print(add_results.id)

# get_result.py
from .add_tasks import add_results
from celery.result import asyncresult
if __name__ == '__main__':
if async.successful():
result = async.get()
print('任務執行成功')
print(result)
elif async.failed():
print('任務失敗')
elif async.status == 'pending':
print('任務等待中被執行')
elif async.status == 'retry':
print('任務異常後正在重試')
elif async.status == 'started':
print('任務已經開始被執行')

from celery_task.tasks import add
from datetime import timedelta, datetime
# 新增延時任務, 10秒後執行
# 任務執行結果的id
print(add_results.id)

注意: 週期任務是通過celery beat來週期性新增的, , 因此啟動worker服務之後, 還要重開乙個cmd視窗啟動beat服務:celery beat -a celery_task -l info

# celery.py
from celery import celery
from datetime import timedelta
from celery.schedules import crontab
# 配置訊息中介軟體, 用來接收任務
broker = 'redis:'
# 配置backend, 用來儲存任務執行結果
backend = 'redis:'
# worker, 任務執行單元
# 時區
'add-task': ,
'minus-task': 
}

在根目錄下建立包資料夾celery_task

""" project ├── celery_task # celery包 ├── __init__.py # 包檔案 ├── celery.py # celery連線和配置相關檔案，且名字必須是celery.py └── tasks.py # 所有任務函式

"""

# 1.載入django配置環境
import os
os.environ.setdefault("django_settings_module", 'luffyapi.settings.dev')
# 2.載入celery配置環境
from celery import celery
broker = 'redis:'
backend = 'redis:'
# 時區
# utc
from datetime import timedelta
'update-banner-cache': 
}

from home.models import banner

from home.serializers import bannermoderserializer

from django.conf import settings

from django.core.cache import cache

def update_banner_cache():

print('lalal')

banner_query = banner.objects.filter(is_delete=false, is_show=true).order_by('-order').all()

serializer_obj = bannermoderserializer(data=banner_query, many=true)

banner_data = serializer_obj.data

for banner in banner_data:

banner['image'] = settings.base_url + banner.get('image')

cache.set('banner_cache', banner_data)

return true

Celery 收下這捆芹菜

celery系列一 celery 相關配置

celery 執行celery定時任務

語言翻譯成組合語言收下這十點C語言入門須知

Celery 收下這捆芹菜

celery系列 一 celery 相關配置

celery 執行celery定時任務

語言翻譯成組合語言 收下這十點C語言入門須知

相關推薦

celery系列一 celery 相關配置

語言翻譯成組合語言收下這十點C語言入門須知