DataWorks:Appendix: Message formats

Precautions

You can view the content of core messages sent by DataWorks by referring to the message bodies. A message sent by EventBridge consists of a message body and other content. For more information about a complete message sent by EventBridge, see Appendix 1: Formats of event messages sent to EventBridge.

Event types

Message body for a status change event for an auto triggered node

Sample code of the message body for a status change event for an auto triggered node:

{
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "beginWaitTimeTime": 1652700576000,
    "dagId": 446555330,
    "dagType": 0,
    "taskType": 0,
    "modifyTime": 1652700577000,
    "createTime": 1652543233000,
    "appId": 3*****2,
    "tenantId": 235454***432001,
    "opCode": 31,
    "flowId": 1,
    "nodeId": 1002698219,
    "beginWaitResTime": 1652700577000,
    "taskId": 4532688169,
    "status": 3
}
  }

The following table describes the key fields in the preceding sample code.

Message body for an instance operation event (freeze, unfreeze, terminate, rerun, and set the instance status to Succeeded)

{
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "operator": "182293110403****",
    "projectId": 123488,
    "projectType": "PROD",
    "taskIds":
    [
        523536569736
    ],
    "tenantId": 280749521950784
}

Message body for a file change event (commit, deploy, execute, delete, and review code)

• Sample code of the message body for a file commit or deployment event:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "operator": "**************",  // The operator.
      "projectId": 12*****56,
      "tenantId": 12*****56,
      "nodeId": 123456,    // The node ID.
      "fileType": 123456, // The type of the file.
      "fileName": "********",
      "fileOwner": "****************",         // The owner of the file.
      "extensionBizId": "***************",    //
      "changeType": "UPDATE", //NEW UPDATE DELETE
      "fileCreateTime": "2021-01-15 14:03:02",
      "fileId": 123456,
      "fileVersion": 3,
      "dataSourceName":"odps_source"
    }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  operator	String	The UID of the user who commits or deploys the file.
  projectId	Long	The ID of the workspace to which the file belongs.
  tenantId	Long	The tenant ID.
  nodeId	Long	The ID of the auto triggered node.
  fileType	Long	The code type of the file. Valid values: 6 (Shell) 10 (ODPS SQL) 11 (ODPS MR) 23 (Data Integration) 24 (ODPS Script) 99 (zero load) 221 (PyODPS 2) 225 (ODPS Spark) 227 (EMR Hive) 228 (EMR Spark) 229 (EMR Spark SQL) 230 (EMR MR) 239 (OSS object inspection) 257 (EMR Shell) 258 (EMR Spark Shell) 259 (EMR Presto) 260 (EMR Impala) 900 (real-time synchronization) 1089 (cross-tenant collaboration) 1091 (Hologres development) 1093 (Hologres SQL) 1100 (assignment) 1221 (PyODPS 3)
  fileName	String	The name of the file.
  fileOwner	String	The owner of the file.
  extensionBizId	String	The ID of the check process in an extension.
  changeType	String	The type of the change to the file. Valid values: UPDATE: updates the file. DELETE: deletes the file. CREATE: creates the file.
  fileCreateTime	String	The time when the file was created. The time is in the yyyy-MM-dd HH:mm:ss format.
  fileId	Long	The ID of the file.
  fileVersion	Long	The version of the file.
  dataSourceName	String	The name of the data source.

• Sample code of the message body for a file deletion or execution event:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "operator": "**************",  // The operator.
      "projectId": 123456,
      "tenantId": 123456,
      "nodeId": 123456,    // The node ID.
      "fileType": 123456, // The type of the file.
      "fileName": "********",
      "fileOwner": "****************",         // The owner of the file.
      "extensionBizId": "***************",    //
      "fileCreateTime": "2021-01-15 14:03:02",
      "fileId": 123456
    }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  operator	String	The UID of the user who deletes or runs the file.
  projectId	Long	The ID of the workspace to which the file belongs.
  tenantId	Long	The tenant ID.
  nodeId	Long	The ID of the auto triggered node.
  fileType	Long	The code type of the file. Valid values: 6 (Shell) 10 (ODPS SQL) 11 (ODPS MR) 23 (Data Integration) 24 (ODPS Script) 99 (zero load) 221 (PyODPS 2) 225 (ODPS Spark) 227 (EMR Hive) 228 (EMR Spark) 229 (EMR Spark SQL) 230 (EMR MR) 239 (OSS object inspection) 257 (EMR Shell) 258 (EMR Spark Shell) 259 (EMR Presto) 260 (EMR Impala) 900 (real-time synchronization) 1089 (cross-tenant collaboration) 1091 (Hologres development) 1093 (Hologres SQL) 1100 (assignment) 1221 (PyODPS 3)
  fileName	String	The name of the file.
  fileOwner	String	The owner of the file.
  extensionBizId	String	The ID of the check process in an extension.
  fileCreateTime	String	The time when the file was created. The time is in the yyyy-MM-dd HH:mm:ss format.
  fileId	Long	The ID of the file.

