azkaban通过接口创建定时任务

本文共有524个字,关键词:

问题: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',

版权声明:本文为作者原创,如需转载须联系作者本人同意,未经作者本人同意不得擅自转载。
添加新评论
暂无评论