DataWorks通过那个api可以调度运行任务?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
在阿里云DataWorks中,可以通过RESTful API来调度运行任务。以下是使用RESTful API调度运行任务的步骤:
通过使用RESTful API,可以在程序中自动调度运行任务。以下是使用RESTful API调度运行任务的示例代码:
import requests
import json
# 设置API请求参数
url = 'http://your-dw-api-url/api/v2/executor/task/run'
headers = {'Content-Type': 'application/json'}
body = {
"appName": "your-app-name",
"taskId": "your-task-id"
}
# 发送API请求
response = requests.post(url, headers=headers, data=json.dumps(body))
# 检查API请求结果
if response.status_code == 200:
print("Task run successfully.")
else:
print("Task run failed. Response code: %s, Response message: %s" % (response.status_code, response.text))
其中,url
是API请求的URL,headers
是API请求的头部信息,body
是API请求的主体信息。在body
中,需要设置运行任务的App名称和任务ID。
DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。