• Sample code of the message body for a code review event:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data":{
      "id":111,
      "tenantId" : The tenant ID,
      "projectId" : The workspace ID,
      "status": "Reviewing",
      "resourceName": "The review file",
      "resourceType": "The review type",
      "resourceId": "50***9789",
      "submitTime": 1688697808000,
      "lastReviewTime": 1688697808000,
      "reviewUrl" : "The review URL",
      "reviewer": "The reviewer",
      "submitter": "The submitter",
  }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  id	Long	The ID of the code review ticket.
  tenantId	Long	The tenant ID.
  projectId	Long	The ID of the workspace.
  status	String	The status of the code review ticket. Valid values: Initialized Reviewing Accepted Rejected Canceled AutomaticCanceled
  resourceName	String	The name of the reviewed resource.
  resourceType	String	The type of the reviewed resource. Valid values: Business File BatchFiles
  resourceId	String	The ID of the reviewed resource.
  submitTime	Long	The time when the code was committed for review.
  lastReviewTime	Long	The time when the code review ticket was most recently viewed.
  reviewUrl	String	The URL for the code review.
  reviewer	String	The approver of the code review.
  submitter	String	The initiator of the code review.

Message body for a table change event (commit a table to the development environment and deploy a table to the production environment)

Sample code of the message body for a table change event:

{
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "operator": "**************",
    "projectId": 12*****56,
    "tenantId": 12******56,
    "extensionBizId": "123456",
    "tableName":"table1",
    "tableType":"ODPS",  // The type of the table. Valid values: ODPS and EMR.
    "maxComputeProject":"project1"
  }

The following table describes the fields in the preceding sample code.

Message body for a node change event (create, modify, delete, freeze, unfreeze, and undeploy)

• Sample code of the message body for a node creation, modification, or deletion event:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "nodeName": "",
      "programType": "ODPS_SQL",
      "cronExpress": "00 20 00 * * ?",
      "schedulerType": "NORMAL",
      "ownerId": "1912232488744735",
      "priority": 1,
      "baselineId": 117801853,
      "repeatability": true,
      "modifyTime": 1646364549642,
      "createTime": 1646364549642,
      "datasource": "odps_source",
      "tenantId": 28378****10656,
      "nodeId": 100***150,
      "projectId": 30**95,
      "operator": "**************"  // The operator.
    }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  nodeName	String	The name of the node.
  programType	String	The code type of the file. Valid values: 6 (Shell) 10 (ODPS SQL) 11 (ODPS MR) 24 (ODPS Script) 99 (zero load) 221 (PyODPS 2) 225 (ODPS Spark) 227 (EMR Hive) 228 (EMR Spark) 229 (EMR Spark SQL) 230 (EMR MR) 239 (OSS object inspection) 257 (EMR Shell) 258 (EMR Spark Shell) 259 (EMR Presto) 260 (EMR Impala) 900 (real-time synchronization) 1089 (cross-tenant collaboration) 1091 (Hologres development) 1093 (Hologres SQL) 1100 (assignment) 1221 (PyODPS 3) You can call the ListFileType operation to query the code type of a file.
  cronExpress	String	The CRON expression that represents the periodic scheduling policy of the node. This parameter is equivalent to the Cron Expression parameter in the Schedule section of the tab on the DataStudio page in the DataWorks console. After you configure the Scheduling Cycle and Run At parameters in the DataWorks console, DataWorks automatically generates the value of the Cron Expression parameter. Examples: CRON expression for a node that is scheduled to run at 05:30 every day: 00 30 05 * * ? CRON expression for a node that is scheduled to run at the fifteenth minute of each hour: 00 15 * * * ? CRON expression for a node that is scheduled to run every 10 minutes: 00 00/10 * * * ? CRON expression for a node that is scheduled to run every 10 minutes from 08:00 to 17:00 every day: 00 00-59/10 8-17 * * * ? CRON expression for a node that is scheduled to run at 00:20 on the first day of each month: 00 20 00 1 * ? CRON expression for a node that is scheduled to run every three months starting from 00:10 on January 1: 00 10 00 1 1-12/3 ? CRON expression for a node that is scheduled to run at 00:05 every Tuesday and Friday: 00 05 00 * * 2,5 Note Limits on CRON expressions: A node can be scheduled to run at a minimum interval of 5 minutes. A node can be scheduled to run at 00:05 every day at the earliest.
  schedulerType	String	The type of the node. Valid values: 0: NORMAL. The node is a normal auto triggered node. The scheduling system regularly runs the node. 1: MANUAL. The node is a manually triggered node. The scheduling system does not regularly run the node. 2: PAUSE. The node is a frozen node. The scheduling system regularly runs the node but sets the node status to Failed when the scheduling system starts to run the node. 3: SKIP. The node is a dry-run node. The scheduling system regularly runs the node but sets the node status to Succeeded when the scheduling system starts to run the node. 4: SKIP_UNCHOOSE. The node is an unselected node in a temporary workflow. This type of node exists only in temporary workflows. The scheduling system sets the node status to Succeeded when the scheduling system starts to run the node. 5: SKIP_CYCLE. The node is a node that is scheduled by week or month and is waiting for the scheduling time to arrive. The scheduling system regularly runs the node but sets the node status to Succeeded when the scheduling system starts to run the node. 6: CONDITION_UNCHOOSE. The node is not selected by its ancestor branch node and is run as a dry-run node. 7: REALTIME_DEPRECATED. The node has instances that are generated in real time but are deprecated. The scheduling system sets the node status to Succeeded.
  ownerId	String	The ID of the Alibaba Cloud account used by the owner of the node. If this field is not configured, the ID of the Alibaba Cloud account of the user who schedules the node is used.
  priority	Integer	The priority of the node. Valid values: 1, 3, 5, 7, and 8. A greater value specifies a higher priority.
  baselineId	Long	The ID of the baseline.
  repeatability	Boolean	Specifies whether the node can be rerun. Valid values: true: The node can be rerun. false: The node cannot be rerun.
  modifyTime	Long	The last time when the node was modified.
  createTime	Long	The time when the node was created.
  nodeId	Long	The ID of the node.
  projectId	Long	The ID of the workspace to which the node belongs.
  tenantId	Long	The ID of the tenant to which the node belongs.
  operator	String	The UID of the user who adds, modifies, or deletes the node.

