當前位置:首頁 » 編程語言 » python任務

python任務

發布時間: 2023-04-15 12:24:54

A. python 非同步任務隊列Celery 使用

在 Python 中定義 Celery 的時候,我們要引入 Broker,中文翻譯過來就是「中間人」的意思。在工頭(生產者)提出任務的時候,把所有的任務放到 Broker 裡面,在 Broker 的另外一頭,一群碼農(消費者)等著取出一個個任務准備著手做。這種模式註定了整個系統會是個開環系統,工頭對於碼農們把任務做的怎樣是不知情的。所以我們要引入 Backend 來保存每次任務的結果。這個 Backend 也是存儲任務的信息用的,只不過這里存的是那些任務的返回結果。我們可以選擇只讓錯誤執行的任務返回結果到 Backend,這樣我們取回結果,便可以知道有多少任務執行失敗了。

其實現架構如下圖所示:

可以看到,Celery 主要包含以下幾個模塊:

celery可以通過pip自動安裝。

broker 可選擇使用RabbitMQ/redis,backend可選擇使用RabbitMQ/redis/MongoDB。RabbitMQ/redis/mongoDB的安裝請參考對應的官方文檔。

------------------------------rabbitmq相關----------------------------------------------------------

官網安裝方法: http://www.rabbitmq.com/install-windows.html

啟動管理插件:sbin/rabbitmq-plugins enable rabbitmq_management 啟動rabbitmq:sbin/rabbitmq-server -detached

rabbitmq已經啟動,可以打開頁面來看看 地址: http://localhost:15672/#/

用戶名密碼都是guest 。進入可以看到具體頁面。 關於rabbitmq的配置,網上很多 自己去搜以下就ok了。

------------------------------rabbitmq相關--------------------------------------------------------

項目結構如下:

使用前,需要三個方面:celery配置,celery實例,需執行的任務函數,如下:

Celery 的配置比較多,可以在 官方配置文檔: http://docs.celeryproject.org/en/latest/userguide/configuration.html 查詢每個配置項的含義。

當然,要保證上述非同步任務and下述定時任務都能正常執行,就需要先啟動celery worker,啟動命令行如下:

啟動beat ,執行定時任務時, Celery會通過celery beat進程來完成。Celery beat會保持運行, 一旦到了某一定時任務需要執行時, Celery beat便將其加入到queue中. 不像worker進程, Celery beat只需要一個即可。而且為了避免有重復的任務被發送出去,所以Celery beat僅能有一個。

命令行啟動:

如果你想將celery worker/beat要放到後台運行,推薦可以扔給supervisor。

supervisor.conf如下:

B. 如何使用python調用命令創建任務計劃

import os
file_path="C:\\Users\\zc\\Desktop\\python\\start.bat"
cmd='schtasks /create /tn "compress_upload" /tr %s /sc daily /st 16:00:00'%file_path
os.popen(cmd)

C. python查看timer定時任務已開啟

python查看timer定時任務已開啟 的操作方法:Timer定時任務

下面仔賀冊是Timer函數的官方doc介紹信息
"""
Call a function after a specified number of seconds:
t = Timer(30.0, f, args=None, kwargs=None)
t.start()
t.cancel() # stop the timer's action if it's still waiting
"""
第一個參念宏數時指定多長時間之後執行這個函數,第二個參數時調用的函數名,
後面兩個是可選函數,作為傳遞函數需要使用的參數,可以傳遞普拍陵通的參數和字典
t.start() 啟動這個定時任務,也可以使用t.cancel()在一定的條件來停止這個定時任務,
下面這行代碼表示十秒鍾後調用一次views_count這個函數
Timer(10, views_count).start()

D. 請教一個Python任務:復制部分文件並刪除

思路:1.利用os.listdir()獲得mainfolder文件夾中的所有文件夾的名稱
2.建立一個計數count<=0循環,在每個文件夾中先移動後刪除
提示:模塊為os.shutil模塊

