All Products
Search

This Product

    DataWorks:Event list and message format

    Document Center

    DataWorks:Event list and message format

    Last Updated:Mar 26, 2026

    DataWorks publishes event messages to EventBridge when specific operations occur. This reference lists every supported event, its EventBridge type filter value, extension event code, and the JSON payload structure.

    Event categories

    DataWorks events fall into two categories:

    • Regular events — Subscribe through OpenEvent. These events fire after an operation completes and do not block DataWorks operations.

    • Extension point events — Subscribe through Extensions. These events fire before an operation begins. DataWorks pauses the operation until your extension returns a result.

    Each event carries two identifiers:

    Identifier Purpose Example
    EventBridge event type (type) Filter event messages in EventBridge. See Enable event subscriptions. dataworks:FileChange:CommitFile
    Extension event code (eventCode) Identify the event type in your extension code at runtime. Extracted from the message payload. commit-file

    Both identifiers follow a consistent naming pattern: dataworks:{Category}:{Action} for type, and a kebab-case action name for eventCode.

    When to use each type

    If you need to... Use
    Receive notifications after an operation completes Regular event
    Intercept an operation and decide whether to allow it Extension point event
    Run a lightweight audit log or trigger a downstream workflow Regular event
    Enforce a policy (for example, block unauthorized file commits) Extension point event

    For operations that support both types (such as file commit), the extension point event fires *before* the operation completes, while the regular event fires *after*. If you subscribe to both, your extension receives two notifications for the same operation.

    Message structure

    Each event message has an outer envelope and an inner data payload. The envelope fields are identical across all events. The data field contains the event-specific fields described in the sections below.

    EventBridge message envelope

    {
  "datacontenttype": "application/json;charset=utf-8",
  "data": {
    "tenantId": 28378****10656,
    "eventCode": "instance-status-changes"
  },
  "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"
}
    Field Type Description
    data Object Event-specific payload. Structure varies by event type. See the event sections below.
    id String Unique event message ID.
    source String Event source. Always acs.dataworks.
    type String EventBridge event type. Use this value to filter messages in EventBridge. Example: dataworks:FileChange:CommitFile.
    time String Timestamp when the event was generated.
    aliyunaccountid String Alibaba Cloud account ID.
    aliyunpublishtime String Timestamp when EventBridge received the event.
    aliyuneventbusname String EventBridge event bus name.
    aliyunregionid String Region where the event was received.

    To filter events in EventBridge, create an event pattern that matches the type field. For example, to subscribe to all file commit events:

    {
  "source": ["acs.dataworks"],
  "type": ["dataworks:FileChange:CommitFile"]
}

    To match all events from DataWorks, omit the type filter:

    {
  "source": ["acs.dataworks"]
}

    Function Compute message envelope

    When you configure an extension to use Function Compute, DataWorks sends the event in the following format:

    {
  "blockBusiness": true,
  "eventCategoryType": "resources-download",
  "eventType": "upload-data-to-table",
  "extensionBizId": "job_6603***070",
  "messageBody": {
    "tenantId": 28378****10656,
    "eventCode": "upload-data-to-table"
  },
  "messageId": "52d44ee7-b51f-4d4d-afeb-*******"
}
    Field Type Description
    messageId String Unique event ID.
    messageBody Object Event-specific payload. Identical to the data field in EventBridge messages.
    messageBody.tenantId Long Tenant ID. Each Alibaba Cloud account maps to one tenant. Find this value in the user info panel in DataWorks Data Development.
    messageBody.eventCode String Event code that identifies the event type. See the event tables below for all valid values.
    eventCategoryType String Event category.
    eventType String Event type.
    extensionBizId String Extension checkpoint process ID.
    blockBusiness Boolean Whether the event blocks the DataWorks operation.

    Workspace-level events

    Workspace-level events are generated by modules within a workspace, such as node changes in Data Development or instance status changes in Operation Center.

    Data Development

    Events

    Event type Triggering operation Timing Regular event Extension point event EventBridge event type (type) Event code (eventCode)
    Node change Create node (publish new node to production) After operation Yes - dataworks:NodeChange:NodeChangeCreated node-change-created
    Node change Update node (modify in dev environment or publish changes to production) After operation Yes - dataworks:NodeChange:NodeChangeUpdated node-change-updated
    File change (node, resource, function) Delete file — deleted file moves to Recycle Bin Before operation Yes Yes dataworks:FileChange:DeleteFile delete-file
    File change Commit file Before operation Yes Yes dataworks:FileChange:CommitFile commit-file
    File change Deploy file Before operation Yes Yes dataworks:FileChange:DeployFile deploy-file
    File change Run code Before operation Yes Yes dataworks:FileChange:RunFile run-file
    Table change Commit table to dev environment Before operation Yes Yes dataworks:TableChange:CommitTable commit-table
    Table change Deploy table to production Before operation Yes Yes dataworks:TableChange:DeployTable deploy-table

    Message formats

    Node change events (create, update)

    The data payload:

    {
  "nodeName": "****",
  "programType": "ODPS_SQL",
  "cronExpress": "00 04 00 * * ?",
  "blockBusiness": false,
  "schedulerType": "NORMAL",
  "ownerId": "19****735",
  "priority": 1,
  "baselineId": 70***287,
  "operator": "19***735",
  "eventCode": "node-change-created",
  "repeatability": true,
  "modifyTime": 17***864,
  "createTime": 17***864,
  "tenantId": 28***656,
  "nodeId": 70***003,
  "projectId": 9***4
}
    Field Type Description
    nodeName String Node name.
    programType String File code type. Call the ListFileType API or see Supported node types for valid values.
    cronExpress String Cron expression for periodic scheduling. DataWorks auto-generates this value based on the schedule period and time configured in the DataWorks console under Data Development. See Cron expression reference.
    blockBusiness Boolean Specifies whether the event blocks DataWorks operations.
    schedulerType String Task scheduling type. See schedulerType values.
    ownerId String Alibaba Cloud user ID of the node owner. Defaults to the caller's user ID if empty.
    priority Integer Task priority. Valid values: 1, 3, 5, 7, 8. Higher values indicate higher priority.
    baselineId Long Baseline ID.
    operator String UID of the user who created or updated the node.
    eventCode String Extension event code.
    repeatability Boolean Specifies whether the node supports reruns. true: rerunnable. false: not rerunnable.
    modifyTime Long Last modification timestamp.
    createTime Long Creation timestamp.
    tenantId Long Tenant ID.
    nodeId Long Node ID.
    projectId Long Workspace ID.

    File change events (commit, deploy)

    The data payload:

    {
  "fileName": "******",
  "extensionBizId": "eb******9ce",
  "changeType": "0",
  "blockBusiness": false,
  "dataSourceName": "0_******engine",
  "operator": "19***735",
  "eventCode": "commit-file",
  "fileCreateTime": "2024-07-12 11:08:50",
  "tenantId": 28***656,
  "fileOwner": "19***735",
  "fileVersion": 1,
  "projectId": 9***4,
  "fileType": 10,
  "fileId": 50***830,
  "resourceType": 1
}
    Field Type Description
    fileName String File name.
    extensionBizId String Extension checkpoint process ID.
    changeType String File change type. 0: create. 1: update. 2: delete.
    blockBusiness Boolean Specifies whether the event blocks operations.
    dataSourceName String Data source name.
    operator String UID of the user who committed or deployed the file.
    eventCode String Extension event code.
    fileCreateTime String File creation time. Format: yyyy-MM-dd HH:mm:ss.
    tenantId Long Tenant ID.
    fileOwner String File owner.
    fileVersion Long File version.
    projectId Long Workspace ID.
    fileType Long File code type. Call the ListFileType API or see Supported node types for valid values.
    fileId Long File ID.
    resourceType Integer Resource type.
    nodeId Long Scheduling node ID.

    File change events (delete, run)

    The data payload:

    {
  "fileName": "***",
  "extensionBizId": "bf******6e3",
  "blockBusiness": false,
  "operator": "19***735",
  "eventCode": "delete-file",
  "fileCreateTime": "2024-07-12 11:08:50",
  "tenantId": 28***656,
  "fileOwner": "19***735",
  "nodeId": 70***003,
  "projectId": 9***4,
  "fileType": 10,
  "fileId": 50***830,
  "resourceType": 1
}
    Field Type Description
    fileName String File name.
    extensionBizId String Extension checkpoint process ID.
    blockBusiness Boolean Specifies whether the event blocks operations.
    operator String UID of the user who deleted or ran the file.
    eventCode String Extension event code.
    fileCreateTime String File creation time. Format: yyyy-MM-dd HH:mm:ss.
    tenantId Long Tenant ID.
    fileOwner String File owner.
    nodeId Long Scheduling node ID.
    projectId Long Workspace ID.
    fileType Long File code type. Call the ListFileType API or see Supported node types for valid values.
    fileId Long File ID.
    resourceType Integer Resource type.

    Table change events (commit to dev, deploy to production)

    The data payload:

    {
  "operator": "**************",
  "projectId": 12*****56,
  "tenantId": 12******56,
  "extensionBizId": "12***56",
  "tableName": "table1",
  "tableType": "ODPS",
  "maxComputeProject": "project1"
}
    Field Type Description
    operator String UID of the user who committed or deployed the table.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    extensionBizId String Extension checkpoint process ID.
    tableName String Table name.
    tableType String Table type. Valid value: ODPS.
    maxComputeProject String MaxCompute project name.

    Data Integration

    Events

    Event type Triggering operation Timing Regular event Extension point event EventBridge event type (type) Event code (eventCode)
    Node change Start task Before operation Yes Yes dataworks:NodeChange:StartDiJob start-diJob
    Node change Batch start tasks Before operation Yes Yes dataworks:NodeChange:BatchStartDiJob batch-start-diJob

    Message formats

    Start task event

    The data payload:

    {
  "eventCode": "start-diJob",
  "extensionBizId": "0a4***b8ae",
  "extensionBizName": "sync_mysql_to_odps_20240726_192307",
  "appId": 293624,
  "showTableMapping": true,
  "tenantId": 28***656,
  "blockBusiness": true,
  "id": 5280,
  "projectId": 9***4,
  "tableMapping": [
    {
      "srcTable": "xb_test_116",
      "dstDatasourceName": "odps_first",
      "srcDatabaseName": "xiaobo_sharding_79fz",
      "srcDatasourceName": "mysql_3357_pub_ip_1",
      "dstTable": "ods_xb_test_116"
    }
  ],
  "operator": "1504650005316516"
}
    Field Type Description
    projectId Long Workspace ID.
    operator String UID of the user who started the task.
    extensionBizName String Solution name.
    showTableMapping Boolean Specifies whether to include table mapping in the message. true: include. false: exclude. Defaults to false when the table count exceeds 500.
    tableMapping JSONArray Table mapping details.
    tableMapping[].srcDatasourceName String Source data source name.
    tableMapping[].srcDatabaseName String Source database name.
    tableMapping[].srcTable String Source table name.
    tableMapping[].dstDatasourceName String Destination data source name.
    tableMapping[].dstTable String Destination table name.
    tenantId Long Tenant ID.
    eventCode String Extension event code.

    Batch start tasks event

    Field Type Description
    jobId Long Job ID.
    forceRun Boolean Specifies whether to force-run the task.
    startAsV2 Boolean Specifies whether the task uses v2 format.
    setting.lastStartPosition String Last start position for incremental sync. Format: yyyy-MM-dd HH:mm:ss.

    Batch start tasks event

    The data payload:

    {
  "needErrorMessage": false,
  "extensionBizId": "2de***c4c6",
  "extensionBizName": "sync_mysql_to_holo_20240911_170801,sync_mysql_to_odps_20240726_192307",
  "errorMessageOnlyFailedFileIds": false,
  "blockBusiness": true,
  "env": "prod",
  "operator": "15***516",
  "setting": {
    "startDateTime": "2024-09-12 14:00:00",
    "timeZone": "Asia/Shanghai"
  },
  "jobIds": [5777, 5679],
  "eventCode": "batch-start-diJob",
  "tableMappings": [
    {
      "extensionBizName": "sync_mysql_to_holo_20240911_170801",
      "id": 5777,
      "tableMapping": [
        {
          "srcTable": "test_verify1",
          "dstDatasourceName": "molin_db",
          "srcDatabaseName": "di_test",
          "srcDatasourceName": "mysql_public",
          "dstTable": "test_verify1"
        }
      ]
    }
  ],
  "appId": 293624,
  "showTableMapping": true,
  "tenantId": 52***018,
  "projectId": 9***4
}
    Field Type Description
    projectId Long Workspace ID.
    operator String UID of the user who started the tasks.
    extensionBizName String Solution name.
    setting JSONObject Start configuration.
    setting.startDateTime String Start time.
    setting.timeZone String Time zone.
    jobIds Array List of job IDs to start.
    tableMappings JSONArray Table mappings grouped by job.
    showTableMapping Boolean Specifies whether to include table mappings. Defaults to false when the table count exceeds 500.
    tenantId Long Tenant ID.
    eventCode String Extension event code.

    Operation Center

    Changing the scheduling resource group or changing the node owner triggers a node-change-updated event.

    Events

    Event type Triggering operation Timing Regular event Extension point event EventBridge event type (type) Event code (eventCode)
    Node change Delete node (publish deletion to production or delete from Recycle Bin) After operation Yes - dataworks:NodeChange:NodeChangeDeleted node-change-deleted
    Node change Undeploy node — directly undeploys a periodic task in production, deletes the node from Data Development, and moves it to Recycle Bin Before operation - Yes dataworks:NodeChange:UndeployNode undeploy-node
    Node change Freeze node — also triggers node-change-updated Before operation - Yes dataworks:NodeChange:FreezeNode freeze-node
    Node change Unfreeze node — also triggers node-change-updated Before operation - Yes dataworks:NodeChange:UnFreezeNode unfreeze-node
    Backfill Backfill data Before operation - Yes dataworks:BackfillDataOperate:BackfillData backfill-data
    Task status change Task instance status change After operation Yes - dataworks:InstanceStatusChanges:InstanceStatusChanges instance-status-changes
    Instance change Freeze instance After operation Yes - dataworks:InstanceChange:FreezeInstance freeze-instance
    Instance change Unfreeze instance After operation Yes - dataworks:InstanceChange:UnfreezeInstance unfreeze-instance
    Instance change Kill instance After operation Yes - dataworks:InstanceChange:KillInstance kill-instance
    Instance change Rerun instance (rerun or rerun downstream) After operation Yes - dataworks:InstanceChange:RerunInstance rerun-instance
    Instance change Set instance as success After operation Yes - dataworks:InstanceChange:SetInstanceSuccess set-instance-success
    Instance change Remove upstream dependency from instance After operation Yes - dataworks:InstanceChange:DeleteTaskInstanceDependencies delete-task-instance-dependencies
    Instance change Freeze instance Before operation - Yes dataworks:InstanceChange:PreFreezeInstance pre-freeze-instance
    Instance change Unfreeze instance Before operation - Yes dataworks:InstanceChange:PreUnfreezeInstance pre-unfreeze-instance
    Instance change Rerun instance Before operation - Yes dataworks:InstanceChange:PreRerunInstance pre-rerun-instance
    Instance change Set instance as success Before operation - Yes dataworks:InstanceChange:PreSetInstanceSuccess pre-set-instance-success
    Instance change Kill instance Before operation - Yes dataworks:InstanceChange:PreKillInstance pre-kill-instance
    Instance change Delete expired instances After operation Yes - dataworks:InstanceChange:ExpiredTaskInstancesDeleted expired-task-instances-deleted
    Workflow status change Workflow status change (backfill instances, manual workflows) After operation Yes - dataworks:DagStatusChanges:DagStatusChanges dag-status-changes
    Monitoring alert Monitoring alert After operation Yes - dataworks:MonitorAlert:WorkbenchMonitorAlert workbench-monitor-alert

    Message formats

    Node change events (delete, undeploy, freeze, unfreeze)

    Node delete event — the data payload:

    {
  "nodeName": "",
  "programType": "ODPS_SQL",
  "cronExpress": "00 20 00 * * ?",
  "schedulerType": "NORMAL",
  "ownerId": "19****735",
  "priority": 1,
  "baselineId": 117801853,
  "repeatability": true,
  "modifyTime": 1646364549642,
  "createTime": 1646364549642,
  "datasource": "odps_source",
  "tenantId": 28378****10656,
  "nodeId": 100***150,
  "projectId": 30**95,
  "operator": "19***735"
}

    Field definitions are the same as node change events (create, update).

    Node freeze, unfreeze, and undeploy events — the data payload:

    {
  "operator": "19***735",
  "projectId": 12***56,
  "tenantId": 28***656,
  "nodeIds": [1, 2, 3],
  "extensionBizId": "12***56"
}
    Field Type Description
    operator String UID of the user who performed the freeze, unfreeze, or undeploy operation.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    nodeIds Array List of affected node IDs.
    extensionBizId String Extension checkpoint process ID.

    Backfill data event

    The data payload:

    {
  "excludeNodeIds": [],
  "rootNodeId": 1000****271,
  "startFutureInstanceImmediately": false,
  "useMultipleTimePeriods": true,
  "operator": "19***735",
  "eventCode": "backfill-data",
  "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": [10***271],
  "projectId": 9***4,
  "order": "asc",
  "extensionBizId": "12***56"
}
    Field Type Description
    name String Backfill workflow name.
    rootNodeId Long Root node ID of the backfill workflow.
    rootNodeProjectId Long Workspace ID of the root node.
    includeNodeIds Array Node IDs to backfill.
    excludeNodeIds Array Node IDs to exclude. Excluded nodes generate skip instances that are set to success without running any code.
    bizBeginTime String Start time for hourly tasks. Format: HH:mm:ss. Range: 00:00:00 to 23:59:59.
    bizEndTime String End time for hourly tasks. Format: HH:mm:ss. Range: 00:00:00 to 23:59:59.
    isParallel Boolean Specifies whether backfill runs in parallel. true: parallel. false: sequential.
    parallelGroup Integer Number of parallel groups. 1 means no grouping.
    startFutureInstanceImmediately Boolean Specifies whether to skip the scheduled time and immediately run future instances. true: skip and run immediately. false: wait for scheduled time.
    order String Backfill run order by business date. asc: ascending. desc: descending.
    multipleTimePeriods String Segmented business date ranges as a JSON string. Example: [{"bizBeginTime":"2022-04-17","bizEndTime":"2022-04-17"}].
    tenantId Long Tenant ID.
    projectId Long Workspace ID.
    operator String UID of the user who initiated the backfill.
    extensionBizId String Extension checkpoint process ID.
    eventCode String Extension event code.

    Task status change event

    The data payload:

    {
  "beginWaitTimeTime": 1652700576000,
  "dagId": 446***330,
  "dagType": 0,
  "eventCode": "instance-status-changes",
  "taskType": 0,
  "modifyTime": 1652700577000,
  "createTime": 1652543233000,
  "appId": 3*****2,
  "tenantId": 235454***432001,
  "opCode": 31,
  "flowId": 1,
  "nodeId": 100***219,
  "beginWaitResTime": 1652700577000,
  "taskId": 453***169,
  "status": 3
}
    Field Type Description
    finishTime Long Timestamp when the instance finished running.
    beginWaitTimeTime Long Timestamp when the instance started waiting to run.
    beginRunningTime Long Timestamp when the instance started running.
    beginWaitResTime Long Timestamp when the instance started waiting for resources.
    dagId Long DAG ID.
    dagType Integer DAG type. See dagType values.
    taskType Integer Task scheduling type. Same values as schedulerType. See schedulerType values.
    modifyTime Long Last modification timestamp.
    createTime Long Creation timestamp.
    appId Long Workspace ID. Call ListProjects to retrieve workspace IDs.
    tenantId Long Tenant ID.
    opCode Integer Operation code. This field can be ignored.
    flowId Long Workflow ID. For periodic tasks, defaults to 1. For manual workflows, returns the actual workflow ID.
    nodeId Long Node ID.
    taskId Long Task instance ID.
    status Integer Instance status. See Instance status values.
    eventCode String Extension event code.

    Instance change events (freeze, unfreeze, kill, rerun, set as success)

    The data payload:

    {
  "eventCode": "freeze-instance",
  "operator": "19***735",
  "projectId": 12***8,
  "projectType": "PROD",
  "taskIds": [523***9736],
  "tenantId": 28***656
}
    Field Type Description
    operator String UID of the user who performed the operation (freeze, unfreeze, kill, rerun, or set as success).
    projectType String Runtime environment. PROD: production. DEV: development.
    taskIds List\<Long\> List of instance IDs.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    eventCode String Event code.

    Instance change pre-events (freeze, unfreeze, rerun, set as success)

    The data payload:

    {
  "eventCode": "pre-freeze-instance",
  "extensionBizId": "055***afaa",
  "extensionBizName": "node_name",
  "projectId": 9***4,
  "taskIds": [523536569736],
  "tenantId": 28***656,
  "operator": "19***735"
}
    Field Type Description
    extensionBizId String Extension checkpoint process ID.
    extensionBizName String Target object name. When multiple objects are involved, the value is truncated with "...".
    projectId Long Workspace ID.
    taskIds List\<Long\> List of instance IDs.
    tenantId Long Tenant ID.
    operator String UID of the user who performed the operation.
    eventCode String Extension event code.

    Delete expired instances event

    The data payload:

    {
  "eventCode": "expired-task-instances-deleted",
  "deletedTaskInstanceIds": [524***035, 524***498, 524***637],
  "appId": 307303,
  "tenantId": 28***656,
  "blockBusiness": false,
  "owner": "1107***538",
  "operationTime": 1734505954897
}
    Field Type Description
    deletedTaskInstanceIds List List of deleted instance IDs.
    owner String Instance owner user ID.
    operationTime Long Operation timestamp.
    blockBusiness Boolean Specifies whether the event blocks the process when an extension exists. true: block. false: do not block.
    appId Long Workspace ID.
    tenantId Long Tenant ID.
    eventCode String Extension event code.

    Remove upstream dependency event

    The data payload:

    {
  "eventCode": "delete-task-instance-dependencies",
  "upstreamTaskInstanceIds": [52******35, 52******98, 52******37],
  "appId": 3***03,
  "tenantId": 52******36,
  "blockBusiness": false,
  "taskInstanceId": 52******49,
  "operator": "19***735",
  "operationTime": 1734505954897
}
    Field Type Description
    taskInstanceId Long Downstream instance ID.
    upstreamTaskInstanceIds List List of upstream instance IDs whose dependencies were removed.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.

    Workflow status change event

    The data payload:

    {
  "bizDate": "2022-11-07 00:00:00",
  "createTime": "2022-11-08 10:56:32",
  "dagId": 500358972116,
  "dagName": "P_test_spark_true_copy_20221108_105631",
  "eventCode": "dag-status-changes",
  "dagType": 3,
  "flowId": 1,
  "flowName": "ATCLOUD_FLOW",
  "operator": "11****538",
  "projectEnv": "PROD",
  "projectId": 25***63,
  "status": 6,
  "tenantId": 52***736
}
    Field Type Description
    bizDate String Business date. Format: yyyy-MM-dd HH:mm:ss.
    createTime String Workflow creation time. Format: yyyy-MM-dd HH:mm:ss.
    dagId Long DAG ID.
    dagName String Workflow name.
    dagType Integer DAG type. See dagType values.
    flowId Integer Workflow ID.
    flowName String Workflow name.
    operator String UID of the user who created the workflow.
    projectEnv String Environment. DEV: development. PROD: production.
    tenantId Long Tenant ID.
    projectId Long Workspace ID.
    status Integer Workflow status. 1: not running. 4: running. 5: failed. 6: succeeded.
    eventCode String Extension event code.

    Monitoring alert events

    DataWorks supports three alert types, each with a different payload structure.

    SLA alert — the data payload:

    {
  "eventCode": "workbench-monitor-alert",
  "alarmType": "SLA_ALERT",
  "baselineId": 137***723,
  "baselineName": "ods_hourly_check_baseline",
  "baselineStatus": 3,
  "bizDate": 1654444800000,
  "inGroupId": 14,
  "nodeId": 1000***8734,
  "projectId": 76***34,
  "taskId": 307***3778,
  "tenantId": 28***656
}
    Field Type Description
    alarmType String Alert type. Valid values: SLA_ALERT, REMIND_ALERT, TOPIC_ALERT.
    baselineId Long Baseline ID.
    baselineName String Baseline name.
    baselineStatus Integer Baseline status. -1: error. 1: safe. 2: warning. 3: breached.
    bizDate Long Business date timestamp.
    inGroupId Integer Baseline instance cycle number. 1 for daily baselines. 1–24 for hourly baselines.
    nodeId Long Node ID that caused the baseline alert.
    projectId Long Workspace ID.
    taskId Long Instance ID that caused the baseline alert.
    tenantId Long Tenant ID.
    eventCode String Extension event code.

    Event alert (TOPIC_ALERT) — the data payload:

    {
  "alarmType": "TOPIC_ALERT",
  "nodeId": 1000***315,
  "projectId": 91***09,
  "taskId": 307***0357,
  "taskStatus": 5,
  "tenantId": 28***656,
  "topicId": 1084769
}
    Field Type Description
    alarmType String Alert type.
    topicId Long Event ID.
    taskStatus String Instance status that triggered the event.
    nodeId Integer Node ID that triggered the event.
    projectId Long Workspace ID.
    taskId Long Instance ID that triggered the event.
    tenantId Long Tenant ID.

    Rule-triggered alert (REMIND_ALERT) — the data payload:

    Alert rules can target task nodes, baselines, workspaces, or workflows.
    {
  "alarmType": "REMIND_ALERT",
  "nodeIds": "1000***5472,1000***5473,1000***5474",
  "projectId": 9***4,
  "remindId": 7605,
  "remindName": "error_alert_rule",
  "remindType": "ERROR",
  "remindUnit": "NODE",
  "taskIds": "307***0896,307***0870,307***0855",
  "tenantId": 28***656
}
    Field Type Description
    alarmType String Alert type.
    nodeIds String Comma-separated list of node IDs that triggered the alert rule.
    remindId Long Alert rule ID.
    remindName String Alert rule name.
    remindType String Alert rule trigger condition. FINISHED: completed. UNFINISHED: not completed. ERROR: run error. CYCLE_UNFINISHED: cycle not completed. TIMEOUT: run timeout.
    remindUnit String Alert rule target type. NODE: task node. GATEWAY_RES: scheduling resource group. DI_RES: data integration resource group.
    projectId Long Workspace ID.
    taskIds String Comma-separated list of instance IDs that triggered the alert.
    tenantId Long Tenant ID.

    Resource group alert — the data payload:

    {
  "alarmType": "REMIND_ALERT",
  "projectId": 9***4,
  "remindId": 200***186,
  "remindName": "exclusive_resource_group_alert",
  "remindType": "RES_GROUP_THRESHOLD",
  "remindUnit": "GATEWAY_RES",
  "resourceGroupIdentifier": "S_res_group_195820716552192_1650965857744",
  "resourceGroupName": "emr_exclusive_scheduld",
  "resourceGroupType": "GATEWAY",
  "tenantId": 28***656
}
    Field Type Description
    alarmType String Alert type.
    remindId Long Alert rule ID.
    remindName String Alert rule name.
    remindType String Alert rule trigger condition. Includes all values from the task rule alert, plus: RES_GROUP_THRESHOLD: resource group utilization. RES_GROUP_WAIT_AMOUNT: instances waiting for resources.
    remindUnit String Alert rule target type. NODE: task node. GATEWAY_RES: scheduling resource group. DI_RES: data integration resource group.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    resourceGroupIdentifier String Resource group unique identifier.
    resourceGroupName String Resource group name.
    resourceGroupType String Resource group type. GATEWAY: scheduling resource group. DI: data integration resource group.

    Security Center

    Events

    Event type Triggering operation Timing Regular event Extension point event EventBridge event type (type) Event code (eventCode)
    Approval Center Create permission request Before operation - Yes dataworks:ApprovalChange:ApprovalChangeCreated approval-change-created
    Approval Center Complete request After operation Yes - dataworks:ApprovalChange:ApprovalChangeFinished approval-change-finished
    Security Center (table permissions) Table permission request Before operation - Yes dataworks:ApprovalChange:ApprovalChangeBeforeCreate approval-change-before-create

    Message formats

    Approval Center events (create, complete)

    The data payload for the approval-change-created event:

    {
  "appId": 194209,
  "assignee": "286098539641742899",
  "eventCode": "approval-change-created",
  "assigneeName": "******.******",
  "comments": "",
  "createTime": 1652094364000,
  "eventType": "approval",
  "process": {
    "applicant": "2860****899",
    "applicantName": "yupeng.sunyp",
    "approvalContent": {},
    "assignmentCategory": "MaxCompute",
    "processDefinitionId": "definition-6e6418e6-****",
    "processId": "528535869984706",
    "status": "Pending",
    "title": "MaxComputeTable",
    "updateTime": 1652094363000
  },
  "processId": "528535869984706",
  "status": "Submit",
  "taskId": "528535870015424",
  "tenantId": 28***656,
  "updateTime": 1652094364000
}
    Field Type Description
    appId Long Workspace ID.
    assignee String Approver's base ID.
    assigneeName String Approver's name.
    comments String Comments.
    createTime Long Approval request creation timestamp.
    processId String Approval request ID.
    status String Approval request status.
    taskId String Approval task ID.
    tenantId String Tenant ID.
    updateTime String Last update timestamp.
    eventType String Event type.
    process Object Approval process object.
    process.applicant String Applicant's base ID.
    process.applicantName String Applicant's name.
    process.approvalContent Object Approval content object containing request details such as applyPeriod, applyReason, contentType, granteeAccounts, arrayData, odpsProjectName, projectEnv, tenantId, and workspaceId.
    process.approvalContent.granteeAccounts[].granteeTypeSub String Grantee account subtype. Valid values: ACCOUNT_PRD (101): production cloud account used by production scheduling. ACCOUNT_APP (102): application cloud account. ACCOUNT_USER (103): personal cloud account. ACCOUNT_DEPT (104): department cloud account. ACCOUNT_MOCK (106): mock account. ACCOUNT_OTHER_USER (105): third-party cloud account.
    process.assignmentCategory String Approval content type.
    process.processDefinitionId String Workflow definition ID.
    process.processId String Process ID.
    process.status String Workflow status.
    process.title String Workflow title.
    process.updateTime Long Approval request update timestamp.
    eventCode String Extension event code.

    Table permission request pre-event

    Table permission request pre-event

    Field Type Description
    operator String UID of the user who submitted the table permission request.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    order Object Request details.
    order.applyReason String Request reason.
    order.deadlineDate String Request validity period.
    order.deadlineType String Time unit for the validity period. Example: Day, Month.
    order.granteeObjectList Array List of grantee objects.
    order.granteeObjectList[].granteeId String Grantee ID (RAM user ID).
    order.projectMeta Object Workspace metadata.
    order.projectMeta.envCode Integer Environment code. 0: development. 1: production.
    order.projectMeta.labelSecurity Boolean Specifies whether label-level access control is enabled.
    order.projectMeta.objectMetaList Array Requested objects.
    order.projectMeta.objectMetaList[].action Array Permission actions. Example: Select, Describe.
    order.projectMeta.objectMetaList[].name String Table name for the permission request.
    order.projectMeta.objectMetaList[].projectGuid String GUID of the workspace containing the table.
    order.projectMeta.objectMetaList[].projectName String Name of the workspace containing the table.
    eventType String Event type.

    Data Quality

    Events

    Event type Triggering operation Timing Regular event Extension point event EventBridge event type (type) Event code (eventCode)
    Data quality check Check result feedback After operation Yes - dataworks:DqcCheck:DqcCheckFeedbackEvent dqc-check-feedback-event
    Data quality check Check completed After operation Yes - dataworks:DqcCheck:DqcCheckFinishedEvent dqc-check-finished-event
    Data quality rules (pre-event) Batch create rules Before operation - Yes dataworks:DqcCheck:BatchCreateDataQualityRules batch-create-data-quality-rules
    Data quality rules (pre-event) Batch update rules Before operation - Yes dataworks:DqcCheck:BatchUpdateDataQualityRules batch-update-data-quality-rules
    Data quality rules (pre-event) Batch delete rules Before operation - Yes dataworks:DqcCheck:BatchDeleteDataQualityRules batch-delete-data-quality-rules
    Data quality rules (pre-event) Update single rule Before operation - Yes dataworks:DqcCheck:UpdateDataQualityRule update-data-quality-rule
    Data quality monitors (pre-event) Create monitor Before operation - Yes dataworks:DqcCheck:CreateDataQualityEvaluationTask create-data-quality-evaluation-task
    Data quality monitors (pre-event) Update monitor Before operation - Yes dataworks:DqcCheck:UpdateDataQualityEvaluationTask update-data-quality-evaluation-task
    Data quality monitors (pre-event) Clone monitor Before operation - Yes dataworks:DqcCheck:CloneDataQualityEvaluationTask clone-data-quality-evaluation-task
    Data quality monitors (pre-event) Batch delete monitors Before operation - Yes dataworks:DqcCheck:BatchDeleteDataQualityEvaluationTasks batch-delete-data-quality-evaluation-tasks
    Alert subscriptions (pre-event) Create alert subscription Before operation - Yes dataworks:DqcCheck:CreateDataQualityEvaluationTaskNotification create-data-quality-evaluation-task-notification
    Alert subscriptions (pre-event) Update alert subscription Before operation - Yes dataworks:DqcCheck:UpdateDataQualityEvaluationTaskNotification update-data-quality-evaluation-task-notification
    Alert subscriptions (pre-event) Delete alert subscription Before operation - Yes dataworks:DqcCheck:DeleteDataQualityEvaluationTaskNotification delete-data-quality-evaluation-task-notification

    Message formats

    Check result feedback event

    The data payload:

    {
  "ruleCheckId": 521771452,
  "feedbackContent": "跳过",
  "ruleId": 28610334,
  "createUser": "110755000425****",
  "taskId": "167644814****9a26ecf4063a88797",
  "beginTime": "1676448145000",
  "envType": "ODPS",
  "projectName": "test_mc_2303_kongjian",
  "projectId": 9***4,
  "tenantId": 28***656
}
    Field Type Description
    ruleId Long Data quality rule ID.
    ruleCheckId Long Check result auto-increment ID.
    feedbackContent String Feedback content.
    createUser String User ID of the person who submitted the feedback.
    taskId String Data quality task ID.
    beginTime String Check start time (timestamp string).
    envType String Data source type associated with the rule.
    projectName String Data source unique identifier for the table associated with the rule.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.

    Data quality rule pre-events (batch create, batch update, batch delete)

    The data payload:

    {
  "projectId": 9***4,
  "tenantId": 28***656,
  "id": 52177****,
  "taskId": "1671***7a6",
  "entityId": 1562***,
  "ruleId": 28610334,
  "property": "-",
  "bizdate": "2023-02-09 00:00:00",
  "dateType": "YMD",
  "actualExpression": "ds=20230210",
  "matchExpression": "ds=$[yyyymmdd]",
  "blockType": 1,
  "checkResult": 0,
  "eventCode": "dqc-check-finished-event",
  "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": "表行数，1天差值",
      "value": 0.0,
      "singleCheckResult": 0
    }
  ],
  "sampleValue": [
    {
      "bizDate": "2023-02-09 00:00:00",
      "value": 3.0
    }
  ],
  "trend": ">=",
  "expectValue": 0.0,
  "op": ">=",
  "projectName": "test_mc_2303_kongjian",
  "tableName": "sx_dim_1209_001",
  "templateId": 47,
  "checkerType": 0,
  "ruleName": "前一天差值",
  "isPrediction": false,
  "upperValue": 0.0,
  "lowerValue": 0.0,
  "checkerName": "table_count"
}
    Field Type Description
    id Long Check result auto-increment ID.
    taskId String Data quality task ID.
    entityId Long Partition expression ID.
    ruleId Long Rule ID.
    property String Partition expression.
    bizdate String Business date.
    dateType String Partition type.
    actualExpression String Actual partition expression.
    matchExpression String Matching partition expression.
    blockType Integer Rule strength. 0: weak rule. 1: strong rule.
    checkResult Integer Check result. 0: pass. 1: warning. 2: critical.
    checkResultStatus Integer Check result status. 0: pass. 1: warning. 2: critical.
    methodName String Check method name.
    beginTime String Check start time.
    endTime String Check end time.
    timeConsuming String Time consumed.
    externalType String External trigger type.
    externalId String External trigger ID.
    discrete Boolean Specifies whether the check uses discrete values.
    fixedCheck Boolean Specifies whether the check uses fixed thresholds.
    referenceValue Array Reference values.
    sampleValue Array Sample values.
    trend String Expected trend operator.
    expectValue Double Expected threshold value.
    op String Comparison operator.
    projectName String Data source unique identifier for the table.
    tableName String Table name.
    templateId Long Template ID.
    checkerType Integer Check type.
    ruleName String Rule name.
    isPrediction Boolean Specifies whether the check result is a prediction.
    upperValue Double Upper threshold.
    lowerValue Double Lower threshold.
    checkerName String Check method name.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    eventCode String Extension event code.

    Data quality rule pre-events (batch create, batch update, batch delete, update single)

    Batch create rules — the data payload:

    {
  "eventCode": "batch-create-data-quality-rules",
  "projectId": 30***03,
  "tenantId": 28***656,
  "operator": "19***735",
  "operationTime": 1734505954897,
  "dataQualityTaskId": 1001,
  "target": {
    "databaseType": "maxcompute",
    "tableGuid": "odps.project_demo.tb_table_demo"
  },
  "rules": [
    {
      "name": "表行数大于0",
      "enabled": true,
      "severity": "High",
      "description": "数据质量规则创建操作检查测试",
      "templateCode": "system:table:table_count:fixed:0",
      "samplingConfig": {
        "metric": "count"
      },
      "checkingConfig": {
        "type": "fixed",
        "thresholds": {
          "expected": {
            "expression": "$checkValue > 0"
          },
          "critical": {
            "expression": "$checkValue <= 0"
          }
        }
      }
    }
  ]
}
    Field Type Description
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.
    dataQualityTaskId Long Data quality monitor ID.
    target Object Target table.
    target.databaseType String Database type. Example: maxcompute.
    target.tableGuid String Table GUID in Data Map.
    rules Array List of rules to create. Each rule contains name, enabled, severity, description, templateCode, samplingConfig, and checkingConfig.
    eventCode String Extension event code.

    Batch update rules — the payload structure is identical to batch create, with the addition of an id field for each rule in the rules array.

    Batch delete rules — the data payload:

    {
  "eventCode": "batch-delete-data-quality-rules",
  "ids": [10***01, 10***02, 10***03],
  "projectId": 30***03,
  "tenantId": 524***4736,
  "operator": "19***735",
  "operationTime": 1734505954897
}
    Field Type Description
    ids List\<Long\> List of deleted rule IDs.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.
    eventCode String Extension event code.

    Update single rule — the data payload:

    {
  "eventCode": "update-data-quality-rule",
  "projectId": 30***03,
  "tenantId": 28***656,
  "operator": "19***735",
  "operationTime": 1734505954897,
  "id": 100001,
  "name": "表行数大于0",
  "enabled": true,
  "severity": "High",
  "description": "数据质量规则创建操作检查测试",
  "templateCode": "system:table:table_count:fixed:0",
  "samplingConfig": {
    "metric": "count"
  },
  "checkingConfig": {
    "type": "fixed",
    "thresholds": {
      "expected": {
        "expression": "$checkValue > 0"
      },
      "critical": {
        "expression": "$checkValue <= 0"
      }
    }
  }
}
    Field Type Description
    id Long Rule ID.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.
    name String Rule name.
    enabled Boolean Specifies whether the rule is enabled.
    severity String Rule severity. Example: High.
    description String Rule description.
    templateCode String Rule template code.
    samplingConfig Object Sampling configuration.
    checkingConfig Object Check configuration including threshold expressions.
    eventCode String Extension event code.

    Data quality monitor pre-events (create, update, clone, batch delete)

    Create monitor — the data payload (abbreviated):

    {
  "eventCode": "create-data-quality-evaluation-task",
  "name": "表数据准确性监控",
  "target": {
    "databaseType": "emr",
    "tableGuid": "an-emr-table-guid"
  },
  "trigger": {
    "type": "ByScheduledTaskInstance",
    "taskIds": [1001, 1002]
  },
  "dataSourceId": 201,
  "runtimeConf": "{ \"queue\": \"default\", \"sqlEngine\": \"HIVE_SQL\" }",
  "rules": ["..."],
  "hooks": ["..."],
  "notifications": {},
  "projectId": 9***4,
  "tenantId": 28***656,
  "operator": "19***735",
  "operationTime": 1734505954897
}
    Field Type Description
    name String Monitor name.
    target Object Target table. Contains databaseType and tableGuid.
    trigger Object Trigger configuration. Contains type (for example, ByScheduledTaskInstance) and taskIds.
    dataSourceId Long Data source ID.
    runtimeConf String Runtime configuration (JSON string).
    rules Array List of data quality rules with sampling and check configurations.
    hooks Array Hook actions (for example, BlockTaskInstance) with condition expressions.
    notifications Object Alert notification configuration including channels and receivers.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.
    eventCode String Extension event code.

    Update monitor — the payload structure is identical to create monitor, with the addition of an id field (Long) for the monitor ID.

    Clone monitor — the data payload:

    {
  "eventCode": "clone-data-quality-evaluation-task",
  "id": 10001,
  "targets": [
    {
      "databaseType": "emr",
      "tableGuid": "an-emr-table-guid"
    }
  ],
  "projectId": 9***4,
  "tenantId": 28***656,
  "operator": "19***735",
  "operationTime": 1734505954897
}
    Field Type Description
    id Long Source monitor ID to clone from.
    targets Array List of target tables. Each contains databaseType and tableGuid.
    targets[].databaseType String Target database type. Valid values: maxcompute, emr, cdh, hologres, analyticdb_for_pg.
    targets[].tableGuid String Table GUID in Data Map.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.
    eventCode String Extension event code.

    Batch delete monitors — the data payload:

    {
  "eventCode": "batch-delete-data-quality-evaluation-tasks",
  "ids": [10001, 10002],
  "projectId": 9***4,
  "tenantId": 28***656,
  "operator": "19***735",
  "operationTime": 1734505954897
}
    Field Type Description
    ids List\<Long\> List of monitor IDs to delete.
    projectId Long Workspace ID.
    tenantId Long Tenant ID.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.
    eventCode String Extension event code.

    Alert subscription pre-events (create, update, delete)

    Create or delete alert subscription — the data payload:

    {
  "eventCode": "create-data-quality-evaluation-task-notification",
  "dataQualityEvaluationTaskId": 10001,
  "channel": "sms",
  "receiverValue": "1107***38",
  "projectId": 30***03,
  "operator": "110***3538",
  "operationTime": 1734505954897
}
    Field Type Description
    dataQualityEvaluationTaskId Long Data quality monitor ID.
    channel String Notification channel type. Valid values: Mail (email), Sms (SMS), Phone (phone call), Feishu (Feishu), Weixin (WeChat), Dingding (DingTalk), Webhook (custom webhook).
    receiverValue String Notification target.
    projectId Long Workspace ID.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.
    eventCode String Extension event code.

    Update alert subscription — the data payload:

    {
  "eventCode": "update-data-quality-evaluation-task-notification",
  "dataQualityEvaluationTaskId": 10001,
  "currentChannel": "sms",
  "currentReceiverValue": "1107***538",
  "updatedChannel": "sms",
  "updatedReceiverValue": "1107***538",
  "projectId": 30***03,
  "operator": "110***3538",
  "operationTime": 1734505954897
}
    Field Type Description
    dataQualityEvaluationTaskId Long Data quality monitor ID.
    currentChannel String Current notification channel type before the update.
    currentReceiverValue String Current notification target before the update.
    updatedChannel String Updated notification channel type.
    updatedReceiverValue String Updated notification target.
    projectId Long Workspace ID.
    operator String UID of the user who performed the operation.
    operationTime Long Operation timestamp.
    eventCode String Extension event code.

    Tenant-level events

    Tenant-level events are generated by tenant-scoped modules, such as workspace deletion from the console.

    Console

    Events

    Event type Triggering operation Timing Regular event Extension point event EventBridge event type (type) Event code (eventCode)
    Workspace deletion Delete workspace Before operation - Yes dataworks:ProjectChange:DeleteProject delete-project
    Workspace deletion Workspace deleted After operation Yes - dataworks:ProjectChange:ProjectDeleted project-deleted

    Message formats

    Workspace deletion events

    The data payload:

    {
  "eventCode": "delete-project",
  "projectId": 7***7,
  "tenantId": 2807****0784,
  "operator": "19***735"
}
    Field Type Description
    operator String UID of the user who deleted the workspace.
    projectId Long Workspace ID to be deleted.
    tenantId Long Tenant ID of the workspace.
    eventCode String Extension event code.

    Workspace deleted event

    The data payload:

    {
  "eventCode": "project-deleted",
  "tenantId": 28***656,
  "blockBusiness": false,
  "projectName": "test2",
  "projectId": 9***4,
  "operator": "19***735",
  "timestamp": 1702260556896
}
    Field Type Description
    operator String UID of the user who deleted the workspace.
    projectId Long Deleted workspace ID.
    projectName String Deleted workspace name.
    tenantId Long Tenant ID.
    timestamp Long Message timestamp.
    eventCode String Extension event code.

    Upload and download

    Events

    Event type Triggering operation Timing Regular event Extension point event EventBridge event type (type) Event code (eventCode)
    Data download and upload Download data (file generation) Before operation - Yes dataworks:ResourcesDownload:DownloadResources download-resources
    Data download and upload Download data (file download) Before operation - Yes dataworks:ResourcesDownload:DownloadResourcesExecute download-resources-execute
    Data download and upload Upload data to table Before operation - Yes dataworks:ResourcesUpload:UploadDataToTable upload-data-to-table

    Message formats

    Data download pre-event (file generation)

    The data payload:

    {
  "eventCode": "download-resources",
  "moduleType": "sqlx_query",
  "operatorBaseId": "123936573******",
  "operatorUid": "14931896037*******",
  "fileName": "filename.csv",
  "fileSize": 10241024,
  "datasourceId": "1111",
  "datasourceName": "odps_first",
  "queryDwProjectId": "9***4",
  "queryDwProjectName": "test_project",
  "dataRowSize": "123456",
  "sqlText": "select sku_code, sku_name from dim_sku"
}
    Field Type Description
    moduleType String Download source. entity_transfer: data catalog. develop_query: Data Development (DataStudio) SQL query. sqlx_query: SQL query. dw_excel: spreadsheet download.
    operatorBaseId String Base ID of the user performing the download.
    operatorUid String UID of the user performing the download.
    fileName String Download file name.
    fileSize Long Download file size in bytes.
    datasourceId String Data source ID.
    datasourceName String Data source name.
    queryDwProjectId String Workspace ID.
    queryDwProjectName String Workspace identifier.
    dataRowSize Long Number of downloaded data rows.
    sqlText String SQL statement used to query and download the data.
    eventCode String Extension event code.

    Data download pre-event (file download)

    This event contains the same fields as the file generation event, plus:

    Field Type Description
    ip String IP address of the user who performed the download.

    Data upload pre-event

    The data payload:

    {
  "eventCode": "upload-data-to-table",
  "uploadSourceType": "LOCAL",
  "optTableType": "CREATE",
  "targetEngineType": "MAXCOMPUTE",
  "writeType": "OVERWRITE",
  "conflictMode": "IGNORE",
  "operatorBaseId": "12312*****",
  "operatorUid": "1222222*****",
  "datasourceId": "1111",
  "datasourceName": "odps_first",
  "tableGuid": "odps.mc_project.test_table",
  "queryDwProjectId": "9***4",
  "queryDwProjectName": "test_project",
  "fileSize": 123456
}
    Field Type Description
    uploadSourceType String Upload source. LOCAL: local file. OSS: OSS file. DW_EXCEL: DataWorks spreadsheet. HTTP: HTTP file.
    optTableType String Target table mode. CREATE: upload to a new table. IMPORT: upload to an existing table.
    targetEngineType String Target engine type. Valid values: MaxCompute, EMR Hive, Hologres.
    writeType String Write mode. OVERWRITE: replace existing data. APPEND: append to existing data.
    conflictMode String Primary key conflict resolution. IGNORE: skip conflicting rows. REPLACE: delete conflicting rows and insert new data (unspecified fields become NULL). UPDATE: overwrite only the specified fields in conflicting rows.
    operatorBaseId String Base ID of the user performing the upload.
    operatorUid String UID of the user performing the upload.
    datasourceId String Target data source ID.
    datasourceName String Target data source name.
    tableGuid String Table GUID. Examples: MaxCompute: odps.maxcomputeProject.tableName. EMR Hive: emr_hive.emrClusterId.schema.tableName. Hologres: holo.hologresInstanceId.database.
    queryDwProjectId String Workspace ID.
    queryDwProjectName String Workspace name.
    fileSize Long Upload file size in bytes.
    eventCode String Extension event code.

    Appendix: enum value reference

    schedulerType values

    Value Constant Description
    0 NORMAL Regular scheduled task. Runs on the daily schedule.
    1 MANUAL Manual task. Not included in daily scheduling.
    2 PAUSE Frozen task. Included in daily scheduling but immediately set to failed.
    3 SKIP Skip task. Included in daily scheduling but immediately set to succeeded.
    4 SKIP_UNCHOOSE Unselected task in a temporary workflow. Immediately set to succeeded.
    5 SKIP_CYCLE Weekly or monthly task not yet in its run cycle. Immediately set to succeeded.
    6 CONDITION_UNCHOOSE Downstream node not selected by a branch (IF) node. Set to skip.
    7 REALTIME_DEPRECATED Expired periodic instance generated in real time. Immediately set to succeeded.

    dagType values

    Value Description
    0 Periodic scheduled task
    1 Manual task
    2 Smoke test
    3 Data backfill
    4 Temporary workflow
    5 Manual workflow

    Instance status values

    Value Description
    1 Not running
    2 Waiting for scheduled time (dueTime or cycleTime)
    3 Waiting for resources
    4 Running
    5 Failed
    6 Succeeded
    7 Submitted to Data Quality for verification
    8 Checking branch conditions

    Cron expression reference

    DataWorks cron expressions follow standard cron syntax with these constraints:

    • Minimum scheduling interval: 5 minutes

    • Earliest daily scheduled time: 00:05

    Schedule Cron expression
    Daily at 5:30 AM 00 30 05 * * ?
    Every hour at minute 15 00 15 * * * ?
    Every 10 minutes 00 00/10 * * * ?
    8:00 AM–5:00 PM, every 10 minutes 00 00-59/10 8-17 * * * ?
    1st of each month at 00:20 00 20 00 1 * ?
    Every 3 months starting January 1 at 00:10 00 10 00 1 1-12/3 ?
    Every Tuesday and Friday at 00:05 00 05 00 * * 2,5