问题:azkaban通过接口创建定时任务时如何传递参数?
解决:使用flowOverride参数
方法:
params = {
'session.id': session_id,
'ajax': 'scheduleCronFlow',
'projectName': 'myProject',
'flow': 'myProject',
'flowOverride[dt]': '',
'cronExpression': cron
}
res = requests.post('%s/schedule' % SCHEDULE_HOST, params=params)
注:需要使用post,但接口的参数是query params,传参时并不是flowParameters,而是flowOverride,dt就是要传的参数,如果多个,就多增加参数,如'flowOverride[type]': '1',