E. python動態添加刪除定時任務

可以基於tornado-APScheler實現添加動態添加/刪除/暫停/清除定時任務。
安裝:pip3 install apsheler
1.任何調度器在開始後,不能再次start。不然會出現異常
2.shutdown方法:終結掉對應的調度器,所以代碼邏輯里需要檢測一下. running方法可以判斷調度器的運行狀態,如果需要設計delete方法清除某個任務,建議用remove方法,對應代碼邏輯需要注意start()不要重復
3.注意BlockingScheler,如果你想動態添加任務的話,這個調度器是阻塞的,所以每個任務必須是一個守護線程,個人感覺不太方便,建議用其他非阻塞的
4. get_jobs()方法很有用,如果我們加上dir,配合這個方法可以很靈活地配置
5.修改一個周期任務,需要用modify_job方法,根據你的job_id修改
Python由荷蘭數學和計算機科學研究學會的Guido van Rossum 於1990 年代初設計,作為一門叫做ABC語言的替代品。 Python提供了高效的高級數據結構,還能簡單有效地面向對象編程。Python語法和動態類型,以及解釋型語言的本質,使它成為多數平台上寫腳本和快速開發應用的編程語言,隨著版本的不斷更新和語言新功能的添加,逐漸被用於獨立的、大型項目的開發。

F. python實現定時任務

缺點:不容易控制,而且是個阻塞函數

優點:可以管理和調度多個任務,可以進行控制
缺點:阻塞式函數

優點:非阻塞
缺點:不易管理多個任務

sched模塊實現了一個時間調度程序,該程序可以通過單線程執行來處理按照時間尺度進行調度的時間。
通過調用 scheler.enter(delay,priority,func,args) 函數,可以將一個任務添加到任務隊列裡面,當指定的時間到了,就會執行任務( func函數 )。

執行結果為:

按順序執行任務:

執行結果為:

s.run()會阻塞當前線程的執行
可以用

也可以用 s.cancal(action) 來取消sched中的某個action

運行結果為:

運行結果為:

運行結果:

celery框架後續更新

G. python能做什麼工作

現在互聯網發展迅速,眾多行業巨頭,都已經轉投到人工智慧領域,而人工智慧的首選編程語言就是python,所以學好Python能夠從事的工作還是很多的,而且前景非常不錯。

學完python可以應用於以下領域:

①Web 和 Internet開發

②科學計算和統計

③人工智慧

④桌面界面開發

⑤軟體開發

⑥後端開發

⑦網路爬蟲

可以從事的崗位也很多,比如Python爬蟲工程師,大數據工程師等等!

互聯網行業目前還是最熱門的行業之一,學習IT技能之後足夠優秀是有機會進入騰訊、阿里、網易等互聯網大廠高薪就業的,發展前景非常好,普通人也可以學習。

想要系統學習,你可以考察對比一下開設有相關專業的熱門學校,好的學校擁有根據當下企業需求自主研發課程的能力,建議實地考察對比一下。

祝你學有所成,望採納。

熱點內容
安卓和蘋果哪個最保值 發布:2024-11-02 02:30:02 瀏覽:603
橋接的網關伺服器地址怎麼查 發布:2024-11-02 02:29:11 瀏覽:861
電腦里dns伺服器未響應咋辦 發布:2024-11-02 02:28:24 瀏覽:543
星與雲伺服器 發布:2024-11-02 02:27:49 瀏覽:205
centos升級python27 發布:2024-11-02 02:00:57 瀏覽:673
ue4未找到編譯器 發布:2024-11-02 01:46:08 瀏覽:155
python中的withopen 發布:2024-11-02 01:46:07 瀏覽:976
編程名人 發布:2024-11-02 01:42:18 瀏覽:867
伺服器電腦配置表 發布:2024-11-02 01:41:29 瀏覽:370
linux使用串口 發布:2024-11-02 01:37:11 瀏覽:702