取消
顯示的結果
而不是尋找
你的意思是:

{{start_time}}不準確和不表現在邏輯上多任務工作

assapin
新的因素

我試圖運行一個增量數據處理工作使用python。

工作計劃如每小時運行。

為我的代碼知道數據增量的過程,我將它與{{start_time}}的命令行

[" end_date = {{start_time}} ")

我注意到兩件事:

* start_time似乎是指當調度器醒來時,與時要醒來。例如,而不是通過準確的整點時間,它可以包含2 - 3秒的小時。

*當我運行工作的兩個任務運行一個接一個,他們每個人都得到不同的{{start_time}}的值。由於調度的工作水平和任務級別,和你有一個特性注入時間的工作,我看不出有什麼不同的值傳遞給每個任務。

每一個這些行為讓{{start_time}}不夠可靠的處理時間窗口的數據。

其他標準調度器氣流和完善做的通過正確的“計劃工作觸發時間”工作,和足夠可靠的處理時間窗口。

看到在這裏在這裏

你能分享注射的最佳實踐是什麼計劃的觸發時間可靠地工作和它的所有任務嗎?

謝謝

0回答0
歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map