DataWorks:GetDIJob

DataSourceName

String

mysql_datasource_1

The name of the data source.

DataSourceName

String

holo_datasource_1

The name of the data source.

RuleActionType

String

Rename

The type of the action. Valid values:

• DefinePrimaryKey

• Rename

• AddColumn

• HandleDml

• DefineIncrementalCondition

• DefineCycleScheduleSettings

• DefineRuntimeSettings

• DefinePartitionKey

RuleExpression

String

{"expression":"${srcDatasoureName}_${srcDatabaseName}"}

The expression of the rule. The expression is a JSON string.

Example of a renaming rule: {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}

expression: the expression of the renaming rule. The expression may contain the following variables: ${srcDatasourceName}, ${srcDatabaseName}, and ${srcTableName}. ${srcDatasourceName} indicates the name of the source. ${srcDatabaseName} indicates the name of a source database. ${srcTableName} indicates the name of a source table.

variables: the generation rule for a variable used in the expression of the renaming rule. The default value of the specified variable is the original value of the object indicated by the variable. A group of string replacement rules used to change the original values may be returned. variableName: the name of the variable. The variable name is not enclosed in ${}. variableRules: the string replacement rules for variables. The system runs the string replacement rules in sequence for string replacement. from indicates the original string. to indicates the new string.

Example of a rule used to add a specific field to the destination and assign a value to the field: {"columns":[{"columnName":"my_add_column","columnValueType":"Constant","columnValue":"123"}]}

If no rule of this type is configured, no fields are added to the destination and no values are assigned by default.

columnName: the name of the field that is added.

columnValueType: the type of the value of the field. Valid values: Constant and Variable.

columnValue: the value of the field that is added. If the valueType parameter is set to Constant, a constant of the STRING type is returned for the columnValue parameter. If the valueType parameter is set to Variable, a built-in variable is returned for the columnValue parameter. The following built-in variables are supported: EXECUTE_TIME (LONG data type), DB_NAME_SRC (STRING data type), DATASOURCE_NAME_SRC (STRING data type), TABLE_NAME_SRC (STRING data type), DB_NAME_DEST (STRING data type), DATASOURCE_NAME_DEST (STRING data type), TABLE_NAME_DEST (STRING data type), and DB_NAME_SRC_TRANSED (STRING data type). EXECUTE_TIME indicates the execution time. DB_NAME_SRC indicates the name of a source database. DATASOURCE_NAME_SRC indicates the name of the source. TABLE_NAME_SRC indicates the name of a source table. DB_NAME_DEST indicates the name of a destination database. DATASOURCE_NAME_DEST indicates the name of the destination. TABLE_NAME_DEST indicates the name of a destination table. DB_NAME_SRC_TRANSED indicates the database name obtained after a transformation.

Example of a rule used to specify primary key fields for a destination table: {"columns":["ukcolumn1","ukcolumn2"]}

If no rule of this type is configured, the primary key fields in the mapped source table are used for the destination table by default.

If the table generation method of the destination table is Use Existing Table, Data Integration does not modify the schema of the destination table. If the specified primary key fields do not exist in the destination table, an error is reported when the synchronization task starts to run.

If the table generation method of the destination table is Create Table, Data Integration automatically creates the schema of the destination table. The schema contains the primary key fields that you specify. If the specified primary key fields do not exist in the destination table, an error is reported when the synchronization task starts to run.

Example of a rule used to process DML messages: {"dmlPolicies":[{"dmlType":"Delete","dmlAction":"Filter","filterCondition":"id > 1"}]}

If no rule of this type is configured, the default processing policy for messages generated for insert, update, and delete operations is Normal.

dmlType: the DML operation. Valid values: Insert, Update, and Delete.

dmlAction: the processing policy for DML messages. Valid values: Normal, Ignore, Filter, and LogicalDelete. Filter indicates conditional processing. The value Filter is returned for the dmlAction parameter only when the dmlType parameter is set to Update or Delete.

filterCondition: the condition used to filter DML messages. This parameter is returned only when the dmlAction parameter is set to Filter.

RuleName

String

rename_rule_1

The name of the rule. If the values of the RuleActionType parameter and the RuleTargetType parameter are the same for multiple transformation rules, you must make sure that the transformation rule names are unique.

RuleTargetType

String

Table

The type of the object on which the action is performed. Valid values:

• Table

• Schema

ChannelSettings

String

{"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""}

The channel control settings for the synchronization task. The value of this parameter is a JSON string.

String

StructureMigrationTotalTables

The detailed statistics on the running of the synchronization task.

• StructureMigrationTotalTables: the total number of tables whose schemas need to be migrated

• StructureMigrationSuccessTables: the number of tables whose schemas are successfully migrated

• StructureMigrationFailedTables: the number of tables whose schemas fail to be migrated

• StructureMigrationStatus: the status of schema migration. Valid values: Waiting, Running, Finished, Failed, and Stopped

• StructureMigrationErrorMessage: the error message returned for schema migration

• FullMigrationTotalTables: the total number of tables whose full data needs to be synchronized

• FullMigrationSuccessTables: the number of tables whose full data is successfully synchronized

• FullMigrationFailedTables: the number of tables whose full data fails to be synchronized

• FullMigrationStatus: the status of full synchronization

• FullMigrationErrorMessage: the error message returned for full synchronization

• RealtimeMigrationMaxDelay: the latency of real-time synchronization. Unit: milliseconds

• RealtimeMigrationStatus: the status of real-time synchronization

• RealtimeMigrationErrorMessage: the error message returned for real-time synchronization