在 DS 2.0 时代，掌握 API 操作的正确姿势，解锁数据调度的新境界！

2024-01-07 03:10:47

背景

众目期待的 Apache Dolphinscheduler 2.0 版本终于在 2021 年 12 月 17 日发布了。作为一款分布式任务调度平台，DS 2.0 凭借其强大的功能和出色的性能，赢得了广大用户的青睐。在 DS 2.0 时代，掌握 API 操作的正确姿势，可以帮助您解锁数据调度的新境界。

DS 2.0 API 操作优势

DS 2.0 提供了丰富的 API 接口，涵盖了任务管理、工作流编排、自动化运维等各个方面。通过使用这些 API 接口，您可以轻松实现以下操作：

创建、编辑和删除任务
启动、暂停和停止任务
查询任务状态
创建、编辑和删除工作流
启动、暂停和停止工作流
查询工作流状态
创建、编辑和删除调度器
启动、暂停和停止调度器
查询调度器状态

DS 2.0 API 操作教程

以下我们将通过一个简单的示例，来演示如何使用 DS 2.0 的 API 接口来创建和启动一个任务。

import requests

# 设置 API 请求头
headers = {'Content-Type': 'application/json'}

# 创建任务的 JSON 数据
task_data = {
    'name': 'test_task',
    'task_type': 'SHELL',
    'command': 'echo Hello, World!'
}

# 发送创建任务的 POST 请求
response = requests.post('http://localhost:12345/api/v1/tasks', headers=headers, json=task_data)

# 检查创建任务是否成功
if response.status_code == 200:
    print('Task created successfully.')
    task_id = response.json()['id']
else:
    print('Failed to create task.')

# 启动任务
response = requests.post(f'http://localhost:12345/api/v1/tasks/{task_id}/start', headers=headers)

# 检查启动任务是否成功
if response.status_code == 200:
    print('Task started successfully.')
else:
    print('Failed to start task.')