alicloud.dataworks.DiJob
Explore with Pulumi AI
Provides a Data Works Di Job resource.
Data Integration Tasks.
For information about Data Works Di Job and how to use it, see What is Di Job.
NOTE: Available since v1.241.0.
Example Usage
Basic Usage
import * as pulumi from "@pulumi/pulumi";
import * as alicloud from "@pulumi/alicloud";
const config = new pulumi.Config();
const name = config.get("name") || "terraform-example";
const defaultMMHL8U = new alicloud.dataworks.Project("defaultMMHL8U", {
description: name,
projectName: name,
displayName: name,
});
const _default = new alicloud.dataworks.DiJob("default", {
description: name,
projectId: defaultMMHL8U.id,
jobName: "zhenyuan_example_case",
migrationType: "api_FullAndRealtimeIncremental",
sourceDataSourceSettings: [{
dataSourceName: "dw_mysql",
dataSourceProperties: {
encoding: "utf-8",
timezone: "Asia/Shanghai",
},
}],
destinationDataSourceType: "Hologres",
tableMappings: [{
sourceObjectSelectionRules: [
{
action: "Include",
expression: "dw_mysql",
expressionType: "Exact",
objectType: "Datasource",
},
{
action: "Include",
expression: "example_db1",
expressionType: "Exact",
objectType: "Database",
},
{
action: "Include",
expression: "lsc_example01",
expressionType: "Exact",
objectType: "Table",
},
],
transformationRules: [{
ruleName: "my_table_rename_rule",
ruleActionType: "Rename",
ruleTargetType: "Table",
}],
}],
sourceDataSourceType: "MySQL",
resourceSettings: {
offlineResourceSettings: {
requestedCu: 2,
resourceGroupIdentifier: "S_res_group_524257424564736_1716799673667",
},
realtimeResourceSettings: {
requestedCu: 2,
resourceGroupIdentifier: "S_res_group_524257424564736_1716799673667",
},
scheduleResourceSettings: {
requestedCu: 2,
resourceGroupIdentifier: "S_res_group_524257424564736_1716799673667",
},
},
transformationRules: [{
ruleActionType: "Rename",
ruleExpression: "{\"expression\":\"table2\"}",
ruleName: "my_table_rename_rule",
ruleTargetType: "Table",
}],
destinationDataSourceSettings: [{
dataSourceName: "dw_example_holo",
}],
jobSettings: {
columnDataTypeSettings: [{
destinationDataType: "bigint",
sourceDataType: "longtext",
}],
ddlHandlingSettings: [{
action: "Ignore",
type: "CreateTable",
}],
runtimeSettings: [{
name: "runtime.realtime.concurrent",
value: "1",
}],
channelSettings: "1",
cycleScheduleSettings: {
cycleMigrationType: "2",
scheduleParameters: "3",
},
},
});
import pulumi
import pulumi_alicloud as alicloud
config = pulumi.Config()
name = config.get("name")
if name is None:
name = "terraform-example"
default_mmhl8_u = alicloud.dataworks.Project("defaultMMHL8U",
description=name,
project_name=name,
display_name=name)
default = alicloud.dataworks.DiJob("default",
description=name,
project_id=default_mmhl8_u.id,
job_name="zhenyuan_example_case",
migration_type="api_FullAndRealtimeIncremental",
source_data_source_settings=[{
"data_source_name": "dw_mysql",
"data_source_properties": {
"encoding": "utf-8",
"timezone": "Asia/Shanghai",
},
}],
destination_data_source_type="Hologres",
table_mappings=[{
"source_object_selection_rules": [
{
"action": "Include",
"expression": "dw_mysql",
"expression_type": "Exact",
"object_type": "Datasource",
},
{
"action": "Include",
"expression": "example_db1",
"expression_type": "Exact",
"object_type": "Database",
},
{
"action": "Include",
"expression": "lsc_example01",
"expression_type": "Exact",
"object_type": "Table",
},
],
"transformation_rules": [{
"rule_name": "my_table_rename_rule",
"rule_action_type": "Rename",
"rule_target_type": "Table",
}],
}],
source_data_source_type="MySQL",
resource_settings={
"offline_resource_settings": {
"requested_cu": 2,
"resource_group_identifier": "S_res_group_524257424564736_1716799673667",
},
"realtime_resource_settings": {
"requested_cu": 2,
"resource_group_identifier": "S_res_group_524257424564736_1716799673667",
},
"schedule_resource_settings": {
"requested_cu": 2,
"resource_group_identifier": "S_res_group_524257424564736_1716799673667",
},
},
transformation_rules=[{
"rule_action_type": "Rename",
"rule_expression": "{\"expression\":\"table2\"}",
"rule_name": "my_table_rename_rule",
"rule_target_type": "Table",
}],
destination_data_source_settings=[{
"data_source_name": "dw_example_holo",
}],
job_settings={
"column_data_type_settings": [{
"destination_data_type": "bigint",
"source_data_type": "longtext",
}],
"ddl_handling_settings": [{
"action": "Ignore",
"type": "CreateTable",
}],
"runtime_settings": [{
"name": "runtime.realtime.concurrent",
"value": "1",
}],
"channel_settings": "1",
"cycle_schedule_settings": {
"cycle_migration_type": "2",
"schedule_parameters": "3",
},
})
package main
import (
"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/dataworks"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
cfg := config.New(ctx, "")
name := "terraform-example"
if param := cfg.Get("name"); param != "" {
name = param
}
defaultMMHL8U, err := dataworks.NewProject(ctx, "defaultMMHL8U", &dataworks.ProjectArgs{
Description: pulumi.String(name),
ProjectName: pulumi.String(name),
DisplayName: pulumi.String(name),
})
if err != nil {
return err
}
_, err = dataworks.NewDiJob(ctx, "default", &dataworks.DiJobArgs{
Description: pulumi.String(name),
ProjectId: defaultMMHL8U.ID(),
JobName: pulumi.String("zhenyuan_example_case"),
MigrationType: pulumi.String("api_FullAndRealtimeIncremental"),
SourceDataSourceSettings: dataworks.DiJobSourceDataSourceSettingArray{
&dataworks.DiJobSourceDataSourceSettingArgs{
DataSourceName: pulumi.String("dw_mysql"),
DataSourceProperties: &dataworks.DiJobSourceDataSourceSettingDataSourcePropertiesArgs{
Encoding: pulumi.String("utf-8"),
Timezone: pulumi.String("Asia/Shanghai"),
},
},
},
DestinationDataSourceType: pulumi.String("Hologres"),
TableMappings: dataworks.DiJobTableMappingArray{
&dataworks.DiJobTableMappingArgs{
SourceObjectSelectionRules: dataworks.DiJobTableMappingSourceObjectSelectionRuleArray{
&dataworks.DiJobTableMappingSourceObjectSelectionRuleArgs{
Action: pulumi.String("Include"),
Expression: pulumi.String("dw_mysql"),
ExpressionType: pulumi.String("Exact"),
ObjectType: pulumi.String("Datasource"),
},
&dataworks.DiJobTableMappingSourceObjectSelectionRuleArgs{
Action: pulumi.String("Include"),
Expression: pulumi.String("example_db1"),
ExpressionType: pulumi.String("Exact"),
ObjectType: pulumi.String("Database"),
},
&dataworks.DiJobTableMappingSourceObjectSelectionRuleArgs{
Action: pulumi.String("Include"),
Expression: pulumi.String("lsc_example01"),
ExpressionType: pulumi.String("Exact"),
ObjectType: pulumi.String("Table"),
},
},
TransformationRules: dataworks.DiJobTableMappingTransformationRuleArray{
&dataworks.DiJobTableMappingTransformationRuleArgs{
RuleName: pulumi.String("my_table_rename_rule"),
RuleActionType: pulumi.String("Rename"),
RuleTargetType: pulumi.String("Table"),
},
},
},
},
SourceDataSourceType: pulumi.String("MySQL"),
ResourceSettings: &dataworks.DiJobResourceSettingsArgs{
OfflineResourceSettings: &dataworks.DiJobResourceSettingsOfflineResourceSettingsArgs{
RequestedCu: pulumi.Float64(2),
ResourceGroupIdentifier: pulumi.String("S_res_group_524257424564736_1716799673667"),
},
RealtimeResourceSettings: &dataworks.DiJobResourceSettingsRealtimeResourceSettingsArgs{
RequestedCu: pulumi.Float64(2),
ResourceGroupIdentifier: pulumi.String("S_res_group_524257424564736_1716799673667"),
},
ScheduleResourceSettings: &dataworks.DiJobResourceSettingsScheduleResourceSettingsArgs{
RequestedCu: pulumi.Float64(2),
ResourceGroupIdentifier: pulumi.String("S_res_group_524257424564736_1716799673667"),
},
},
TransformationRules: dataworks.DiJobTransformationRuleArray{
&dataworks.DiJobTransformationRuleArgs{
RuleActionType: pulumi.String("Rename"),
RuleExpression: pulumi.String("{\"expression\":\"table2\"}"),
RuleName: pulumi.String("my_table_rename_rule"),
RuleTargetType: pulumi.String("Table"),
},
},
DestinationDataSourceSettings: dataworks.DiJobDestinationDataSourceSettingArray{
&dataworks.DiJobDestinationDataSourceSettingArgs{
DataSourceName: pulumi.String("dw_example_holo"),
},
},
JobSettings: &dataworks.DiJobJobSettingsArgs{
ColumnDataTypeSettings: dataworks.DiJobJobSettingsColumnDataTypeSettingArray{
&dataworks.DiJobJobSettingsColumnDataTypeSettingArgs{
DestinationDataType: pulumi.String("bigint"),
SourceDataType: pulumi.String("longtext"),
},
},
DdlHandlingSettings: dataworks.DiJobJobSettingsDdlHandlingSettingArray{
&dataworks.DiJobJobSettingsDdlHandlingSettingArgs{
Action: pulumi.String("Ignore"),
Type: pulumi.String("CreateTable"),
},
},
RuntimeSettings: dataworks.DiJobJobSettingsRuntimeSettingArray{
&dataworks.DiJobJobSettingsRuntimeSettingArgs{
Name: pulumi.String("runtime.realtime.concurrent"),
Value: pulumi.String("1"),
},
},
ChannelSettings: pulumi.String("1"),
CycleScheduleSettings: &dataworks.DiJobJobSettingsCycleScheduleSettingsArgs{
CycleMigrationType: pulumi.String("2"),
ScheduleParameters: pulumi.String("3"),
},
},
})
if err != nil {
return err
}
return nil
})
}
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AliCloud = Pulumi.AliCloud;
return await Deployment.RunAsync(() =>
{
var config = new Config();
var name = config.Get("name") ?? "terraform-example";
var defaultMMHL8U = new AliCloud.DataWorks.Project("defaultMMHL8U", new()
{
Description = name,
ProjectName = name,
DisplayName = name,
});
var @default = new AliCloud.DataWorks.DiJob("default", new()
{
Description = name,
ProjectId = defaultMMHL8U.Id,
JobName = "zhenyuan_example_case",
MigrationType = "api_FullAndRealtimeIncremental",
SourceDataSourceSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobSourceDataSourceSettingArgs
{
DataSourceName = "dw_mysql",
DataSourceProperties = new AliCloud.DataWorks.Inputs.DiJobSourceDataSourceSettingDataSourcePropertiesArgs
{
Encoding = "utf-8",
Timezone = "Asia/Shanghai",
},
},
},
DestinationDataSourceType = "Hologres",
TableMappings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobTableMappingArgs
{
SourceObjectSelectionRules = new[]
{
new AliCloud.DataWorks.Inputs.DiJobTableMappingSourceObjectSelectionRuleArgs
{
Action = "Include",
Expression = "dw_mysql",
ExpressionType = "Exact",
ObjectType = "Datasource",
},
new AliCloud.DataWorks.Inputs.DiJobTableMappingSourceObjectSelectionRuleArgs
{
Action = "Include",
Expression = "example_db1",
ExpressionType = "Exact",
ObjectType = "Database",
},
new AliCloud.DataWorks.Inputs.DiJobTableMappingSourceObjectSelectionRuleArgs
{
Action = "Include",
Expression = "lsc_example01",
ExpressionType = "Exact",
ObjectType = "Table",
},
},
TransformationRules = new[]
{
new AliCloud.DataWorks.Inputs.DiJobTableMappingTransformationRuleArgs
{
RuleName = "my_table_rename_rule",
RuleActionType = "Rename",
RuleTargetType = "Table",
},
},
},
},
SourceDataSourceType = "MySQL",
ResourceSettings = new AliCloud.DataWorks.Inputs.DiJobResourceSettingsArgs
{
OfflineResourceSettings = new AliCloud.DataWorks.Inputs.DiJobResourceSettingsOfflineResourceSettingsArgs
{
RequestedCu = 2,
ResourceGroupIdentifier = "S_res_group_524257424564736_1716799673667",
},
RealtimeResourceSettings = new AliCloud.DataWorks.Inputs.DiJobResourceSettingsRealtimeResourceSettingsArgs
{
RequestedCu = 2,
ResourceGroupIdentifier = "S_res_group_524257424564736_1716799673667",
},
ScheduleResourceSettings = new AliCloud.DataWorks.Inputs.DiJobResourceSettingsScheduleResourceSettingsArgs
{
RequestedCu = 2,
ResourceGroupIdentifier = "S_res_group_524257424564736_1716799673667",
},
},
TransformationRules = new[]
{
new AliCloud.DataWorks.Inputs.DiJobTransformationRuleArgs
{
RuleActionType = "Rename",
RuleExpression = "{\"expression\":\"table2\"}",
RuleName = "my_table_rename_rule",
RuleTargetType = "Table",
},
},
DestinationDataSourceSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobDestinationDataSourceSettingArgs
{
DataSourceName = "dw_example_holo",
},
},
JobSettings = new AliCloud.DataWorks.Inputs.DiJobJobSettingsArgs
{
ColumnDataTypeSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobJobSettingsColumnDataTypeSettingArgs
{
DestinationDataType = "bigint",
SourceDataType = "longtext",
},
},
DdlHandlingSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobJobSettingsDdlHandlingSettingArgs
{
Action = "Ignore",
Type = "CreateTable",
},
},
RuntimeSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobJobSettingsRuntimeSettingArgs
{
Name = "runtime.realtime.concurrent",
Value = "1",
},
},
ChannelSettings = "1",
CycleScheduleSettings = new AliCloud.DataWorks.Inputs.DiJobJobSettingsCycleScheduleSettingsArgs
{
CycleMigrationType = "2",
ScheduleParameters = "3",
},
},
});
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.dataworks.Project;
import com.pulumi.alicloud.dataworks.ProjectArgs;
import com.pulumi.alicloud.dataworks.DiJob;
import com.pulumi.alicloud.dataworks.DiJobArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobSourceDataSourceSettingArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobSourceDataSourceSettingDataSourcePropertiesArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobTableMappingArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobResourceSettingsArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobResourceSettingsOfflineResourceSettingsArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobResourceSettingsRealtimeResourceSettingsArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobResourceSettingsScheduleResourceSettingsArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobTransformationRuleArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobDestinationDataSourceSettingArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobJobSettingsArgs;
import com.pulumi.alicloud.dataworks.inputs.DiJobJobSettingsCycleScheduleSettingsArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
final var config = ctx.config();
final var name = config.get("name").orElse("terraform-example");
var defaultMMHL8U = new Project("defaultMMHL8U", ProjectArgs.builder()
.description(name)
.projectName(name)
.displayName(name)
.build());
var default_ = new DiJob("default", DiJobArgs.builder()
.description(name)
.projectId(defaultMMHL8U.id())
.jobName("zhenyuan_example_case")
.migrationType("api_FullAndRealtimeIncremental")
.sourceDataSourceSettings(DiJobSourceDataSourceSettingArgs.builder()
.dataSourceName("dw_mysql")
.dataSourceProperties(DiJobSourceDataSourceSettingDataSourcePropertiesArgs.builder()
.encoding("utf-8")
.timezone("Asia/Shanghai")
.build())
.build())
.destinationDataSourceType("Hologres")
.tableMappings(DiJobTableMappingArgs.builder()
.sourceObjectSelectionRules(
DiJobTableMappingSourceObjectSelectionRuleArgs.builder()
.action("Include")
.expression("dw_mysql")
.expressionType("Exact")
.objectType("Datasource")
.build(),
DiJobTableMappingSourceObjectSelectionRuleArgs.builder()
.action("Include")
.expression("example_db1")
.expressionType("Exact")
.objectType("Database")
.build(),
DiJobTableMappingSourceObjectSelectionRuleArgs.builder()
.action("Include")
.expression("lsc_example01")
.expressionType("Exact")
.objectType("Table")
.build())
.transformationRules(DiJobTableMappingTransformationRuleArgs.builder()
.ruleName("my_table_rename_rule")
.ruleActionType("Rename")
.ruleTargetType("Table")
.build())
.build())
.sourceDataSourceType("MySQL")
.resourceSettings(DiJobResourceSettingsArgs.builder()
.offlineResourceSettings(DiJobResourceSettingsOfflineResourceSettingsArgs.builder()
.requestedCu(2)
.resourceGroupIdentifier("S_res_group_524257424564736_1716799673667")
.build())
.realtimeResourceSettings(DiJobResourceSettingsRealtimeResourceSettingsArgs.builder()
.requestedCu(2)
.resourceGroupIdentifier("S_res_group_524257424564736_1716799673667")
.build())
.scheduleResourceSettings(DiJobResourceSettingsScheduleResourceSettingsArgs.builder()
.requestedCu(2)
.resourceGroupIdentifier("S_res_group_524257424564736_1716799673667")
.build())
.build())
.transformationRules(DiJobTransformationRuleArgs.builder()
.ruleActionType("Rename")
.ruleExpression("{\"expression\":\"table2\"}")
.ruleName("my_table_rename_rule")
.ruleTargetType("Table")
.build())
.destinationDataSourceSettings(DiJobDestinationDataSourceSettingArgs.builder()
.dataSourceName("dw_example_holo")
.build())
.jobSettings(DiJobJobSettingsArgs.builder()
.columnDataTypeSettings(DiJobJobSettingsColumnDataTypeSettingArgs.builder()
.destinationDataType("bigint")
.sourceDataType("longtext")
.build())
.ddlHandlingSettings(DiJobJobSettingsDdlHandlingSettingArgs.builder()
.action("Ignore")
.type("CreateTable")
.build())
.runtimeSettings(DiJobJobSettingsRuntimeSettingArgs.builder()
.name("runtime.realtime.concurrent")
.value("1")
.build())
.channelSettings("1")
.cycleScheduleSettings(DiJobJobSettingsCycleScheduleSettingsArgs.builder()
.cycleMigrationType("2")
.scheduleParameters("3")
.build())
.build())
.build());
}
}
configuration:
name:
type: string
default: terraform-example
resources:
defaultMMHL8U:
type: alicloud:dataworks:Project
properties:
description: ${name}
projectName: ${name}
displayName: ${name}
default:
type: alicloud:dataworks:DiJob
properties:
description: ${name}
projectId: ${defaultMMHL8U.id}
jobName: zhenyuan_example_case
migrationType: api_FullAndRealtimeIncremental
sourceDataSourceSettings:
- dataSourceName: dw_mysql
dataSourceProperties:
encoding: utf-8
timezone: Asia/Shanghai
destinationDataSourceType: Hologres
tableMappings:
- sourceObjectSelectionRules:
- action: Include
expression: dw_mysql
expressionType: Exact
objectType: Datasource
- action: Include
expression: example_db1
expressionType: Exact
objectType: Database
- action: Include
expression: lsc_example01
expressionType: Exact
objectType: Table
transformationRules:
- ruleName: my_table_rename_rule
ruleActionType: Rename
ruleTargetType: Table
sourceDataSourceType: MySQL
resourceSettings:
offlineResourceSettings:
requestedCu: 2
resourceGroupIdentifier: S_res_group_524257424564736_1716799673667
realtimeResourceSettings:
requestedCu: 2
resourceGroupIdentifier: S_res_group_524257424564736_1716799673667
scheduleResourceSettings:
requestedCu: 2
resourceGroupIdentifier: S_res_group_524257424564736_1716799673667
transformationRules:
- ruleActionType: Rename
ruleExpression: '{"expression":"table2"}'
ruleName: my_table_rename_rule
ruleTargetType: Table
destinationDataSourceSettings:
- dataSourceName: dw_example_holo
jobSettings:
columnDataTypeSettings:
- destinationDataType: bigint
sourceDataType: longtext
ddlHandlingSettings:
- action: Ignore
type: CreateTable
runtimeSettings:
- name: runtime.realtime.concurrent
value: '1'
channelSettings: '1'
cycleScheduleSettings:
cycleMigrationType: '2'
scheduleParameters: '3'
Create DiJob Resource
Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.
Constructor syntax
new DiJob(name: string, args: DiJobArgs, opts?: CustomResourceOptions);
@overload
def DiJob(resource_name: str,
args: DiJobArgs,
opts: Optional[ResourceOptions] = None)
@overload
def DiJob(resource_name: str,
opts: Optional[ResourceOptions] = None,
destination_data_source_settings: Optional[Sequence[DiJobDestinationDataSourceSettingArgs]] = None,
destination_data_source_type: Optional[str] = None,
job_name: Optional[str] = None,
migration_type: Optional[str] = None,
resource_settings: Optional[DiJobResourceSettingsArgs] = None,
source_data_source_settings: Optional[Sequence[DiJobSourceDataSourceSettingArgs]] = None,
source_data_source_type: Optional[str] = None,
table_mappings: Optional[Sequence[DiJobTableMappingArgs]] = None,
description: Optional[str] = None,
job_settings: Optional[DiJobJobSettingsArgs] = None,
project_id: Optional[int] = None,
transformation_rules: Optional[Sequence[DiJobTransformationRuleArgs]] = None)
func NewDiJob(ctx *Context, name string, args DiJobArgs, opts ...ResourceOption) (*DiJob, error)
public DiJob(string name, DiJobArgs args, CustomResourceOptions? opts = null)
type: alicloud:dataworks:DiJob
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.
Parameters
- name string
- The unique name of the resource.
- args DiJobArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- resource_name str
- The unique name of the resource.
- args DiJobArgs
- The arguments to resource properties.
- opts ResourceOptions
- Bag of options to control resource's behavior.
- ctx Context
- Context object for the current deployment.
- name string
- The unique name of the resource.
- args DiJobArgs
- The arguments to resource properties.
- opts ResourceOption
- Bag of options to control resource's behavior.
- name string
- The unique name of the resource.
- args DiJobArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- name String
- The unique name of the resource.
- args DiJobArgs
- The arguments to resource properties.
- options CustomResourceOptions
- Bag of options to control resource's behavior.
Constructor example
The following reference example uses placeholder values for all input properties.
var diJobResource = new AliCloud.DataWorks.DiJob("diJobResource", new()
{
DestinationDataSourceSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobDestinationDataSourceSettingArgs
{
DataSourceName = "string",
},
},
DestinationDataSourceType = "string",
JobName = "string",
MigrationType = "string",
ResourceSettings = new AliCloud.DataWorks.Inputs.DiJobResourceSettingsArgs
{
OfflineResourceSettings = new AliCloud.DataWorks.Inputs.DiJobResourceSettingsOfflineResourceSettingsArgs
{
RequestedCu = 0,
ResourceGroupIdentifier = "string",
},
RealtimeResourceSettings = new AliCloud.DataWorks.Inputs.DiJobResourceSettingsRealtimeResourceSettingsArgs
{
RequestedCu = 0,
ResourceGroupIdentifier = "string",
},
ScheduleResourceSettings = new AliCloud.DataWorks.Inputs.DiJobResourceSettingsScheduleResourceSettingsArgs
{
RequestedCu = 0,
ResourceGroupIdentifier = "string",
},
},
SourceDataSourceSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobSourceDataSourceSettingArgs
{
DataSourceName = "string",
DataSourceProperties = new AliCloud.DataWorks.Inputs.DiJobSourceDataSourceSettingDataSourcePropertiesArgs
{
Encoding = "string",
Timezone = "string",
},
},
},
SourceDataSourceType = "string",
TableMappings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobTableMappingArgs
{
SourceObjectSelectionRules = new[]
{
new AliCloud.DataWorks.Inputs.DiJobTableMappingSourceObjectSelectionRuleArgs
{
Action = "string",
Expression = "string",
ExpressionType = "string",
ObjectType = "string",
},
},
TransformationRules = new[]
{
new AliCloud.DataWorks.Inputs.DiJobTableMappingTransformationRuleArgs
{
RuleActionType = "string",
RuleName = "string",
RuleTargetType = "string",
},
},
},
},
Description = "string",
JobSettings = new AliCloud.DataWorks.Inputs.DiJobJobSettingsArgs
{
ChannelSettings = "string",
ColumnDataTypeSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobJobSettingsColumnDataTypeSettingArgs
{
DestinationDataType = "string",
SourceDataType = "string",
},
},
CycleScheduleSettings = new AliCloud.DataWorks.Inputs.DiJobJobSettingsCycleScheduleSettingsArgs
{
CycleMigrationType = "string",
ScheduleParameters = "string",
},
DdlHandlingSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobJobSettingsDdlHandlingSettingArgs
{
Action = "string",
Type = "string",
},
},
RuntimeSettings = new[]
{
new AliCloud.DataWorks.Inputs.DiJobJobSettingsRuntimeSettingArgs
{
Name = "string",
Value = "string",
},
},
},
ProjectId = 0,
TransformationRules = new[]
{
new AliCloud.DataWorks.Inputs.DiJobTransformationRuleArgs
{
RuleActionType = "string",
RuleExpression = "string",
RuleName = "string",
RuleTargetType = "string",
},
},
});
example, err := dataworks.NewDiJob(ctx, "diJobResource", &dataworks.DiJobArgs{
DestinationDataSourceSettings: dataworks.DiJobDestinationDataSourceSettingArray{
&dataworks.DiJobDestinationDataSourceSettingArgs{
DataSourceName: pulumi.String("string"),
},
},
DestinationDataSourceType: pulumi.String("string"),
JobName: pulumi.String("string"),
MigrationType: pulumi.String("string"),
ResourceSettings: &dataworks.DiJobResourceSettingsArgs{
OfflineResourceSettings: &dataworks.DiJobResourceSettingsOfflineResourceSettingsArgs{
RequestedCu: pulumi.Float64(0),
ResourceGroupIdentifier: pulumi.String("string"),
},
RealtimeResourceSettings: &dataworks.DiJobResourceSettingsRealtimeResourceSettingsArgs{
RequestedCu: pulumi.Float64(0),
ResourceGroupIdentifier: pulumi.String("string"),
},
ScheduleResourceSettings: &dataworks.DiJobResourceSettingsScheduleResourceSettingsArgs{
RequestedCu: pulumi.Float64(0),
ResourceGroupIdentifier: pulumi.String("string"),
},
},
SourceDataSourceSettings: dataworks.DiJobSourceDataSourceSettingArray{
&dataworks.DiJobSourceDataSourceSettingArgs{
DataSourceName: pulumi.String("string"),
DataSourceProperties: &dataworks.DiJobSourceDataSourceSettingDataSourcePropertiesArgs{
Encoding: pulumi.String("string"),
Timezone: pulumi.String("string"),
},
},
},
SourceDataSourceType: pulumi.String("string"),
TableMappings: dataworks.DiJobTableMappingArray{
&dataworks.DiJobTableMappingArgs{
SourceObjectSelectionRules: dataworks.DiJobTableMappingSourceObjectSelectionRuleArray{
&dataworks.DiJobTableMappingSourceObjectSelectionRuleArgs{
Action: pulumi.String("string"),
Expression: pulumi.String("string"),
ExpressionType: pulumi.String("string"),
ObjectType: pulumi.String("string"),
},
},
TransformationRules: dataworks.DiJobTableMappingTransformationRuleArray{
&dataworks.DiJobTableMappingTransformationRuleArgs{
RuleActionType: pulumi.String("string"),
RuleName: pulumi.String("string"),
RuleTargetType: pulumi.String("string"),
},
},
},
},
Description: pulumi.String("string"),
JobSettings: &dataworks.DiJobJobSettingsArgs{
ChannelSettings: pulumi.String("string"),
ColumnDataTypeSettings: dataworks.DiJobJobSettingsColumnDataTypeSettingArray{
&dataworks.DiJobJobSettingsColumnDataTypeSettingArgs{
DestinationDataType: pulumi.String("string"),
SourceDataType: pulumi.String("string"),
},
},
CycleScheduleSettings: &dataworks.DiJobJobSettingsCycleScheduleSettingsArgs{
CycleMigrationType: pulumi.String("string"),
ScheduleParameters: pulumi.String("string"),
},
DdlHandlingSettings: dataworks.DiJobJobSettingsDdlHandlingSettingArray{
&dataworks.DiJobJobSettingsDdlHandlingSettingArgs{
Action: pulumi.String("string"),
Type: pulumi.String("string"),
},
},
RuntimeSettings: dataworks.DiJobJobSettingsRuntimeSettingArray{
&dataworks.DiJobJobSettingsRuntimeSettingArgs{
Name: pulumi.String("string"),
Value: pulumi.String("string"),
},
},
},
ProjectId: pulumi.Int(0),
TransformationRules: dataworks.DiJobTransformationRuleArray{
&dataworks.DiJobTransformationRuleArgs{
RuleActionType: pulumi.String("string"),
RuleExpression: pulumi.String("string"),
RuleName: pulumi.String("string"),
RuleTargetType: pulumi.String("string"),
},
},
})
var diJobResource = new DiJob("diJobResource", DiJobArgs.builder()
.destinationDataSourceSettings(DiJobDestinationDataSourceSettingArgs.builder()
.dataSourceName("string")
.build())
.destinationDataSourceType("string")
.jobName("string")
.migrationType("string")
.resourceSettings(DiJobResourceSettingsArgs.builder()
.offlineResourceSettings(DiJobResourceSettingsOfflineResourceSettingsArgs.builder()
.requestedCu(0)
.resourceGroupIdentifier("string")
.build())
.realtimeResourceSettings(DiJobResourceSettingsRealtimeResourceSettingsArgs.builder()
.requestedCu(0)
.resourceGroupIdentifier("string")
.build())
.scheduleResourceSettings(DiJobResourceSettingsScheduleResourceSettingsArgs.builder()
.requestedCu(0)
.resourceGroupIdentifier("string")
.build())
.build())
.sourceDataSourceSettings(DiJobSourceDataSourceSettingArgs.builder()
.dataSourceName("string")
.dataSourceProperties(DiJobSourceDataSourceSettingDataSourcePropertiesArgs.builder()
.encoding("string")
.timezone("string")
.build())
.build())
.sourceDataSourceType("string")
.tableMappings(DiJobTableMappingArgs.builder()
.sourceObjectSelectionRules(DiJobTableMappingSourceObjectSelectionRuleArgs.builder()
.action("string")
.expression("string")
.expressionType("string")
.objectType("string")
.build())
.transformationRules(DiJobTableMappingTransformationRuleArgs.builder()
.ruleActionType("string")
.ruleName("string")
.ruleTargetType("string")
.build())
.build())
.description("string")
.jobSettings(DiJobJobSettingsArgs.builder()
.channelSettings("string")
.columnDataTypeSettings(DiJobJobSettingsColumnDataTypeSettingArgs.builder()
.destinationDataType("string")
.sourceDataType("string")
.build())
.cycleScheduleSettings(DiJobJobSettingsCycleScheduleSettingsArgs.builder()
.cycleMigrationType("string")
.scheduleParameters("string")
.build())
.ddlHandlingSettings(DiJobJobSettingsDdlHandlingSettingArgs.builder()
.action("string")
.type("string")
.build())
.runtimeSettings(DiJobJobSettingsRuntimeSettingArgs.builder()
.name("string")
.value("string")
.build())
.build())
.projectId(0)
.transformationRules(DiJobTransformationRuleArgs.builder()
.ruleActionType("string")
.ruleExpression("string")
.ruleName("string")
.ruleTargetType("string")
.build())
.build());
di_job_resource = alicloud.dataworks.DiJob("diJobResource",
destination_data_source_settings=[{
"data_source_name": "string",
}],
destination_data_source_type="string",
job_name="string",
migration_type="string",
resource_settings={
"offline_resource_settings": {
"requested_cu": 0,
"resource_group_identifier": "string",
},
"realtime_resource_settings": {
"requested_cu": 0,
"resource_group_identifier": "string",
},
"schedule_resource_settings": {
"requested_cu": 0,
"resource_group_identifier": "string",
},
},
source_data_source_settings=[{
"data_source_name": "string",
"data_source_properties": {
"encoding": "string",
"timezone": "string",
},
}],
source_data_source_type="string",
table_mappings=[{
"source_object_selection_rules": [{
"action": "string",
"expression": "string",
"expression_type": "string",
"object_type": "string",
}],
"transformation_rules": [{
"rule_action_type": "string",
"rule_name": "string",
"rule_target_type": "string",
}],
}],
description="string",
job_settings={
"channel_settings": "string",
"column_data_type_settings": [{
"destination_data_type": "string",
"source_data_type": "string",
}],
"cycle_schedule_settings": {
"cycle_migration_type": "string",
"schedule_parameters": "string",
},
"ddl_handling_settings": [{
"action": "string",
"type": "string",
}],
"runtime_settings": [{
"name": "string",
"value": "string",
}],
},
project_id=0,
transformation_rules=[{
"rule_action_type": "string",
"rule_expression": "string",
"rule_name": "string",
"rule_target_type": "string",
}])
const diJobResource = new alicloud.dataworks.DiJob("diJobResource", {
destinationDataSourceSettings: [{
dataSourceName: "string",
}],
destinationDataSourceType: "string",
jobName: "string",
migrationType: "string",
resourceSettings: {
offlineResourceSettings: {
requestedCu: 0,
resourceGroupIdentifier: "string",
},
realtimeResourceSettings: {
requestedCu: 0,
resourceGroupIdentifier: "string",
},
scheduleResourceSettings: {
requestedCu: 0,
resourceGroupIdentifier: "string",
},
},
sourceDataSourceSettings: [{
dataSourceName: "string",
dataSourceProperties: {
encoding: "string",
timezone: "string",
},
}],
sourceDataSourceType: "string",
tableMappings: [{
sourceObjectSelectionRules: [{
action: "string",
expression: "string",
expressionType: "string",
objectType: "string",
}],
transformationRules: [{
ruleActionType: "string",
ruleName: "string",
ruleTargetType: "string",
}],
}],
description: "string",
jobSettings: {
channelSettings: "string",
columnDataTypeSettings: [{
destinationDataType: "string",
sourceDataType: "string",
}],
cycleScheduleSettings: {
cycleMigrationType: "string",
scheduleParameters: "string",
},
ddlHandlingSettings: [{
action: "string",
type: "string",
}],
runtimeSettings: [{
name: "string",
value: "string",
}],
},
projectId: 0,
transformationRules: [{
ruleActionType: "string",
ruleExpression: "string",
ruleName: "string",
ruleTargetType: "string",
}],
});
type: alicloud:dataworks:DiJob
properties:
description: string
destinationDataSourceSettings:
- dataSourceName: string
destinationDataSourceType: string
jobName: string
jobSettings:
channelSettings: string
columnDataTypeSettings:
- destinationDataType: string
sourceDataType: string
cycleScheduleSettings:
cycleMigrationType: string
scheduleParameters: string
ddlHandlingSettings:
- action: string
type: string
runtimeSettings:
- name: string
value: string
migrationType: string
projectId: 0
resourceSettings:
offlineResourceSettings:
requestedCu: 0
resourceGroupIdentifier: string
realtimeResourceSettings:
requestedCu: 0
resourceGroupIdentifier: string
scheduleResourceSettings:
requestedCu: 0
resourceGroupIdentifier: string
sourceDataSourceSettings:
- dataSourceName: string
dataSourceProperties:
encoding: string
timezone: string
sourceDataSourceType: string
tableMappings:
- sourceObjectSelectionRules:
- action: string
expression: string
expressionType: string
objectType: string
transformationRules:
- ruleActionType: string
ruleName: string
ruleTargetType: string
transformationRules:
- ruleActionType: string
ruleExpression: string
ruleName: string
ruleTargetType: string
DiJob Resource Properties
To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.
Inputs
In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.
The DiJob resource accepts the following input properties:
- Destination
Data List<Pulumi.Source Settings Ali Cloud. Data Works. Inputs. Di Job Destination Data Source Setting> - Destination data source See
destination_data_source_settings
below. - Destination
Data stringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- Job
Name string - Task Name.
- Migration
Type string Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- Resource
Settings Pulumi.Ali Cloud. Data Works. Inputs. Di Job Resource Settings - Resource Group Properties See
resource_settings
below. - Source
Data List<Pulumi.Source Settings Ali Cloud. Data Works. Inputs. Di Job Source Data Source Setting> - Source data source setting List See
source_data_source_settings
below. - Source
Data stringSource Type - The type of the source data source. The enumerated value is MySQL.
- Table
Mappings List<Pulumi.Ali Cloud. Data Works. Inputs. Di Job Table Mapping> - Synchronize object transformation mapping list See
table_mappings
below. - Description string
- Description of the integration task
- Job
Settings Pulumi.Ali Cloud. Data Works. Inputs. Di Job Job Settings - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - Project
Id int - Project Id
- Transformation
Rules List<Pulumi.Ali Cloud. Data Works. Inputs. Di Job Transformation Rule> - Definition list of synchronization object conversion rules See
transformation_rules
below.
- Destination
Data []DiSource Settings Job Destination Data Source Setting Args - Destination data source See
destination_data_source_settings
below. - Destination
Data stringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- Job
Name string - Task Name.
- Migration
Type string Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- Resource
Settings DiJob Resource Settings Args - Resource Group Properties See
resource_settings
below. - Source
Data []DiSource Settings Job Source Data Source Setting Args - Source data source setting List See
source_data_source_settings
below. - Source
Data stringSource Type - The type of the source data source. The enumerated value is MySQL.
- Table
Mappings []DiJob Table Mapping Args - Synchronize object transformation mapping list See
table_mappings
below. - Description string
- Description of the integration task
- Job
Settings DiJob Job Settings Args - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - Project
Id int - Project Id
- Transformation
Rules []DiJob Transformation Rule Args - Definition list of synchronization object conversion rules See
transformation_rules
below.
- destination
Data List<DiSource Settings Job Destination Data Source Setting> - Destination data source See
destination_data_source_settings
below. - destination
Data StringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- job
Name String - Task Name.
- migration
Type String Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- resource
Settings DiJob Resource Settings - Resource Group Properties See
resource_settings
below. - source
Data List<DiSource Settings Job Source Data Source Setting> - Source data source setting List See
source_data_source_settings
below. - source
Data StringSource Type - The type of the source data source. The enumerated value is MySQL.
- table
Mappings List<DiJob Table Mapping> - Synchronize object transformation mapping list See
table_mappings
below. - description String
- Description of the integration task
- job
Settings DiJob Job Settings - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - project
Id Integer - Project Id
- transformation
Rules List<DiJob Transformation Rule> - Definition list of synchronization object conversion rules See
transformation_rules
below.
- destination
Data DiSource Settings Job Destination Data Source Setting[] - Destination data source See
destination_data_source_settings
below. - destination
Data stringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- job
Name string - Task Name.
- migration
Type string Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- resource
Settings DiJob Resource Settings - Resource Group Properties See
resource_settings
below. - source
Data DiSource Settings Job Source Data Source Setting[] - Source data source setting List See
source_data_source_settings
below. - source
Data stringSource Type - The type of the source data source. The enumerated value is MySQL.
- table
Mappings DiJob Table Mapping[] - Synchronize object transformation mapping list See
table_mappings
below. - description string
- Description of the integration task
- job
Settings DiJob Job Settings - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - project
Id number - Project Id
- transformation
Rules DiJob Transformation Rule[] - Definition list of synchronization object conversion rules See
transformation_rules
below.
- destination_
data_ Sequence[Disource_ settings Job Destination Data Source Setting Args] - Destination data source See
destination_data_source_settings
below. - destination_
data_ strsource_ type - The type of the target data source. Enumerated values: Hologres and Hive.
- job_
name str - Task Name.
- migration_
type str Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- resource_
settings DiJob Resource Settings Args - Resource Group Properties See
resource_settings
below. - source_
data_ Sequence[Disource_ settings Job Source Data Source Setting Args] - Source data source setting List See
source_data_source_settings
below. - source_
data_ strsource_ type - The type of the source data source. The enumerated value is MySQL.
- table_
mappings Sequence[DiJob Table Mapping Args] - Synchronize object transformation mapping list See
table_mappings
below. - description str
- Description of the integration task
- job_
settings DiJob Job Settings Args - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - project_
id int - Project Id
- transformation_
rules Sequence[DiJob Transformation Rule Args] - Definition list of synchronization object conversion rules See
transformation_rules
below.
- destination
Data List<Property Map>Source Settings - Destination data source See
destination_data_source_settings
below. - destination
Data StringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- job
Name String - Task Name.
- migration
Type String Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- resource
Settings Property Map - Resource Group Properties See
resource_settings
below. - source
Data List<Property Map>Source Settings - Source data source setting List See
source_data_source_settings
below. - source
Data StringSource Type - The type of the source data source. The enumerated value is MySQL.
- table
Mappings List<Property Map> - Synchronize object transformation mapping list See
table_mappings
below. - description String
- Description of the integration task
- job
Settings Property Map - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - project
Id Number - Project Id
- transformation
Rules List<Property Map> - Definition list of synchronization object conversion rules See
transformation_rules
below.
Outputs
All input properties are implicitly available as output properties. Additionally, the DiJob resource produces the following output properties:
Look up Existing DiJob Resource
Get an existing DiJob resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.
public static get(name: string, id: Input<ID>, state?: DiJobState, opts?: CustomResourceOptions): DiJob
@staticmethod
def get(resource_name: str,
id: str,
opts: Optional[ResourceOptions] = None,
description: Optional[str] = None,
destination_data_source_settings: Optional[Sequence[DiJobDestinationDataSourceSettingArgs]] = None,
destination_data_source_type: Optional[str] = None,
di_job_id: Optional[int] = None,
job_name: Optional[str] = None,
job_settings: Optional[DiJobJobSettingsArgs] = None,
migration_type: Optional[str] = None,
project_id: Optional[int] = None,
resource_settings: Optional[DiJobResourceSettingsArgs] = None,
source_data_source_settings: Optional[Sequence[DiJobSourceDataSourceSettingArgs]] = None,
source_data_source_type: Optional[str] = None,
table_mappings: Optional[Sequence[DiJobTableMappingArgs]] = None,
transformation_rules: Optional[Sequence[DiJobTransformationRuleArgs]] = None) -> DiJob
func GetDiJob(ctx *Context, name string, id IDInput, state *DiJobState, opts ...ResourceOption) (*DiJob, error)
public static DiJob Get(string name, Input<string> id, DiJobState? state, CustomResourceOptions? opts = null)
public static DiJob get(String name, Output<String> id, DiJobState state, CustomResourceOptions options)
resources: _: type: alicloud:dataworks:DiJob get: id: ${id}
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- resource_name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- Description string
- Description of the integration task
- Destination
Data List<Pulumi.Source Settings Ali Cloud. Data Works. Inputs. Di Job Destination Data Source Setting> - Destination data source See
destination_data_source_settings
below. - Destination
Data stringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- Di
Job intId - Integration Task Id
- Job
Name string - Task Name.
- Job
Settings Pulumi.Ali Cloud. Data Works. Inputs. Di Job Job Settings - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - Migration
Type string Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- Project
Id int - Project Id
- Resource
Settings Pulumi.Ali Cloud. Data Works. Inputs. Di Job Resource Settings - Resource Group Properties See
resource_settings
below. - Source
Data List<Pulumi.Source Settings Ali Cloud. Data Works. Inputs. Di Job Source Data Source Setting> - Source data source setting List See
source_data_source_settings
below. - Source
Data stringSource Type - The type of the source data source. The enumerated value is MySQL.
- Table
Mappings List<Pulumi.Ali Cloud. Data Works. Inputs. Di Job Table Mapping> - Synchronize object transformation mapping list See
table_mappings
below. - Transformation
Rules List<Pulumi.Ali Cloud. Data Works. Inputs. Di Job Transformation Rule> - Definition list of synchronization object conversion rules See
transformation_rules
below.
- Description string
- Description of the integration task
- Destination
Data []DiSource Settings Job Destination Data Source Setting Args - Destination data source See
destination_data_source_settings
below. - Destination
Data stringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- Di
Job intId - Integration Task Id
- Job
Name string - Task Name.
- Job
Settings DiJob Job Settings Args - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - Migration
Type string Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- Project
Id int - Project Id
- Resource
Settings DiJob Resource Settings Args - Resource Group Properties See
resource_settings
below. - Source
Data []DiSource Settings Job Source Data Source Setting Args - Source data source setting List See
source_data_source_settings
below. - Source
Data stringSource Type - The type of the source data source. The enumerated value is MySQL.
- Table
Mappings []DiJob Table Mapping Args - Synchronize object transformation mapping list See
table_mappings
below. - Transformation
Rules []DiJob Transformation Rule Args - Definition list of synchronization object conversion rules See
transformation_rules
below.
- description String
- Description of the integration task
- destination
Data List<DiSource Settings Job Destination Data Source Setting> - Destination data source See
destination_data_source_settings
below. - destination
Data StringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- di
Job IntegerId - Integration Task Id
- job
Name String - Task Name.
- job
Settings DiJob Job Settings - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - migration
Type String Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- project
Id Integer - Project Id
- resource
Settings DiJob Resource Settings - Resource Group Properties See
resource_settings
below. - source
Data List<DiSource Settings Job Source Data Source Setting> - Source data source setting List See
source_data_source_settings
below. - source
Data StringSource Type - The type of the source data source. The enumerated value is MySQL.
- table
Mappings List<DiJob Table Mapping> - Synchronize object transformation mapping list See
table_mappings
below. - transformation
Rules List<DiJob Transformation Rule> - Definition list of synchronization object conversion rules See
transformation_rules
below.
- description string
- Description of the integration task
- destination
Data DiSource Settings Job Destination Data Source Setting[] - Destination data source See
destination_data_source_settings
below. - destination
Data stringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- di
Job numberId - Integration Task Id
- job
Name string - Task Name.
- job
Settings DiJob Job Settings - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - migration
Type string Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- project
Id number - Project Id
- resource
Settings DiJob Resource Settings - Resource Group Properties See
resource_settings
below. - source
Data DiSource Settings Job Source Data Source Setting[] - Source data source setting List See
source_data_source_settings
below. - source
Data stringSource Type - The type of the source data source. The enumerated value is MySQL.
- table
Mappings DiJob Table Mapping[] - Synchronize object transformation mapping list See
table_mappings
below. - transformation
Rules DiJob Transformation Rule[] - Definition list of synchronization object conversion rules See
transformation_rules
below.
- description str
- Description of the integration task
- destination_
data_ Sequence[Disource_ settings Job Destination Data Source Setting Args] - Destination data source See
destination_data_source_settings
below. - destination_
data_ strsource_ type - The type of the target data source. Enumerated values: Hologres and Hive.
- di_
job_ intid - Integration Task Id
- job_
name str - Task Name.
- job_
settings DiJob Job Settings Args - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - migration_
type str Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- project_
id int - Project Id
- resource_
settings DiJob Resource Settings Args - Resource Group Properties See
resource_settings
below. - source_
data_ Sequence[Disource_ settings Job Source Data Source Setting Args] - Source data source setting List See
source_data_source_settings
below. - source_
data_ strsource_ type - The type of the source data source. The enumerated value is MySQL.
- table_
mappings Sequence[DiJob Table Mapping Args] - Synchronize object transformation mapping list See
table_mappings
below. - transformation_
rules Sequence[DiJob Transformation Rule Args] - Definition list of synchronization object conversion rules See
transformation_rules
below.
- description String
- Description of the integration task
- destination
Data List<Property Map>Source Settings - Destination data source See
destination_data_source_settings
below. - destination
Data StringSource Type - The type of the target data source. Enumerated values: Hologres and Hive.
- di
Job NumberId - Integration Task Id
- job
Name String - Task Name.
- job
Settings Property Map - The dimension settings of the synchronization task, including the DDL processing policy, the source and destination column data type mapping policy, and the task runtime parameters. See
job_settings
below. - migration
Type String Synchronization type, optional enumeration values are:
Fulllandrealtimeincremental (full and real-time incremental)
RealtimeIncremental
Full
Offflineincremental
FullAndOfflineIncremental (full amount + offline increment)
- project
Id Number - Project Id
- resource
Settings Property Map - Resource Group Properties See
resource_settings
below. - source
Data List<Property Map>Source Settings - Source data source setting List See
source_data_source_settings
below. - source
Data StringSource Type - The type of the source data source. The enumerated value is MySQL.
- table
Mappings List<Property Map> - Synchronize object transformation mapping list See
table_mappings
below. - transformation
Rules List<Property Map> - Definition list of synchronization object conversion rules See
transformation_rules
below.
Supporting Types
DiJobDestinationDataSourceSetting, DiJobDestinationDataSourceSettingArgs
- Data
Source stringName - Destination data source name
- Data
Source stringName - Destination data source name
- data
Source StringName - Destination data source name
- data
Source stringName - Destination data source name
- data_
source_ strname - Destination data source name
- data
Source StringName - Destination data source name
DiJobJobSettings, DiJobJobSettingsArgs
- Channel
Settings string Channel-related task settings, in the form of a Json String.
For example, {"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""}
- Column
Data List<Pulumi.Type Settings Ali Cloud. Data Works. Inputs. Di Job Job Settings Column Data Type Setting> - Column type mapping of the synchronization task See
column_data_type_settings
below. - Cycle
Schedule Pulumi.Settings Ali Cloud. Data Works. Inputs. Di Job Job Settings Cycle Schedule Settings - Periodic scheduling settings See
cycle_schedule_settings
below. - Ddl
Handling List<Pulumi.Settings Ali Cloud. Data Works. Inputs. Di Job Job Settings Ddl Handling Setting> - List of DDL processing settings for synchronization tasks See
ddl_handling_settings
below. - Runtime
Settings List<Pulumi.Ali Cloud. Data Works. Inputs. Di Job Job Settings Runtime Setting> - Run-time setting parameter list See
runtime_settings
below.
- Channel
Settings string Channel-related task settings, in the form of a Json String.
For example, {"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""}
- Column
Data []DiType Settings Job Job Settings Column Data Type Setting - Column type mapping of the synchronization task See
column_data_type_settings
below. - Cycle
Schedule DiSettings Job Job Settings Cycle Schedule Settings - Periodic scheduling settings See
cycle_schedule_settings
below. - Ddl
Handling []DiSettings Job Job Settings Ddl Handling Setting - List of DDL processing settings for synchronization tasks See
ddl_handling_settings
below. - Runtime
Settings []DiJob Job Settings Runtime Setting - Run-time setting parameter list See
runtime_settings
below.
- channel
Settings String Channel-related task settings, in the form of a Json String.
For example, {"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""}
- column
Data List<DiType Settings Job Job Settings Column Data Type Setting> - Column type mapping of the synchronization task See
column_data_type_settings
below. - cycle
Schedule DiSettings Job Job Settings Cycle Schedule Settings - Periodic scheduling settings See
cycle_schedule_settings
below. - ddl
Handling List<DiSettings Job Job Settings Ddl Handling Setting> - List of DDL processing settings for synchronization tasks See
ddl_handling_settings
below. - runtime
Settings List<DiJob Job Settings Runtime Setting> - Run-time setting parameter list See
runtime_settings
below.
- channel
Settings string Channel-related task settings, in the form of a Json String.
For example, {"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""}
- column
Data DiType Settings Job Job Settings Column Data Type Setting[] - Column type mapping of the synchronization task See
column_data_type_settings
below. - cycle
Schedule DiSettings Job Job Settings Cycle Schedule Settings - Periodic scheduling settings See
cycle_schedule_settings
below. - ddl
Handling DiSettings Job Job Settings Ddl Handling Setting[] - List of DDL processing settings for synchronization tasks See
ddl_handling_settings
below. - runtime
Settings DiJob Job Settings Runtime Setting[] - Run-time setting parameter list See
runtime_settings
below.
- channel_
settings str Channel-related task settings, in the form of a Json String.
For example, {"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""}
- column_
data_ Sequence[Ditype_ settings Job Job Settings Column Data Type Setting] - Column type mapping of the synchronization task See
column_data_type_settings
below. - cycle_
schedule_ Disettings Job Job Settings Cycle Schedule Settings - Periodic scheduling settings See
cycle_schedule_settings
below. - ddl_
handling_ Sequence[Disettings Job Job Settings Ddl Handling Setting] - List of DDL processing settings for synchronization tasks See
ddl_handling_settings
below. - runtime_
settings Sequence[DiJob Job Settings Runtime Setting] - Run-time setting parameter list See
runtime_settings
below.
- channel
Settings String Channel-related task settings, in the form of a Json String.
For example, {"structInfo":"MANAGED","storageType":"TEXTFILE","writeMode":"APPEND","partitionColumns":[{"columnName":"pt","columnType":"STRING","comment":""}],"fieldDelimiter":""}
- column
Data List<Property Map>Type Settings - Column type mapping of the synchronization task See
column_data_type_settings
below. - cycle
Schedule Property MapSettings - Periodic scheduling settings See
cycle_schedule_settings
below. - ddl
Handling List<Property Map>Settings - List of DDL processing settings for synchronization tasks See
ddl_handling_settings
below. - runtime
Settings List<Property Map> - Run-time setting parameter list See
runtime_settings
below.
DiJobJobSettingsColumnDataTypeSetting, DiJobJobSettingsColumnDataTypeSettingArgs
- Destination
Data stringType - The destination type of the mapping relationship
- Source
Data stringType - The source type of the mapping type
- Destination
Data stringType - The destination type of the mapping relationship
- Source
Data stringType - The source type of the mapping type
- destination
Data StringType - The destination type of the mapping relationship
- source
Data StringType - The source type of the mapping type
- destination
Data stringType - The destination type of the mapping relationship
- source
Data stringType - The source type of the mapping type
- destination_
data_ strtype - The destination type of the mapping relationship
- source_
data_ strtype - The source type of the mapping type
- destination
Data StringType - The destination type of the mapping relationship
- source
Data StringType - The source type of the mapping type
DiJobJobSettingsCycleScheduleSettings, DiJobJobSettingsCycleScheduleSettingsArgs
- Cycle
Migration stringType The type of synchronization that requires periodic scheduling. Value range:
Full: Full
OfflineIncremental: offline increment
- Schedule
Parameters string - Scheduling Parameters
- Cycle
Migration stringType The type of synchronization that requires periodic scheduling. Value range:
Full: Full
OfflineIncremental: offline increment
- Schedule
Parameters string - Scheduling Parameters
- cycle
Migration StringType The type of synchronization that requires periodic scheduling. Value range:
Full: Full
OfflineIncremental: offline increment
- schedule
Parameters String - Scheduling Parameters
- cycle
Migration stringType The type of synchronization that requires periodic scheduling. Value range:
Full: Full
OfflineIncremental: offline increment
- schedule
Parameters string - Scheduling Parameters
- cycle_
migration_ strtype The type of synchronization that requires periodic scheduling. Value range:
Full: Full
OfflineIncremental: offline increment
- schedule_
parameters str - Scheduling Parameters
- cycle
Migration StringType The type of synchronization that requires periodic scheduling. Value range:
Full: Full
OfflineIncremental: offline increment
- schedule
Parameters String - Scheduling Parameters
DiJobJobSettingsDdlHandlingSetting, DiJobJobSettingsDdlHandlingSettingArgs
DiJobJobSettingsRuntimeSetting, DiJobJobSettingsRuntimeSettingArgs
- Name string
Set name, optional ENUM value:
runtime.offline.speed.limit.mb (valid when runtime.offline.speed.limit.enable = true)
runtime.offline.speed.limit.enable
dst.offline.connection.max (the maximum number of write connections for offline batch tasks)
runtime.offline.concurrent (offline batch synchronization task concurrency)
dst.realtime.connection.max (maximum number of write connections for real-time tasks)
runtime.enable.auto.create.schema (whether to automatically create a schema on the target side)
src.offline.datasource.max.connection (maximum number of source connections for offline batch tasks)
runtime.realtime.concurrent (real-time task concurrency)
- Value string
- Runtime setting value
- Name string
Set name, optional ENUM value:
runtime.offline.speed.limit.mb (valid when runtime.offline.speed.limit.enable = true)
runtime.offline.speed.limit.enable
dst.offline.connection.max (the maximum number of write connections for offline batch tasks)
runtime.offline.concurrent (offline batch synchronization task concurrency)
dst.realtime.connection.max (maximum number of write connections for real-time tasks)
runtime.enable.auto.create.schema (whether to automatically create a schema on the target side)
src.offline.datasource.max.connection (maximum number of source connections for offline batch tasks)
runtime.realtime.concurrent (real-time task concurrency)
- Value string
- Runtime setting value
- name String
Set name, optional ENUM value:
runtime.offline.speed.limit.mb (valid when runtime.offline.speed.limit.enable = true)
runtime.offline.speed.limit.enable
dst.offline.connection.max (the maximum number of write connections for offline batch tasks)
runtime.offline.concurrent (offline batch synchronization task concurrency)
dst.realtime.connection.max (maximum number of write connections for real-time tasks)
runtime.enable.auto.create.schema (whether to automatically create a schema on the target side)
src.offline.datasource.max.connection (maximum number of source connections for offline batch tasks)
runtime.realtime.concurrent (real-time task concurrency)
- value String
- Runtime setting value
- name string
Set name, optional ENUM value:
runtime.offline.speed.limit.mb (valid when runtime.offline.speed.limit.enable = true)
runtime.offline.speed.limit.enable
dst.offline.connection.max (the maximum number of write connections for offline batch tasks)
runtime.offline.concurrent (offline batch synchronization task concurrency)
dst.realtime.connection.max (maximum number of write connections for real-time tasks)
runtime.enable.auto.create.schema (whether to automatically create a schema on the target side)
src.offline.datasource.max.connection (maximum number of source connections for offline batch tasks)
runtime.realtime.concurrent (real-time task concurrency)
- value string
- Runtime setting value
- name str
Set name, optional ENUM value:
runtime.offline.speed.limit.mb (valid when runtime.offline.speed.limit.enable = true)
runtime.offline.speed.limit.enable
dst.offline.connection.max (the maximum number of write connections for offline batch tasks)
runtime.offline.concurrent (offline batch synchronization task concurrency)
dst.realtime.connection.max (maximum number of write connections for real-time tasks)
runtime.enable.auto.create.schema (whether to automatically create a schema on the target side)
src.offline.datasource.max.connection (maximum number of source connections for offline batch tasks)
runtime.realtime.concurrent (real-time task concurrency)
- value str
- Runtime setting value
- name String
Set name, optional ENUM value:
runtime.offline.speed.limit.mb (valid when runtime.offline.speed.limit.enable = true)
runtime.offline.speed.limit.enable
dst.offline.connection.max (the maximum number of write connections for offline batch tasks)
runtime.offline.concurrent (offline batch synchronization task concurrency)
dst.realtime.connection.max (maximum number of write connections for real-time tasks)
runtime.enable.auto.create.schema (whether to automatically create a schema on the target side)
src.offline.datasource.max.connection (maximum number of source connections for offline batch tasks)
runtime.realtime.concurrent (real-time task concurrency)
- value String
- Runtime setting value
DiJobResourceSettings, DiJobResourceSettingsArgs
- Offline
Resource Pulumi.Settings Ali Cloud. Data Works. Inputs. Di Job Resource Settings Offline Resource Settings - Offline Resource Group configuration See
offline_resource_settings
below. - Realtime
Resource Pulumi.Settings Ali Cloud. Data Works. Inputs. Di Job Resource Settings Realtime Resource Settings - Real-time Resource Group See
realtime_resource_settings
below. - Schedule
Resource Pulumi.Settings Ali Cloud. Data Works. Inputs. Di Job Resource Settings Schedule Resource Settings - Scheduling Resource Groups See
schedule_resource_settings
below.
- Offline
Resource DiSettings Job Resource Settings Offline Resource Settings - Offline Resource Group configuration See
offline_resource_settings
below. - Realtime
Resource DiSettings Job Resource Settings Realtime Resource Settings - Real-time Resource Group See
realtime_resource_settings
below. - Schedule
Resource DiSettings Job Resource Settings Schedule Resource Settings - Scheduling Resource Groups See
schedule_resource_settings
below.
- offline
Resource DiSettings Job Resource Settings Offline Resource Settings - Offline Resource Group configuration See
offline_resource_settings
below. - realtime
Resource DiSettings Job Resource Settings Realtime Resource Settings - Real-time Resource Group See
realtime_resource_settings
below. - schedule
Resource DiSettings Job Resource Settings Schedule Resource Settings - Scheduling Resource Groups See
schedule_resource_settings
below.
- offline
Resource DiSettings Job Resource Settings Offline Resource Settings - Offline Resource Group configuration See
offline_resource_settings
below. - realtime
Resource DiSettings Job Resource Settings Realtime Resource Settings - Real-time Resource Group See
realtime_resource_settings
below. - schedule
Resource DiSettings Job Resource Settings Schedule Resource Settings - Scheduling Resource Groups See
schedule_resource_settings
below.
- offline_
resource_ Disettings Job Resource Settings Offline Resource Settings - Offline Resource Group configuration See
offline_resource_settings
below. - realtime_
resource_ Disettings Job Resource Settings Realtime Resource Settings - Real-time Resource Group See
realtime_resource_settings
below. - schedule_
resource_ Disettings Job Resource Settings Schedule Resource Settings - Scheduling Resource Groups See
schedule_resource_settings
below.
- offline
Resource Property MapSettings - Offline Resource Group configuration See
offline_resource_settings
below. - realtime
Resource Property MapSettings - Real-time Resource Group See
realtime_resource_settings
below. - schedule
Resource Property MapSettings - Scheduling Resource Groups See
schedule_resource_settings
below.
DiJobResourceSettingsOfflineResourceSettings, DiJobResourceSettingsOfflineResourceSettingsArgs
- Requested
Cu double - Scheduling resource group cu
- Resource
Group stringIdentifier - Scheduling resource group name
- Requested
Cu float64 - Scheduling resource group cu
- Resource
Group stringIdentifier - Scheduling resource group name
- requested
Cu Double - Scheduling resource group cu
- resource
Group StringIdentifier - Scheduling resource group name
- requested
Cu number - Scheduling resource group cu
- resource
Group stringIdentifier - Scheduling resource group name
- requested_
cu float - Scheduling resource group cu
- resource_
group_ stridentifier - Scheduling resource group name
- requested
Cu Number - Scheduling resource group cu
- resource
Group StringIdentifier - Scheduling resource group name
DiJobResourceSettingsRealtimeResourceSettings, DiJobResourceSettingsRealtimeResourceSettingsArgs
- Requested
Cu double - Scheduling resource group cu
- Resource
Group stringIdentifier - Scheduling resource group name
- Requested
Cu float64 - Scheduling resource group cu
- Resource
Group stringIdentifier - Scheduling resource group name
- requested
Cu Double - Scheduling resource group cu
- resource
Group StringIdentifier - Scheduling resource group name
- requested
Cu number - Scheduling resource group cu
- resource
Group stringIdentifier - Scheduling resource group name
- requested_
cu float - Scheduling resource group cu
- resource_
group_ stridentifier - Scheduling resource group name
- requested
Cu Number - Scheduling resource group cu
- resource
Group StringIdentifier - Scheduling resource group name
DiJobResourceSettingsScheduleResourceSettings, DiJobResourceSettingsScheduleResourceSettingsArgs
- Requested
Cu double - Scheduling resource group cu
- Resource
Group stringIdentifier - Scheduling resource group name
- Requested
Cu float64 - Scheduling resource group cu
- Resource
Group stringIdentifier - Scheduling resource group name
- requested
Cu Double - Scheduling resource group cu
- resource
Group StringIdentifier - Scheduling resource group name
- requested
Cu number - Scheduling resource group cu
- resource
Group stringIdentifier - Scheduling resource group name
- requested_
cu float - Scheduling resource group cu
- resource_
group_ stridentifier - Scheduling resource group name
- requested
Cu Number - Scheduling resource group cu
- resource
Group StringIdentifier - Scheduling resource group name
DiJobSourceDataSourceSetting, DiJobSourceDataSourceSettingArgs
- Data
Source stringName - Data source name of a single source
- Data
Source Pulumi.Properties Ali Cloud. Data Works. Inputs. Di Job Source Data Source Setting Data Source Properties - Single Source Data Source Properties See
data_source_properties
below.
- Data
Source stringName - Data source name of a single source
- Data
Source DiProperties Job Source Data Source Setting Data Source Properties - Single Source Data Source Properties See
data_source_properties
below.
- data
Source StringName - Data source name of a single source
- data
Source DiProperties Job Source Data Source Setting Data Source Properties - Single Source Data Source Properties See
data_source_properties
below.
- data
Source stringName - Data source name of a single source
- data
Source DiProperties Job Source Data Source Setting Data Source Properties - Single Source Data Source Properties See
data_source_properties
below.
- data_
source_ strname - Data source name of a single source
- data_
source_ Diproperties Job Source Data Source Setting Data Source Properties - Single Source Data Source Properties See
data_source_properties
below.
- data
Source StringName - Data source name of a single source
- data
Source Property MapProperties - Single Source Data Source Properties See
data_source_properties
below.
DiJobSourceDataSourceSettingDataSourceProperties, DiJobSourceDataSourceSettingDataSourcePropertiesArgs
DiJobTableMapping, DiJobTableMappingArgs
- Source
Object List<Pulumi.Selection Rules Ali Cloud. Data Works. Inputs. Di Job Table Mapping Source Object Selection Rule> - Each rule can select different types of source objects to be synchronized, such as source database and source data table. See
source_object_selection_rules
below. - Transformation
Rules List<Pulumi.Ali Cloud. Data Works. Inputs. Di Job Table Mapping Transformation Rule> - A list of conversion rule definitions for a synchronization object. Each element in the list defines a conversion rule. See
transformation_rules
below.
- Source
Object []DiSelection Rules Job Table Mapping Source Object Selection Rule - Each rule can select different types of source objects to be synchronized, such as source database and source data table. See
source_object_selection_rules
below. - Transformation
Rules []DiJob Table Mapping Transformation Rule - A list of conversion rule definitions for a synchronization object. Each element in the list defines a conversion rule. See
transformation_rules
below.
- source
Object List<DiSelection Rules Job Table Mapping Source Object Selection Rule> - Each rule can select different types of source objects to be synchronized, such as source database and source data table. See
source_object_selection_rules
below. - transformation
Rules List<DiJob Table Mapping Transformation Rule> - A list of conversion rule definitions for a synchronization object. Each element in the list defines a conversion rule. See
transformation_rules
below.
- source
Object DiSelection Rules Job Table Mapping Source Object Selection Rule[] - Each rule can select different types of source objects to be synchronized, such as source database and source data table. See
source_object_selection_rules
below. - transformation
Rules DiJob Table Mapping Transformation Rule[] - A list of conversion rule definitions for a synchronization object. Each element in the list defines a conversion rule. See
transformation_rules
below.
- source_
object_ Sequence[Diselection_ rules Job Table Mapping Source Object Selection Rule] - Each rule can select different types of source objects to be synchronized, such as source database and source data table. See
source_object_selection_rules
below. - transformation_
rules Sequence[DiJob Table Mapping Transformation Rule] - A list of conversion rule definitions for a synchronization object. Each element in the list defines a conversion rule. See
transformation_rules
below.
- source
Object List<Property Map>Selection Rules - Each rule can select different types of source objects to be synchronized, such as source database and source data table. See
source_object_selection_rules
below. - transformation
Rules List<Property Map> - A list of conversion rule definitions for a synchronization object. Each element in the list defines a conversion rule. See
transformation_rules
below.
DiJobTableMappingSourceObjectSelectionRule, DiJobTableMappingSourceObjectSelectionRuleArgs
- Action string
- Expression string
- Expression, such as mysql_table_1
- Expression
Type string - Expression type, value range: Exact/Regex
- Object
Type string Object type, optional enumeration value:
Table (Table)
Database
- Action string
- Expression string
- Expression, such as mysql_table_1
- Expression
Type string - Expression type, value range: Exact/Regex
- Object
Type string Object type, optional enumeration value:
Table (Table)
Database
- action String
- expression String
- Expression, such as mysql_table_1
- expression
Type String - Expression type, value range: Exact/Regex
- object
Type String Object type, optional enumeration value:
Table (Table)
Database
- action string
- expression string
- Expression, such as mysql_table_1
- expression
Type string - Expression type, value range: Exact/Regex
- object
Type string Object type, optional enumeration value:
Table (Table)
Database
- action str
- expression str
- Expression, such as mysql_table_1
- expression_
type str - Expression type, value range: Exact/Regex
- object_
type str Object type, optional enumeration value:
Table (Table)
Database
- action String
- expression String
- Expression, such as mysql_table_1
- expression
Type String - Expression type, value range: Exact/Regex
- object
Type String Object type, optional enumeration value:
Table (Table)
Database
DiJobTableMappingTransformationRule, DiJobTableMappingTransformationRuleArgs
- Rule
Action stringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- Rule
Name string - Rule Name
- Rule
Target stringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- Rule
Action stringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- Rule
Name string - Rule Name
- Rule
Target stringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- rule
Action StringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- rule
Name String - Rule Name
- rule
Target StringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- rule
Action stringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- rule
Name string - Rule Name
- rule
Target stringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- rule_
action_ strtype Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- rule_
name str - Rule Name
- rule_
target_ strtype Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- rule
Action StringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- rule
Name String - Rule Name
- rule
Target StringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
DiJobTransformationRule, DiJobTransformationRuleArgs
- Rule
Action stringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- Rule
Expression string Regular expression, in json string format.
Example renaming rule (Rename): {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}
- Rule
Name string - Rule Name
- Rule
Target stringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- Rule
Action stringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- Rule
Expression string Regular expression, in json string format.
Example renaming rule (Rename): {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}
- Rule
Name string - Rule Name
- Rule
Target stringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- rule
Action StringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- rule
Expression String Regular expression, in json string format.
Example renaming rule (Rename): {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}
- rule
Name String - Rule Name
- rule
Target StringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- rule
Action stringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- rule
Expression string Regular expression, in json string format.
Example renaming rule (Rename): {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}
- rule
Name string - Rule Name
- rule
Target stringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- rule_
action_ strtype Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- rule_
expression str Regular expression, in json string format.
Example renaming rule (Rename): {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}
- rule_
name str - Rule Name
- rule_
target_ strtype Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
- rule
Action StringType Action type, optional enumeration value:
DefinePrimaryKey (defines the primary key)
Rename
AddColumn (increase column)
HandleDml(DML handling)
DefineIncrementalCondition
- rule
Expression String Regular expression, in json string format.
Example renaming rule (Rename): {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922","variables":[{"variableName":"srcDatabaseName","variableRules":[{"from":"fromdb","to":"todb"}]}]}
- rule
Name String - Rule Name
- rule
Target StringType Target type of action, optional enumeration value:
Table (Table)
Schema(schema)
Import
Data Works Di Job can be imported using the id, e.g.
$ pulumi import alicloud:dataworks/diJob:DiJob example <project_id>:<di_job_id>
To learn more about importing existing cloud resources, see Importing resources.
Package Details
- Repository
- Alibaba Cloud pulumi/pulumi-alicloud
- License
- Apache-2.0
- Notes
- This Pulumi package is based on the
alicloud
Terraform Provider.