• Sample code of the message body for a node freezing, unfreezing, or undeployment event:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "operator": "**************",
      "projectId": 123456,
      "tenantId": 123456,
      "nodeIds":[1,2,3],
      "extensionBizId": "123456"
    }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  operator	String	The UID of the user who freezes, unfreezes, or undeploys the node.
  projectId	Long	The ID of the workspace to which the node belongs.
  tenantId	Long	The tenant ID.
  nodeIds	Array	The IDs of the nodes on which you performed the operation.
  extensionBizId	String	The ID of the check process in an extension.

Message body for a data backfill event

Sample code of the message body for a data backfill event:

{
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "excludeNodeIds":[],
    "rootNodeId": 10000838271,
    "startFutureInstanceImmediately": false,
    "useMultipleTimePeriods": true,
    "operator": "1320876710332592",
    "multipleTimePeriods": "[{\"bizBeginTime\":\"2022-04-17\",\"bizEndTime\":\"2022-04-17\"}]",
    "parallelGroup": 1,
    "rootNodeProjectId": 12*****8,
    "isParallel": false,
    "name": "P_fff_20220418_215404",
    "tenantId": 16935*****3377,
    "includeNodeIds":
    [
      10000838271
    ],
    "projectId": 12958,
    "order": "asc",
    "extensionBizId": "123456"
  }

The following table describes the key fields in the preceding sample code.

Message body for an Approval Center event (request task creation and completion, and pre-request for table permissions)

