python迴圈排程kettle作業

2021-10-14 11:10:50 字數 928 閱讀 3446

需求:當前job只能一次跑一天程式,想著用python寫個迴圈,然後一次性跑乙個月的資料。

原理是python呼叫cmd

cmd = 'kitchen.bat -rep=kettle_repo -user=admin -pass=admin -dir=/job -job=material_inventory "-param:t_date=\'2018-01-01\'" -level=error' 

os.system(cmd)

rep為資源庫

dir為目錄

job為任務名

param為引數

由於這個job每次只能跑一天的資料,一次次的輸引數很麻煩,所以這裡用python寫個時間迴圈,來呼叫kettle.

整體**如下

import os, datetime

import pandas as pd

start = '2018-11-01'

end = (datetime.datetime.now()-datetime.timedelta(days=1)).strftime('%y-%m-%d')

date_start = datetime.datetime.strptime(start, '%y-%m-%d')

date_end = datetime.datetime.strptime(end, '%y-%m-%d')

for i in pd.date_range(datestart, dateend):

cmd = 'kitchen.bat -rep=yao -user=admin -pass=admin -dir=/job -job=material_inventory "-param:t_date=\'%s\'" -level=error' % (i)

os.system(cmd)

模擬迴圈排程 佇列

include include define len 100005 現有名稱為namei且處理時間為timei的n個任務按照順序排成一列,cpu通過迴圈排程法逐一處理這些任務,每個任務最多處理q ms 這個時間稱為時間片 如果q ms之後任務尚未處理完畢,那麼該任務 將被移動至隊伍最末尾,cpu隨即...

磁碟排程 迴圈掃瞄(CSCAN)

scan演算法既能獲得較好的尋道效能,又能防止飢餓現象。但是存在這樣的問題 當磁頭剛從裡向外移動而超越了某一磁軌時,恰好又有一程序請求訪問此磁軌,這時該程序必須等待。將磁頭繼續從裡向外,然後再從外向裡掃瞄完處於外面的所有要訪問的磁軌後,才處理該程序的請求,致使該請求的請求被大大的推遲。為此,csca...

python任務排程

coding utf 8 import sched import time 初始化sched模組的scheduler類 第乙個引數是乙個可以返回時間戳的函式,第二個引數可以在定時未到達之前阻塞。s sched.scheduler time.time,time.sleep enter四個引數分別為 間...