alicloud.dataworks.DiJob

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'

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