• Sample code of the message body for the event of creating a request processing order:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "appId":194209,
    "assignee":"286098539641742899",
    "assigneeName":"yupeng.sunyp",
    "createTime":1652094363000,
    "eventType":"approval",
    "process":{
      "applicant":"286098539641742899",
      "applicantName":"yupeng.sunyp",
      "approvalContent":{
        "applyPeriod":"2997964800000",
        "applyReason":"test",
        "arrayData":[
          {
            "ownerBaseId":"1822931104031845",
            "objectType":"TABLE",
            "odpsTable":"loghub_070103",
            "envType":1,
            "projectGuid":"odps.b_mc1",
            "objectGuid":"odps.b_mc1.loghub_070103",
            "tenantId":0,
            "objectName":"loghub_070103",
            "ownerAccountName":"ALIYUN$dataworks_3h1_1(dataworks_3h1_1)",
            "odpsProject":"B_MC1",
            "projectName":"B_MC1",
            "actions":[
              "Select",
              "Describe"
            ],
            "projectId":194209,
            "workspaceId":"194209"
          }
        ],
        "contentType":"application/json",
        "granteeAccounts":[
          {
            "granteeId":"286098539641742899",
            "granteeTypeSub":103,
            "granteeType":1,
            "granteeName":"RAM$dataworks_3h1_1:yupeng.sunyp"
          },
          {
            "granteeId":"237857631119109360",
            "granteeTypeSub":105,
            "granteeType":1,
            "granteeName":"RAM$dataworks_3h1_1:dev"
          }
        ],
        "odpsProjectName":"B_MC1",
        "projectEnv":"1",
        "resourceSummary":"loghub_070103",
        "tenantId":280749521950784,
        "workspaceId":194209
      },
      "assignmentCategory":"MaxCompute",
      "createTime":1652094363000,
      "processDefinitionId":"definition-3dcc9ce7-d29d-435d-a908-60d4355ff5e2",
      "processId":"528535869984706",
      "status":"Pending",
      "title":"MaxComputeTable",
      "updateTime":1652094363000
    },
    "processId":"528535869984706",
    "status":"Submit",
    "taskId":"528535870015424",
    "tenantId":280749521950784,
    "updateTime":1652094364000
    }

  The following table describes the key fields in the preceding sample code.

  Field	Type	Description
  appId	Long	The ID of the workspace.
  assignee	String	The base ID of the Alibaba Cloud account used by the request approver.
  assigneeName	String	The name of the Alibaba Cloud account used by the request approver.
  comments	String	The comment.
  createTime	Long	The timestamp when the request processing order is created.
  processId	String	The ID of the request processing order.
  status	String	The status of the request processing order.
  taskId	String	The ID of the request processing task.
  tenantId	String	The tenant ID.
  updateTime	String	The timestamp when the request processing order is updated.
  eventType	String	The type of the event.
  process	Object	The process for the request processing task.
  applicant	String	The base ID of the applicant.
  applicantName	String	The name of the applicant.
  assignmentCategory	String	The type of the content on which you request permissions.
  createTime	String	The timestamp when the request processing order is created.
  processDefinitionId	String	The unique ID of the defined approval workflow.
  processId	String	The ID of the workflow.
  status	String	The status of the workflow.
  title	String	The title of the workflow.
  updateTime	Long	The timestamp when the request processing order is updated.
  approvalContent	Object	The content of the request processing order.
  applyPeriod	String	The validity period of the requested permissions.
  applyReason	String	The reason for the request.
  contentType	String	The data type of the content.
  odpsProjectName	String	The name of the MaxCompute project.
  resourceSummary	String	The description of the resource.
  tenantId	Long	The tenant ID.
  workspaceId	Long	The ID of the workspace.
  projectEnv	String	The environment of the MaxCompute project.
  granteeAccounts	Array	The accounts of the requesters.
  .granteeId	String	The ID of the requester.
  granteeType	String	The authorization type.
  granteeTypeSub	String	The account type of the requester.
  granteeName	String	The name of the requester.
  arrayData	Array	The authorized content. For more information, see Appendix 2: Authorized content (MaxCompute).

• Sample code of the message body for the event of completing a request processing order:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "appId":227859,
      "assignee":"286098539641742899",
      "assigneeName":"yupeng.sunyp",
      "comments":"ces",
      "createTime":1652095981000,
      "eventType":"approval",
      "process":{
          "applicant":"286098539641742899",
          "applicantName":"yupeng.sunyp",
          "approvalContent":{
              "applyPeriod":"2997964800000",
              "applyReason":"test",
              "arrayData":[
                  {
                      "ownerBaseId":"238266539737108884", 
                      "objectType":"TABLE",
                      "odpsTable":"cdd",
                      "objectNameCn":"a big tree with deep roots",
                      "envType":1,
                      "projectGuid":"odps.da_simple_202112",
                      "objectGuid":"odps.da_simple_202112.cdd",
                      "tenantId":0,
                      "objectName":"cdd",
                      "ownerAccountName":"RAM$dataworks_3h1_1:wb-wjh926877(wb-wjh926877)",
                      "odpsProject":"da_simple_202112",
                      "projectName":"da_simple_202112",
                      "actions":[
                          "Select",
                          "Describe"
                      ],
                      "projectId":227859,
                      "workspaceId":"227859"
                  }
              ],
              "contentType":"application/json",
              "granteeAccounts":[
                  {
                      "granteeId":"286098539641742899",
                      "granteeTypeSub":103,
                      "granteeType":1,
                      "granteeName":"RAM$dataworks_3h1_1:yupeng.sunyp"
                  }
              ],
              "odpsProjectName":"da_simple_202112",
              "projectEnv":"1",
              "resourceSummary":"cdd",
              "tenantId":280749521950784,
              "workspaceId":227859
          },
          "assignmentCategory":"MaxCompute",
          "createTime":1652095981000,
          "processDefinitionId":"definition-6e6418e6-c65f-4f26-a673-88576b1c1e4a",
          "processId":"528539182432192",
          "status":"Pending",
          "title":"MaxComputeTable",
          "updateTime":1652095981000
      },
      "processId":"528539182432192",
      "status":"Completed",
      "taskId":"528539182780353",
      "tenantId":280749521950784,
      "updateTime":1652096017000
    }

  The following table describes the key fields in the preceding sample code.

  Field	Type	Description
  appId	Long	The ID of the workspace.
  assignee	String	The base ID of the Alibaba Cloud account used by the request approver.
  assigneeName	String	The name of the Alibaba Cloud account used by the request approver.
  comments	String	The comment.
  createTime	Long	The timestamp when the request processing order is created.
  processId	String	The ID of the request processing order.
  status	String	The status of the request processing order.
  taskId	String	The ID of the request processing task.
  tenantId	String	The tenant ID.
  updateTime	String	The timestamp when the request processing order is last updated.
  eventType	String	The type of the event.
  process	Object	The process for the request processing task.
  applicant	String	The base ID of the applicant.
  applicantName	String	The name of the applicant.
  assignmentCategory	String	The type of the content on which you request permissions.
  createTime	String	The timestamp when the request processing order is created.
  processDefinitionId	String	The unique ID of the defined approval workflow.
  processId	String	The ID of the workflow.
  status	String	The status of the workflow.
  title	String	The title of the workflow.
  updateTime	Long	The timestamp when the request processing order is updated.
  approvalContent	Object	The content of the request processing order.
  applyPeriod	String	The validity period of the requested permissions.
  applyReason	String	The reason for the request.
  contentType	String	The data type of the content.
  odpsProjectName	String	The name of the MaxCompute project.
  resourceSummary	String	The description of the resource.
  tenantId	Long	The tenant ID.
  workspaceId	Long	The ID of the workspace.
  projectEnv	String	The environment of the MaxCompute project.
  granteeAccounts	Array	The accounts of the requesters.
  granteeId	String	The ID of the requester.
  granteeType	String	The authorization type.
  granteeTypeSub	String	The account type of the requester. Valid values: ACCOUNT_PRD(101): the account that is used for node scheduling in the production environment ACCOUNT_APP(102): the account for an application ACCOUNT_USER(103): the account for a user ACCOUNT_DEPT(104): the account for a department ACCOUNT_MOCK(106): the account for MOCK ACCOUNT_OTHER_USER(105): the account for another user
  granteeName	String	The name of the requester.
  arrayData	Array	The authorized content. For more information, see Appendix 3: Authorized content (DataService).

