DEV Community
·
使用DolphinScheduler API实现高效的批量工作流导入和脚本部署
内容提要
本文介绍了如何通过DolphinScheduler的API实现任务批量导入和自动部署，包括创建token、构建请求头、导入任务文件、获取工作流列表和调度ID，最终实现在线部署，从而提高工作效率。
关键要点
-
通过DolphinScheduler的API实现任务批量导入和自动部署。
-
所有API调用都需要创建token，并在安全中心进行管理。
-
构建请求头时需要包含token。
-
任务导入API的地址为http://IP:12345/dolphinscheduler/projects/{project_id}/process-definition/import。
-
任务导入只支持二进制文件，需从工作流中导出作为参考。
-
使用API获取工作流列表和调度ID以便于后续的工作流部署。
-
工作流列表的API地址为http://IP:12345/dolphinscheduler/projects/{project_id}/process-definition。
-
获取调度ID的API地址为http://36.133.140.132:12345/dolphinscheduler/projects/{project_id}/schedules?pageSize=1000&pageNo=1&processDefinitionCode=。
-
在部署前需过滤掉已上线的调度ID。
-
最终通过API实现在线部署，完成批量任务的导入和自动部署。
延伸问答
如何使用DolphinScheduler的API进行任务批量导入？
可以通过调用任务导入API，使用二进制文件上传任务，API地址为http://IP:12345/dolphinscheduler/projects/{project_id}/process-definition/import。
在使用DolphinScheduler API时，如何创建和管理token？
所有API调用都需要创建token，可以在安全中心的Token管理中创建并管理该token。
如何获取DolphinScheduler中的工作流列表？
可以通过调用工作流列表API，地址为http://IP:12345/dolphinscheduler/projects/{project_id}/process-definition，进行分页查询以获取所有工作流。
如何获取调度ID以便于工作流部署？
可以通过调用调度ID的API，地址为http://36.133.140.132:12345/dolphinscheduler/projects/{project_id}/schedules?pageSize=1000&pageNo=1&processDefinitionCode=，并过滤掉已上线的调度ID。
DolphinScheduler API支持哪些文件格式的任务导入？
任务导入只支持二进制文件，需从工作流中导出作为参考。
如何实现DolphinScheduler的在线部署？
在获取调度ID后，可以通过调用在线部署API，地址为http://36.133.140.132:12345/dolphinscheduler/projects/{project_id}/schedules/{scheduler_id}/online，完成在线部署。
