使用开放消息和POP接口检查待发布节点DataWorks向用户发送文件发布检查事件?
DataWorks向Kafka发送文件发布检查事件后,Kafka会将其转发至用户的服务,用于后续用户进行审批操作。事件的参数及描述信息格式如下。{"isContentChange": true,"baseId": "","appId": *,"tenantId": *,"cloudUuid": *,"type": ,"fileName": "","owner": "","projectOwner": "","projectName": "","checkerIdentify": "**","checkerInstanceId": "*","changeType": "UPDATE","useType": 0,"fileCreateTime": "2021-01-15 14:03:02","fileId": *,"connName": "","fileVersion": 3}参数描述如下表所示。参数 描述
isContentChange 相较于前一次文件内容是否有变动。取值如下:
baseId 提交节点任务的用户ID。
appId DataWorks工作空间的ID。 您可以调用GetFileVersion获取目标节点本次发布的详细内容,appId、fileId、fileVersion可以作为GetFileVersion接口的入参信息。
tenantId 租户ID。
cloudUuid 调度节点的ID。
type 提交节点的节点类型。
fileName 提交节点的节点名称。
owner 提交节点对应节点责任人的阿里云账号ID。
projectOwner DataWorks工作空间的Owner。
projectName DataWorks工作空间的名称。
checkerIdentify 检查器的唯一标识。
checkerInstanceId 检查器实例的唯一标识。
changeType 提交节点的变更类型。取值如下:
useType 功能模块。例如,数据开发页面的业务流程(0)
https://help.aliyun.com/document_detail/218021.html,此回答整理自钉群“DataWorks交流群(答疑@机器人)”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。