根据DataWorks开放消息的消息ID,查询触发扩展点事件时的扩展点数据快照。
接口说明
前置条件:调用本接口前,请先开通 DataWorks 企业版或旗舰版;未开通时服务会返回 403 Forbidden.Access。
调试
您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。
调试
授权信息
|
操作 |
访问级别 |
资源类型 |
条件关键字 |
关联操作 |
|
dataworks:* |
get |
*全部资源
|
无 | 无 |
请求参数
|
名称 |
类型 |
必填 |
描述 |
示例值 |
| MessageId |
string |
是 |
DataWorks 开放消息的消息 ID。当触发扩展点事件后,您可以从接收到的事件消息中获取消息 ID。 消息格式,可参考消息格式。 |
8abcb91f-d266-4073-b907-2ed67****1 |
| ProjectId |
integer |
是 |
DataWorks 工作空间的 ID,您可以通过解析 DataWorks 开放消息获取空间 ID。 |
10000 |
返回参数
|
名称 |
类型 |
描述 |
示例值 |
|
object |
返回结果。 |
||
| RequestId |
string |
请求的唯一标识,用于后续错误排查使用。 |
8abcb91f-d266-4073-b907-2ed670378ed1 |
| EventDetail |
object |
触发扩展点事件时的数据快照。 不同类型的消息事件,数据快照的有效字段存在差异,具体请参考各消息事件的字段说明。 |
|
| FileExecutionCommand |
object |
文件代码执行时的快照,当 Message 类型为 IDE_FILE_EXECUTE_BEFORE 时有效。 |
|
| FileId |
integer |
文件的 ID。 |
1234123 |
| DataSourceName |
string |
文件关联的数据源唯一标识。 |
odps_source |
| Content |
string |
生成本次文件版本的文件代码。 |
SHOW TABLES; |
| FileType |
integer |
文件类型。不同文件类型其代码不同,详情请参见 DataWorks 节点合集。 |
10 |
| DeletedFile |
object |
删除文件时的快照信息,当 Message 类型为 IDE_FILE_DELETE_BEFORE 时有效。 |
|
| Owner |
string |
文件责任人。 |
7384234**** |
| FileType |
integer |
文件类型。不同文件类型其代码不同,详情请参见 DataWorks 节点合集。 |
10 |
| CurrentVersion |
integer |
当前文件的最新版本。 |
1 |
| BusinessId |
integer |
文件所属的业务流程 ID。 |
74328 |
| FileName |
string |
文件名称。 |
hello_dataworks.sql |
| DataSourceName |
string |
文件关联的数据源唯一标识。 |
odps_source |
| UseType |
string |
文件所属的功能模块。取值如下:
|
NORMAL |
| FolderId |
string |
文件所属的文件夹 ID,您可以调用 GetFolder 接口,通过文件夹 ID 查询文件详情。 |
aldurie78l2falure |
| ParentFileId |
integer |
文件所属的循环节点或遍历节点的节点 ID。 |
1234122 |
| Content |
string |
生成本次文件版本的文件代码。 |
SHOW TABLES; |
| NodeId |
integer |
调度节点的 ID。 |
421429 |
| FileId |
integer |
文件的 ID。 |
1234123 |
| CommittedFile |
object |
文件提交和发布时的快照。 仅当 Message 类型为 IDE_FILE_SUBMIT_BEFORE 或 IDE_FILE_DEPLOY_BEFORE 时有效。 |
|
| FileId |
integer |
文件的 ID。 |
1234123 |
| Content |
string |
生成本次文件版本的文件代码。 |
SHOW TABLES; |
| Committor |
string |
生成本次文件版本的阿里云用户 ID。 |
7384234**** |
| FileType |
integer |
文件类型。不同文件类型其代码不同,详情请参见 DataWorks 节点合集。 |
10 |
| ChangeType |
string |
本次文件版本的变更类型,包括 CREATE、UPDATE 和 DELETE。 |
UPDATE |
| FileName |
string |
文件名称。 |
hello_dataworks.sql |
| NodeId |
integer |
调度节点的 ID。 |
421429 |
| Comment |
string |
本次文件版本的说明。 |
Second version submission |
| UseType |
string |
文件所属的功能模块。取值如下:
|
NORMAL |
| FilePropertyContent |
object |
文件的更多属性。 |
|
| DataSourceName |
string |
文件关联的数据源唯一标识。 |
odps_source |
| ParentFileId |
integer |
文件所属的循环节点或遍历节点的节点 ID。 |
1234122 |
| BusinessId |
integer |
文件所属的业务流程 ID。 |
74328 |
| CurrentVersion |
integer |
当前文件的最新版本。 |
1 |
| Owner |
string |
文件责任人。 |
7384234**** |
| FolderId |
string |
文件所属的文件夹 ID,您可以调用 GetFolder 接口,通过文件夹 ID 查询文件详情。 |
aldurie78l2falure |
| NodeConfiguration |
object |
文件的调度属性配置。 |
|
| RerunMode |
string |
重跑属性。取值如下:
该参数与 DataWorks 控制台中,数据开发任务的“调度配置>时间属性>重跑属性”配置内容对应。 |
ALL_ALLOWED |
| SchedulerType |
string |
调度的类型,取值如下:
|
NORMAL |
| ParaValue |
string |
调度参数。 该参数与 DataWorks 控制台中,数据开发任务的“调度配置>参数”对应。您可以参考调度参数配置。 |
a=x b=y |
| CycleType |
string |
调度周期的类型,包括 NOT_DAY(分钟、小时)和 DAY(日、周、月)。 该参数与 DataWorks 控制台中,数据开发任务的“调度配置>时间属性>调度周期”对应。 |
DAY |
| DependentNodeIdList |
string |
当 DependentType 参数配置为 USER_DEFINE 时,用于设置当前文件具体依赖的节点 ID。依赖多个节点时,使用英文逗号(,)分隔。 该参数与 DataWorks 控制台中,数据开发任务的“调度配置>调度依赖>跨周期依赖(原上一周期)”,依赖项选择”其他节点“时配置的内容对应。 |
5,10,15,20 |
| ResourceGroupId |
integer |
文件发布成任务后,任务执行时使用的资源组。您可以调用 ListResourceGroups 获取工作空间可用的资源组列表。 |
375827434852437 |
| AutoRerunTimes |
integer |
自动重跑次数。 |
3 |
| AutoRerunIntervalMillis |
integer |
自动重跑间隔毫秒数。 |
120000 |
| CronExpress |
string |
调度 Cron 表达式。 |
00 05 00 * * ? |
| InputList |
array<object> |
文件依赖的上游文件输出。 |
|
|
object |
依赖的上游文件输出信息。 |
||
| Input |
string |
文件依赖的上游文件的输出名称。 该参数与 DataWorks 控制台中,数据开发任务的“调度配置>调度依赖>依赖上游节点“的”上游节点输出名”对应。 |
dw_project_root |
| ParseType |
string |
配置文件依赖的方式,取值如下:
|
MANUAL |
| OutputList |
array<object> |
文件的输出。 该参数与 DataWorks 控制台中,数据开发任务的“调度配置>调度依赖>本节点输出名称“对应。 |
|
|
object |
文件的输出信息。 |
||
| RefTableName |
string |
文件的输出表名。 该参数与 DataWorks 控制台中,数据开发任务的“调度配置>调度依赖>本节点输出名称“的“输出表名”对应。 |
ods_user_info_d |
| Output |
string |
文件的输出名称。 该参数与 DataWorks 控制台中,数据开发任务的“调度配置>调度依赖>本节点输出名称“的“输出名”对应。 |
dw_project.002_out |
| DependentType |
string |
依赖上一周期的方式。取值如下:
|
USER_DEFINE |
| TableModel |
object |
表提交和发布时的快照,当 Message 类型为 IDE_TABLE_SUBMIT_BEFORE 和 IDE_TABLE_DEPLOY_BEFORE 时有效。 |
|
| Env |
string |
表所属环境。取值如下:
|
DEV |
| LifeCycle |
integer |
表的生命周期。单位为天。 |
7 |
| TableName |
string |
表名称。 |
tb_hello |
| DataSourceName |
string |
表所属数据源的唯一标识。 |
odps_source |
| Columns |
array<object> |
字段列表。 |
|
|
object |
字段信息。 |
||
| ColumnName |
string |
字段名称。 |
ID |
| ColumnType |
string |
字段类型。 |
BIGINT |
| IsPartitionColumn |
boolean |
是否为分区字段,取值如下:
|
false |
| Comment |
string |
字段备注。 |
ID |
| Comment |
string |
表的备注信息。 |
A new table |
| Location |
string |
外部表的 Location 信息。 |
hdfs://path/to/object |
示例
正常返回示例
JSON格式
{
"RequestId": "8abcb91f-d266-4073-b907-2ed670378ed1",
"EventDetail": {
"FileExecutionCommand": {
"FileId": 1234123,
"DataSourceName": "odps_source",
"Content": "SHOW TABLES;",
"FileType": 10
},
"DeletedFile": {
"Owner": "7384234****",
"FileType": 10,
"CurrentVersion": 1,
"BusinessId": 74328,
"FileName": "hello_dataworks.sql",
"DataSourceName": "odps_source",
"UseType": "NORMAL",
"FolderId": "aldurie78l2falure",
"ParentFileId": 1234122,
"Content": "SHOW TABLES;",
"NodeId": 421429,
"FileId": 1234123
},
"CommittedFile": {
"FileId": 1234123,
"Content": "SHOW TABLES;",
"Committor": "7384234****",
"FileType": 10,
"ChangeType": "UPDATE",
"FileName": "hello_dataworks.sql",
"NodeId": 421429,
"Comment": "Second version submission",
"UseType": "NORMAL",
"FilePropertyContent": {
"DataSourceName": "odps_source",
"ParentFileId": 1234122,
"BusinessId": 74328,
"CurrentVersion": 1,
"Owner": "7384234****",
"FolderId": "aldurie78l2falure"
},
"NodeConfiguration": {
"RerunMode": "ALL_ALLOWED",
"SchedulerType": "NORMAL",
"ParaValue": "a=x b=y",
"CycleType": "DAY",
"DependentNodeIdList": "5,10,15,20",
"ResourceGroupId": 375827434852437,
"AutoRerunTimes": 3,
"AutoRerunIntervalMillis": 120000,
"CronExpress": "00 05 00 * * ?",
"InputList": [
{
"Input": "dw_project_root",
"ParseType": "MANUAL"
}
],
"OutputList": [
{
"RefTableName": "ods_user_info_d",
"Output": "dw_project.002_out"
}
],
"DependentType": "USER_DEFINE"
}
},
"TableModel": {
"Env": "DEV",
"LifeCycle": 7,
"TableName": "tb_hello",
"DataSourceName": "odps_source",
"Columns": [
{
"ColumnName": "ID",
"ColumnType": "BIGINT",
"IsPartitionColumn": false,
"Comment": "ID"
}
],
"Comment": "A new table",
"Location": "hdfs://path/to/object"
}
}
}
错误码
|
HTTP status code |
错误码 |
错误信息 |
描述 |
|---|---|---|---|
| 400 | InternalError.UserId.Missing | An internal system error occurred. Try again later. | |
| 500 | InternalError.System | An internal system error occurred. Try again later. | |
| 403 | Forbidden.Access | Access is forbidden. Please first activate DataWorks Enterprise Edition or Flagship Edition. | 没有权限,请授权 |
| 429 | Throttling.Api | The request for this resource has exceeded your available limit. | |
| 429 | Throttling.System | The DataWorks system is busy. Try again later. | |
| 429 | Throttling.User | Your request is too frequent. Try again later. |
访问错误中心查看更多错误码。
变更历史
更多信息,参考变更详情。