celery實測之Django呼叫

1、新建並配置乙個celery檔案，需同setting在同一級。

from celery import celery

from django.conf import settings
import os
# 為celery設定環境變數
os.environ.setdefault('django_settings_module', 'aimilling.settings.dev') # 注意此為專案的名稱
# 建立應用
# 配置應用
# 配置broker, 這裡我們用redis作為broker
broker_url='redis:', # 無密碼寫法
broker_url='redis:', # 密碼寫法
)

print(number1+number2)

3、檢視呼叫。

class testview(apiview):

authentication_classes = 
def post(self, request, *args, **kwargs):
"""add function"""
number1=1
number2=2
my_task.delay(number1, number2)
return response()

c:\users\administrator\desktop\aimilling>celery -a aimilling worker -l info --pool=solo

post

celery實測之定時任務

新建乙個tasks檔案，裡面 如下 coding utf 8 import requests from celery import celery ip def setup periodic tasks sender,kwargs 每5秒鐘就呼叫一次test方法 sender.add periodic...

django中使用celery 一

建立django專案celery demo,建立應用demo 在celery demo模組中建立celery.py模組,檔案目錄為 celery.py模組內容為 from celery import celery from django.conf import settings import os ...

django和celery結合應用

django celery專案結構 project name init py admin.py views.py modes.py tasks.py celery用來執行任務的檔案，task裡的任務由views函式裡去觸發 urls.py views.py project name init py ...