1. 程式人生 > >Python Django Celery 實現非同步任務(二)使用rabbitmq 作為broker

Python Django Celery 實現非同步任務(二)使用rabbitmq 作為broker

之前在上一篇文章中Python Celery 實現非同步任務是使用Django預設作為borker (訊息分發),因為升級最新的celery後,不再支援Django作為borker ,所以測試平臺更換為rabbitmq 。以下簡單介紹下更換的方法,其實很簡單。

在django 專案下,把全域性的settings.py 中修改以下程式碼

 # 使用rabbitmq 作為任務代理 (broker)
BROKER_URL = "amqp://" 

# 預設是以本機的mq服務作為broker。如果你需要配置成遠端的mq,請填寫完整的
BROKER_URL = amqp://userid:password@hostname:port/virtual_host

rabbitmq 的安裝方法,網上有很多,請Google後安裝,並且啟動mq 服務。

結構圖

這裡寫圖片描述

celey 結構

這裡寫圖片描述