python非同步任務處理框架 celery

2021-10-05 09:26:41 字數 988 閱讀 2108

celery 是一款非常簡單、靈活、可靠的分布式系統,可用於處理大量訊息,並且提供了一整套操作此系統的一系列工具,同時celery 是一款訊息佇列工具,可用於處理實時資料以及任務排程。

比方說現在站點註冊需要在使用者註冊完成後傳送啟用郵件給使用者,而後台傳送郵件時間需要一定時間,而又不能同步等待郵件傳送完成再響應頁面,這樣使用者體驗非常不好,這個時候我們就需要乙個非同步框架(celery)來幫我們完成這些任務。

broker_url =

'redis:'

celery_result_backend =

'redis:'

celery_timezone =

'asia/shanghai'

# 匯入指定的任務模組

celery_imports=

關於更多的配置引數請參考celery配置引數以及celery的configuration.

from celery import celery

"demo"

)# 可以從配置物件中進行載入配置。

)

def

send_mail()

:print

("傳送郵件中****************************"

)return

"郵件傳送成功"

再開啟python console介面操作如下:

>>

>

>>

>send_mail.name

>>

> result=send_mail.delay(

)>>

> result.ready(

)true

>>

> result.get(

)'郵件傳送成功'

非同步處理任務框架

非同步處理任務框架 非同步獲取頭像 第三個引數就是非同步任務執行完畢後的返回值 author administrator public class loadimageasyntask extends asynctask public inte ce loadimageasyntaskcallback...

sidekiq 非同步處理任務

1.安裝 gem install sidekiq或者在gemfile檔案中新增 gem sidekiq gem slim 1.3.0 gem sinatra 1.3.0 require nil2.掛載mount 可以讓你監控專案執行狀態 require sidekiq web mount sidek...

php swoole 非同步處理任務例子

安裝swoole cd swoole 進入 swoole 目錄 phpize configure with php config usr local php bin php config 注意檢視伺服器上是否有這個路徑 make make install修改php.in檔案vi usr local ...