数据湖工厂 DLF
数据湖工厂 DLF
- 最新动态
- 产品介绍
-
用户指南
- 环境准备
- IAM权限管理
- 数据管理
- 数据集成
- 数据开发
- 解决方案
- 运维调度
- 配置管理
- 配置
- 使用教程
-
参考
-
节点
- 节点概述
- CDM Job
- DIS Stream
- DIS Dump
- DIS Client
- Rest Client
- Import GES
- MRS Kafka
- Kafka Client
- CS Job
- DLI SQL
- DLI Spark
- DWS SQL
- MRS SparkSQL
- MRS Hive SQL
- MRS Presto SQL
- MRS Spark
- MRS Spark Python
- MRS Flink Job
- MRS MapReduce
- CSS
- Shell
- RDS SQL
- ETL Job
- OCR
- Create OBS
- Delete OBS
- OBS Manager
- Open/Close Resource
- Data Quality Monitor
- Sub Job
- SMN
- Dummy
- For Each
- 表达式
-
节点
- 修订记录
- API参考
- 常见问题
- 产品术语
- 通用参考
链接复制成功!
快速入门
本节通过调用API来执行作业,流程如下:
- 调用Token认证获取用户的Token,因为在后续的请求中需要将Token放到请求消息头中作为认证。
- 执行作业。
操作步骤
假设已获取前提条件中的信息为如下值:
- IAM的Endpoint:下面示例中以iam_endpoint代替。
- 数据开发模块的Endpoint:下面示例中以dlf_endpoint代替。
- 项目编号projectId:下面示例中以project_id代替。
则可以通过如下步骤创建一个应用。
- 调用Token认证其他接口前,需要获取Token,并设置成环境变量。
curl -H "Content-Type:application/json" https://{iam_endpoint}/v3/auth/tokens -X POST -d '{ "auth": { "identity": { "methods": [ "password" ], "password": { "user": { "name": "testname", "domain": { "name": "testname" }, "password": "Passw0rd" } } }, "scope": { "project": { "name": "ap-southeast-1" } } } }' -v -k
响应Header中“X-Subject-Token”的值即为Token:
X-Subject-Token:MIIDkgYJKoZIhvcNAQcCoIIDgzCCA38CAQExDTALBglghkgBZQMEAgEwgXXXXX...
使用如下命令将Token设置为环境变量,方便后续事项。
export Token={X-Subject-Token}
X-Subject-Token即为上一步骤获取到的Token,如下所示。
export X-Auth-Token=MIIDkgYJKoZIhvcNAQcCoIIDgzCCA38CAQExDTALBglghkgBZQMEAgEwgXXXXX...
- 调用执行作业。
curl -H "Content-Type:application/json" https://{dlf_endpoint}/v1.0/{project_id}/pipelines/run-pipeline -X POST -d ' { "pipelineId": "b9636fa3-048f-495e-a33f-74b2744801ec" }
如果返回状态码为200,则说明执行作业命令执行成功。