登录接口

调用示例:

curl -k -X POST --data "action=login&username=azkaban&password=azkaban" https://localhost:8443

注意：文中请求均以curl命令形式展现，最后的url是请求的url，-X POST代表POST方式请求，--data或-d代表POST请求的BODY体

{"status" : "success","session.id" : "c001aba5-a90f-4daf-8f11-62330d034c0a"
}

输出示例:

取到session.id后，后续请求需该参数保持登录状态。

获取projectid及flow列表

curl -k --get --data "session.id=6c96e7d8-4df5-470d-88fe-259392c09eea&ajax=fetchprojectflows&project=azkaban-test-project" https://localhost:8443/manager

输出示例:

{"project" : "test-azkaban","projectId" : 192,"flows" : [ {"flowId" : "test"}, {"flowId" : "test2"} ]
}

获取某个project下flow的schedule执行计划

curl -k --get --data "session.id=XXXXXXXXXXXXXX&ajax=fetchSchedule&projectId=1&flowId=test" http://localhost:8081/schedule

输出示例:

{"schedule" : {"cronExpression" : "0 * 9 ? * *","nextExecTime" : "2017-04-01 09:00:00","period" : "null","submitUser" : "azkaban","executionOptions" : {"notifyOnFirstFailure" : false,"notifyOnLastFailure" : false,"failureEmails" : [ ],"successEmails" : [ ],"pipelineLevel" : null,"queueLevel" : 0,"concurrentOption" : "skip","mailCreator" : "default","memoryCheck" : true,"flowParameters" : {},"failureAction" : "FINISH_CURRENTLY_RUNNING","failureEmailsOverridden" : false,"successEmailsOverridden" : false,"pipelineExecutionId" : null,"disabledJobs" : [ ]},"scheduleId" : "3","firstSchedTime" : "2017-03-31 11:45:21"}
}

修改执行时间

curl -k -d ajax=scheduleCronFlow -d projectName=wtwt -d flow=azkaban-training --data-urlencode cronExpression="0 23/30 5,7-10 ? * 6#3" -b "azkaban.browser.session.id=XXXXXXXXXXXXXX" http://localhost:8081/schedule

输出示例：

{"message" : "PROJECT_NAME.FLOW_NAME scheduled.","scheduleId" : SCHEDULE_ID,"status" : "success"
}

列表执行历史

curl -k --get --data "session.id=6c96e7d8-4df5-470d-88fe-259392c09eea&ajax=fetchFlowExecutions&project=azkaban-test-project&flow=test&start=0&length=3" https://localhost:8443/manager

start 开始位置

length 长度

输出示例：

{"total" : 2,"executions" : [ {"submitTime" : 1562914409512,"submitUser" : "azkaban","startTime" : 1562914409540,"endTime" : 1562914409571,"flowId" : "command","projectId" : 9,"execId" : 48,"status" : "SUCCEEDED"}, {"submitTime" : 1562913985555,"submitUser" : "azkaban","startTime" : 1562913985583,"endTime" : 1562913985652,"flowId" : "command","projectId" : 9,"execId" : 47,"status" : "SUCCEEDED"} ],"length" : 3,"project" : "whqtest","from" : 0,"projectId" : 9,"flow" : "command"
}

执行flow

curl -k --get --data 'session.id=189b956b-f39f-421e-9a95-e3117e7543c9' --data 'ajax=executeFlow' --data 'project=azkaban-test-project' --data 'flow=test' https://localhost:8443/executor

返回值

{ message: "Execution submitted successfully with exec id 295", project: "foo-demo", flow: "test", execid: 295 }

删除执行计划

curl -k https://HOST:PORT/schedule -d "action=removeSched&scheduleId=SCHEDULE_ID" -b azkaban.browser.session.id=SESSION_ID

返回值

{ "message" : "PROJECT_NAME.FLOW_NAME scheduled.", "scheduleId" : SCHEDULE_ID, "status" : "success" }

Azkaban WebApi 调用相关推荐

.NET WebApi调用微信接口Https请求工具类
.NET WebApi调用微信接口Https请求工具类 using System; using System.Collections.Generic; using System.IO; using S ...
Dynamics 365 CRM (online) 使用WebApi调用全局action（Plugin)执行批量更新操作，前端JS批量上传记录到CRM中
创建一个action process,如下图,分别有两个inputparameter 和一个outputparameter 2.使用visual studio 2019编写一个plugin dll, ...
Kettle【实践 01】Linux环境下使用Azkaban定时调用Kettle的KJB或KTR脚本实现自动化数据处理（完整流程实例分享:包含sql+ktr+shell+flow相关文件云资源）
资源链接在文章末尾,包含文件: 1. 说明 Kettle 的 KJB 或 KTR 调用使用的 shell 脚本,小伙伴可能会想,可以用 Linux 的 crontab 进行任务的调度啊,为什么需要 A ...
前端 JS/TS 调用 ASP.NET Core gRPC-Web
前言在上两篇文章中,介绍了ASP.NET Core 中的 gRPC-Web 实现和在 Blazor WebAssembly 中使用 gRPC-Web,实现了 Blazor WebAssembly ...
ASP.NET WebAPI 中的参数绑定
当 WebAPI 调用 Controller 上的方法时, 必须为其参数赋值, 这个过程就是参数绑定. 本文介绍 WebAPI 如何绑定参数, 以及如何进行自定义. WebAPI 默认使用下面的规则进 ...
消费和部署ASP.NET WebApi服务–陷阱
我相信您已经开始使用WebApi.如果不是这样,那么当您开始时,这篇文章仍然可以为您提供帮助. 这篇文章重点介绍我在使用ASP.NET WebApi开发时遇到的一些问题以及解决这些问题的解决方案. 陷 ...
ASP.NET Web API 入门（API接口、寄宿方式、HttpClient调用）
一.ASP.NET Web API接口定义 ASP.NET Web API默认实现了Action方法和HTTP方法的映射,Action方法方法名体现了其能处理的请求必须采用的HTTP方法二.寄宿方式 ...
Android制作AAR包并混淆后加载调用
学更好的别人, 做更好的自己. --<微卡智享> 本文长度为4389字,预计阅读12分钟前言最近准备做新版本产品研发,部分相关算法原来用的Webapi调用返回,考虑到速度问题,需要在A ...
百度地图WebAPI
百度地图WebAPI 调用百度地图WebAPI实现如下周边配套效果可以点这里查看效果首先要去百度地图开放平台申请为百度开发者,然后得到服务秘钥(ak) WEB服务API: http://lb ...

Azkaban WebApi 调用

登录接口

获取projectid及flow列表

获取某个project下flow的schedule执行计划

修改执行时间

列表执行历史

执行flow

删除执行计划

Azkaban WebApi 调用相关推荐

最新文章

热门文章