• Sample code of the message body for a pre-event for table permission request:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "operator":"1239****8872",
      "order":{
          "applyReason":"test",
          "deadlineDate":"1",
          "deadlineType":"month",
          "granteeObjectList":[
              {
                  "granteeId":"1239****8872"
              }
          ],
          "projectMeta":{
              "envCode":1,
              "labelSecurity":false,
              "objectMetaList":[
                  {
                      "action":[
                          "Select",
                          "Describe"
                      ],
                      "name":"tablei",
                      "projectGuid":"odps.d11aa"
                  }
              ],
              "projectId":2****0,
              "projectName":"d11aa"
          }
      },
      "projectId":2****0,
      "tenantId":5564****6465
  },
    "id": "539fd8f4-4ea1-4625-aa8b-6c906674c113",
    "source": "acs.dataworks",
    "specversion": "1.0",
    "subject": "",
    "time": "2020-11-19T21:04:41+08:00",
    "type": "dataworks:ApprovalChange:ApprovalChangeBeforeCreate",
    "aliyunaccountid": "123456789098****",
    "aliyunpublishtime": "2020-11-19T21:04:42.179PRC",
    "aliyuneventbusname": "default",
    "aliyunregionid": "cn-hangzhou",
    "aliyunpublishaddr": "172.25.XX.XX"
  }

  The following table describes the key fields in the preceding sample code.

  Field	Type	Description
  operator	String	The ID of the user who requests for permissions on a table (pre-event).
  projectId	Long	The ID of the workspace in which a pre-event for table permission request is identified.
  tenantId	Long	The ID of the tenant within which a pre-event for table permission request is identified.
  order	Object	The information about the request order.
  applyReason	String	The reason for the request.
  deadlineDate	String	The validity period of the request order.
  deadlineType	String	The unit of the validity period of the request order. Valid values: Day and Month.
  granteeObjectList	Object	The list of authorized objects.
  granteeId	String	The ID of the authorized object, which is the ID of a RAM user.
  projectMeta	Object	The information about the workspace.
  envCode	Integer	The code of the workspace environment. The value 0 indicates the development environment. The value 1 indicates the production environment.
  labelSecurity	Boolean	Specifies whether to enable label-level control. Valid values: true: enable false: disable
  objectMetaList	Array	The list of authorized objects.
  action	Array	The authorized operation. For example, the authorized object is granted the SELECT or DESCRIBE permission.
  name	String	The name of the table on which you want to request for permissions.
  projectGuid	String	The GUID of the workspace to which the table belongs.
  projectName	String	The name of the workspace to which the table belongs.

Message body for an alert event in Operation Center (baseline alert, event alert, and rule-based alert for an object such as node, baseline, workspace, workflow, or resource group)

