DataWorks:CreateDIJob

The name of the data source.

The properties of the data source.

The name of the data source.

The number of compute units (CUs) in the resource group for Data Integration that are used for batch synchronization.

The identifier of the resource group for Data Integration used for batch synchronization.

The number of CUs in the resource group for Data Integration that are used for real-time synchronization.

The identifier of the resource group for Data Integration used for real-time synchronization.

The number of CUs in the resource group for scheduling that are used for batch synchronization.

The identifier of the resource group for scheduling used for batch synchronization.

The action type. Valid values:

• DefinePrimaryKey
• Rename
• AddColumn
• HandleDml
• DefineIncrementalCondition
• DefineCycleScheduleSettings
• DefineRuntimeSettings
• DefinePartitionKey

The expression of the rule. The expression must be 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. You can use the following variables in an expression: ${srcDatasourceName}, ${srcDatabaseName}, and ${srcTableName}. ${srcDatasourceName} specifies the name of the source. ${srcDatabaseName} specifies the name of a source database. ${srcTableName} specifies 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. You can define a group of string replacement rules to change the original values based on your business requirements. variableName: the name of the variable. The variable name cannot be enclosed in ${}. variableRules: the string replacement rules for variables. The system runs the string replacement rules in sequence. from specifies the original string. to specifies 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 you do not configure such a rule, no fields are added to the destination and no values are assigned by default.
• columnName: the name of the field that you want to add.
• columnValueType: the value type of the field. Valid values: Constant and Variable.
• columnValue: the value of the field. If you set the valueType parameter to Constant, set the columnValue parameter to a custom constant of the STRING type. If you set the valueType parameter to Variable, set the columnValue to a built-in variable. 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 specifies the execution time. DB_NAME_SRC specifies the name of a source database. DATASOURCE_NAME_SRC specifies the name of the source. TABLE_NAME_SRC specifies the name of a source table. DB_NAME_DEST specifies the name of a destination database. DATASOURCE_NAME_DEST specifies the name of the destination. TABLE_NAME_DEST specifies the name of a destination table. DB_NAME_SRC_TRANSED specifies 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 you do not configure such a rule, the primary key fields in the mapped source table are used for the destination table by default.
• If the destination table is an 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 destination table is automatically created by the system, 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 you do not configure such a rule, 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. You can set the dmlAction parameter to Filter only when the dmlType parameter is set to Update or Delete.
• filterCondition: the condition used to filter DML messages. This parameter is required only when the dmlAction parameter is set to Filter.

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.

The type of the object on which you want to perform the action. Valid values:

• Table
• Schema

The list of rules used to select synchronization objects in the source. The objects can be databases or tables.

The list of transformation rules that you want to apply to the synchronization objects selected from the source. Each entry in the list defines a transformation rule.

The data type mapping between a source field and a destination field.

The synchronization type that requires periodic scheduling. Valid values:

• Full: full synchronization
• OfflineIncremental: batch incremental synchronization

The scheduling parameters.

The processing setting for a specific type of DDL message.