Queries runtime events of a data integration synchronization task, such as failovers, alerts, and DDL changes.
Operation description
This API operation is available for all DataWorks editions.
Try it now
Test
RAM authorization
Request parameters
|
Parameter |
Type |
Required |
Description |
Example |
| DIJobId |
integer |
No |
The ID of the synchronization task. |
11588 |
| EventType |
string |
Yes |
The type of event that you want to query. Valid values: Failover, Alarm, and DDL. |
Alarm |
| StartTime |
integer |
Yes |
The beginning of the time range to query. |
1716971005 |
| EndTime |
integer |
Yes |
The end of the time range to query. |
1717971005 |
| PageNumber |
integer |
No |
The page number. Pages start from page 1. Default value: 1. |
1 |
| PageSize |
integer |
No |
The number of entries per page. Default value: 10. Maximum value: 100. |
10 |
Response elements
|
Element |
Type |
Description |
Example |
|
object |
Schema of Response |
||
| RequestId |
string |
The request ID. You can locate logs and troubleshoot issues based on the ID. |
645F6D68-9C29-5961-80B1-BDD4B794C22D |
| PagingInfo |
object |
The pagination information. |
|
| TotalCount |
integer |
The total number of entries returned. |
2524 |
| PageSize |
integer |
The number of entries per page. |
10 |
| PageNumber |
integer |
The page number. |
1 |
| DIJobEvent |
array<object> |
The list of events. |
|
|
object |
The details of an event. |
||
| Id |
string |
The event ID. |
1 |
| CreateTime |
string |
The time when the event was created. |
1663573162 |
| FailoverMessage |
string |
The failover error logs. |
2024-05-29 15:11:31,377 [main] INFO com.*.**.di.core.metrics.:21 [] {****} 2024-05-29 15:11:31,384 [main] INFO *.aliyun.*.di.*.*.metrics.*:27 [] - Open MarioDiReporter 2024-05-29 15:11:33,248 [flink-akka.*.*-dispatcher-17] INFO |
| Severity |
string |
The severity level of the alert. Valid values: Warning and Critical. |
Warning |
| Channels |
string |
The alert notification method. Valid values: Phone, Mail, Sms, Ding, and Webhook. |
Phone |
| Status |
string |
The delivery status of an alert notification. Valid values: Success, Fail, and Silence. |
Success |
| Detail |
string |
The alert details. |
aggregator:avg [**] for 5 minutes, service maybe abnormal |
| Type |
string |
The alert event type.
|
Delay |
| Action |
string |
The processing result of the DDL event. Valid values: Critical, Ignore, Normal, and Warning. |
Ignore |
| SrcTable |
string |
The name of the source table. |
table1 |
| DstTable |
string |
The name of the destination table. |
table2 |
| SrcSql |
string |
The DDL statement of the source table. |
alter table table1 *** |
| DstSql |
string |
The DDL statement of the destination table. |
alter table table2 *** |
Examples
Success response
JSON format
{
"RequestId": "645F6D68-9C29-5961-80B1-BDD4****",
"PagingInfo": {
"TotalCount": 2524,
"PageSize": 10,
"PageNumber": 1,
"DIJobEvent": [
{
"Id": "1",
"CreateTime": "1663573162",
"FailoverMessage": "2024-05-29 15:11:31,377 [main] INFO com.*.**.di.core.metrics.:21 [] {****} \n2024-05-29 15:11:31,384 [main] INFO *.aliyun.*.di.*.*.metrics.*:27 [] - Open MarioDiReporter \n2024-05-29 15:11:33,248 [flink-akka.*.*-dispatcher-17] INFO ",
"Severity": "Warning",
"Channels": "Phone",
"Status": "Success",
"Detail": "Data integration synchronization task exception: Level: WARNING, DataWorks project name:** [Region: cn-shanghai], Task name:**, Alert rule: Business delay, aggregator:avg [**] for 5 minutes, service maybe abnormal",
"Type": "Delay",
"Action": "Ignore",
"SrcTable": "table1",
"DstTable": "table2",
"SrcSql": "alter table table1 ***",
"DstSql": "alter table table2 ***"
}
]
}
}Error codes
See Error Codes for a complete list.
Release notes
See Release Notes for a complete list.