• Sample code of the message body for a baseline alert:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "alarmType": "SLA_ALERT",
      "baselineId": 137000723,
      "baselineName": "Dedicated to the check for hour-level nodes at the ODS layer",
      "baselineStatus": 3,
      "bizDate": 1654444800000,
      "inGroupId": 14,
      "nodeId": 10000398734,
      "projectId": 7634,
      "taskId": 3072893778,
      "tenantId": 260953503125729
    }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  alarmType	String	The type of the alert. Valid values: SLA_ALERT REMIND_ALERT TOPIC_ALERT
  baselineId	Long	The ID of the baseline.
  baselineName	String	The name of the baseline.
  baselineStatus	Integer	The status of the baseline. Valid values: -1: indicates that the baseline is abnormal. 1: indicates that the baseline is safe. 2: indicates that an alert is triggered for the baseline. 3: indicates that the baseline is in the Overtime state.
  bizDate	Long	The data timestamp of the baseline instance.
  inGroupId	Integer	The ID of the scheduling cycle of the baseline instance. For a baseline instance that is scheduled by day, the field value is 1. For a baseline instance that is scheduled by hour, the field value ranges from 1 to 24.
  nodeId	Long	The ID of the node that triggers an exception on the baseline to which the node belongs.
  projectId	Long	The ID of the workspace to which the baseline belongs.
  taskId	Long	The ID of the instance that triggers an exception on the baseline to which the instance belongs.
  tenantId	Long	The tenant ID.

• Sample code of the message body for an event alert:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "alarmType": "TOPIC_ALERT",
      "nodeId": 10000316315,
      "projectId": 9109,
      "taskId": 3072750357,
      "taskStatus": 5,
      "tenantId": 280749521950784,
      "topicId": 1084769
    }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  alarmType	String	The type of the alert. Valid values: SLA_ALERT REMIND_ALERT TOPIC_ALERT
  topicId	Long	The ID of the event.
  taskStatus	String	The status of the instance that is generated for the node in which the event occurred.
  nodeId	Integer	The ID of the node in which the event occurred.
  projectId	Long	The ID of the workspace to which the node in which the event occurred belongs.
  taskId	Long	The ID of the instance that is generated for the node in which the event occurred.
  tenantId	Long	The tenant ID.

• Sample code of the message body for a rule-based alert:

  Note

  In most cases, the objects for which you can configure a rule include node, baseline, workspace, and workflow.

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "alarmType": "REMIND_ALERT",
      "nodeIds": "10000405472,10000405473,10000405474",
      "projectId": 9876,
      "remindId": 7605,
      "remindName": "Error alert",
      "remindType": "ERROR",
      "remindUnit": "NODE",
      "taskIds": "3072900896,3072900870,3072900855",
      "tenantId": 259025816027648
    }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  alarmType	String	The type of the alert. Valid values: SLA_ALERT REMIND_ALERT TOPIC_ALERT
  nodeIds	String	The IDs of the nodes for which the rule-based alert is triggered.
  remindId	Long	The ID of the rule.
  remindType	Stirng	The trigger condition of the rule. Valid values: FINISHED: The object finishes running. UNFINISHED: The object does not finish running. ERROR: An error occurs when the object runs. CYCLE_UNFINISHED: The object does not finish running in the current scheduling cycle. TIMEOUT: The execution of the object times out.
  projectId	Long	The ID of the workspace. The workspace contains the node for which the rule-based alert is triggered.
  remindUnit	String	The type of the object for which the rule-based alert is triggered. Valid values: NODE: a node GATEWAY_RES: an exclusive resource group for scheduling DI_RES: a resource group for Data Integration
  tenantId	Long	The tenant ID.
  taskId	String	The IDs of the instances for which the rule-based alert is triggered.
  remindName	String	The name of the rule.

• Sample code of the message body for a rule-based alert for a resource group:

  {
    "datacontenttype": "application/json;charset=utf-8",
    "data": {
      "alarmType": "REMIND_ALERT",
      "projectId": 2991,
      "remindId": 200000186,
      "remindName": "Alert for an exclusive resource group",
      "remindType": "RES_GROUP_THRESHOLD",
      "remindUnit": "GATEWAY_RES",
      "resourceGroupIdentifier": "S_res_group_195820716552192_1650965857744",
      "resourceGroupName": "emr_exclusive_scheduld",
      "resourceGroupType": "GATEWAY",
      "tenantId": 195820716552192
    }

  The following table describes the fields in the preceding sample code.

  Field	Type	Description
  alarmType	String	The type of the alert. Valid values: SLA_ALERT REMIND_ALERT TOPIC_ALERT
  remindId	Long	The ID of the rule.
  remindType	Stirng	The trigger condition of the rule. Valid values: FINISHED: The object finishes running. UNFINISHED: The object does not finish running. ERROR: An error occurs when the object runs. CYCLE_UNFINISHED: The object does not finish running in the current scheduling cycle. TIMEOUT: The execution of the object times out. RES_GROUP_THRESHOL: The resource usage of a resource group reaches the upper limit of the threshold. RES_GROUP_WAIT_AMOUNT: The number of instances that are run on a resource group and are waiting for the resources in the resource group reaches the upper limit of the threshold.
  projectId	Long	The ID of the workspace. The workspace contains the node for which the rule-based alert is triggered.
  remindUnit	String	The type of the object for which the rule-based alert is triggered. Valid values: NODE: a node GATEWAY_RES: an exclusive resource group for scheduling DI_RES: a resource group for Data Integration
  tenantId	Long	The tenant ID.
  remindName	String	The name of the rule.
  resourceGroupIdentifier	String	The ID of the resource group.
  resourceGroupName	String	The name of the resource group.
  resourceGroupType	String	The type of the resource group. Valid values: GATEWAY: a resource group for scheduling DI: a resource group for Data Integration

Message body for a status change event for a workflow

Sample code of the message body for a status change event for a workflow:

{
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "bizDate": "2022-11-07 00:00:00",
    "createTime": "2022-11-08 10:56:32",
    "dagId": 500358972116,
    "dagName": "P_test_spark_true_copy_20221108_105631",
    "dagType": 3,
    "flowId": 1,
    "flowName": "ATCLOUD_FLOW",
    "operator": "1107550004253538",
    "projectEnv": "PROD",
    "projectId": 258463,
    "status": 6,
    "tenantId": 524257424564736
}

The following table describes the key fields in the preceding sample code.

Message body for a check result feedback event

{
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "ruleCheckId": 521771452,
    "feedbackContent": "Skip",
    "ruleId": 28610334,
    "createUser": "110755000425****",
    "taskId": "1676448144650974278b99ee64ca9a26ecf4063a88797",
    "beginTime": "1676448145000",
    "envType": "ODPS",
    "projectName": "test_mc_2303_kongjian",
    "projectId": 242601,
    "tenantId": 524257424564736
}

Message body for a check completion event

{
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "projectId": 242601,
    "tenantId": 52425742456****,
    "id": 52177****,
    "taskId": "1676463288449d1b2102ac40048aeb7a628753363****",
    "entityId": 1562***,
    "ruleId": 28610334,
    "property": "-",
    "bizdate": "2023-02-09 00:00:00",
    "dateType": "YMD",
    "actualExpression": "ds\u003d20230210",
    "matchExpression": "ds\u003d$[yyyymmdd]",
    "blockType": 1,
    "checkResult": 0,
    "checkResultStatus": 0,
    "methodName": "table_count",
    "beginTime": "2023-02-15 20:14:48",
    "endTime": "2023-02-15 20:14:55",
    "timeConsuming": "7s",
    "externalType": "CWF2",
    "externalId": "triggerByManual",
    "discrete": false,
    "fixedCheck": true,
    "referenceValue": [
        {
            "bizDate": "3000-12-31 00:00:00",
            "discreteProperty": "Number of rows, one day difference",
            "value": 0.0,
            "singleCheckResult": 0
        }
    ],
    "sampleValue": [
        {
            "bizDate": "2023-02-09 00:00:00",
            "value": 3.0
        }
    ],
    "trend": "\u003e\u003d",
    "expectValue": 0.0,
    "op": "\u003e\u003d",
    "projectName": "test_mc_2303_kongjian",
    "tableName": "sx_dim_1209_001",
    "templateId": 47,
    "checkerType": 0,
    "ruleName": "Difference compared with the previous day",
    "isPrediction": false,
    "feedbackStatus": 0,
    "whetherToFilterDirtyData": false
}

Message body for a pre-event for workspace deletion within a tenant

{
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "projectId": 7***7, // The ID of the workspace.
		"tenantId": 2807****0784, // The ID of the tenant.
		"operator": "The base ID of the operator"
},
  "id": "539fd8f4-4ea1-4625-aa8b-6c906674c113",
  "source": "acs.dataworks",
  "specversion": "1.0",
  "subject": "",
  "time": "2020-11-19T21:04:41+08:00",
  "type": "dataworks:ProjectChange:DeleteProject",
  "aliyunaccountid": "123456789098****",
  "aliyunpublishtime": "2020-11-19T21:04:42.179PRC",
  "aliyuneventbusname": "default",
  "aliyunregionid": "cn-hangzhou",
  "aliyunpublishaddr": "172.25.XX.XX"
}

Message body for a post-event for workspace deletion within a tenant

{
    "datacontenttype": "application/json;charset=utf-8",
    "aliyunaccountid": "1493189603770213",
    "aliyunpublishtime": "2023-12-11T02:10:00.194Z",
    "data": {
        "tenantId": 605355236006144,
        "blockBusiness": false,
        "projectName": "test2",
        "projectId": 380708,
        "operator": "1493189603770213",
        "timestamp": 1702260556896
    },
    "aliyunoriginalaccountid": "1493189603770213",
    "specversion": "1.0",
    "aliyuneventbusname": "default",
    "id": "2c3e41e5-3486-40ce-87d4-910f989cf2a7",
    "source": "acs.dataworks",
    "time": "2023-12-11T10:10:00.117Z",
    "aliyunregionid": "cn-shanghai",
    "type": "dataworks:ProjectChange:ProjectDeleted"
}

Message body for a pre-event for data download

{
    {
  "datacontenttype": "application/json;charset=utf-8",
  "aliyunaccountid": "11075****",
  "aliyunpublishtime": "2023-12-05T07:25:31.708Z",
  "data": {
    "eventCode": "download-resources",
    "extensionBizId": "audit_4d7ebb42b805428483148295a97a8404",
    "extensionBizName": "DataWorks_IDE_Query_20231205152530.csv",
    "requestId": "77cac0c2fc12cecbf1d289128897cc7b@@ac15054317017611303051804e8b43",
    "appId": 3**9,
    "tenantId": 5242*******4736,
    "blockBusiness": true,
    "eventBody": {
      "sqlText": "SELECT * FROM table_1",
      "queryDwProjectId": "3**9",
      "moduleType": "develop_query",
      "operatorBaseId": "1107********3538",
      "datasourceId": "1***9",
      "queryDwProjectName": "yongxunQA_emr_chengdu1",
      "dataRowSize": 4577,
      "datasourceName": "odps_source",
      "operatorUid": "1107*******3538"
    },
    "operator": "1107********3538"
  },
  "aliyunoriginalaccountid": "1107********3538",
  "specversion": "1.0",
  "aliyuneventbusname": "default",
  "id": "169d171c-d523-4370-a874-bb0fa083194d",
  "source": "acs.dataworks",
  "time": "2023-12-05T15:25:31.588Z",
  "aliyunregionid": "cn-chengdu",
  "type": "dataworks:ResourcesDownload:DownloadResources"
}

Appendix 1: Formats of event messages sent to EventBridge

{ 
 "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "beginWaitTimeTime": 165270057****,
    "dagId": 44655****,
    "dagType": 0,
    "taskType": 0,
    "modifyTime": 165270057****,
    "createTime": 165254323****,
    "appId": 3*****2,
    "tenantId": 235454***432001,
    "opCode": 31,
    "flowId": 1,
    "nodeId": 100269****,
    "beginWaitResTime": 165270057****,
    "taskId": 453268****,
    "status": 3
  },
  "id": "539fd8f4-4ea1-4625-aa8b-6c906674****",
  "source": "acs.dataworks",
  "specversion": "1.0",
  "subject": "",
  "time": "2020-11-19T21:04:41+08:00",
  "type": "dataworks:InstanceStatusChanges:InstanceStatusChanges",
  "aliyunaccountid": "123456789098****",
  "aliyunpublishtime": "2020-11-19T21:04:42.179PRC",
  "aliyuneventbusname": "default",
  "aliyunregionid": "cn-hangzhou",
  "aliyunpublishaddr": "172.25.XX.XX"
}

Appendix 2: Authorized content (MaxCompute)

[
  {
    "ownerBaseId":"1822931104031845",
    "objectType":"TABLE",
    "odpsTable":"oracle_dss_a1214_1136_1_invalid_column",
    "envType":1,
    "projectGuid":"odps.px_wokebench_1",
    "objectGuid":"odps.px_wokebench_1.oracle_dss_a1214_1136_1_invalid_column",
    "tenantId":0,
    "objectName":"oracle_dss_a1214_1136_1_invalid_column",
    "ownerAccountName":"ALIYUN$dataworks_3h1_1(dataworks_3h1_1)",
    "odpsProject":"dataworks_pref_test1113",
    "projectName":"dataworks_pref_test1113",
    "actions":[
      "Select",
      "Describe"
    ],
    "projectId":107100,
    "workspaceId":"107100"
  }
]

Appendix 3: Authorized content (DataService)

[
  {
    "resourceId":"DsApiDeploy/1822931104031845/workspaceId/227859/dsDeployId/1|417381955947846|1|280749521950784|227859",
    "ownerName":"ysf01115618",
    "resourceVersion":1,
    "name":"api_api",
    "dsDeployId":"1|417381955947846|1|280749521950784|227859",
    "workspaceName":"da_simple_202112",
    "id":"417381955947846",
    "type":1,
    "ownerId":"258882139554032242",
    "url":"https://ds-cn-shanghai.data.aliyun.com/?projectId=227859&type=api&id=417381955947846&version=1&defaultProjectId=227859",
    "workspaceId":"227859"
  }
]