All Products
Search

This Product

    DataWorks:UpdateDIJob

    Document Center

    DataWorks:UpdateDIJob

    Last Updated:Jun 11, 2026

    Memperbarui tugas Integrasi Data.

    Deskripsi operasi

    Fitur ini memerlukan DataWorks Basic Edition atau yang lebih tinggi.

    Coba sekarang

    Coba API ini di OpenAPI Explorer tanpa perlu penandatanganan manual. Panggilan yang berhasil akan secara otomatis menghasilkan contoh kode SDK sesuai dengan parameter Anda. Unduh kode tersebut dengan kredensial bawaan yang aman untuk penggunaan lokal.

    Test

    RAM authorization

    Tidak ada otorisasi untuk operasi ini. Jika Anda mengalami masalah saat menjalankan operasi ini, hubungi dukungan teknis.

    Parameter permintaan

    Parameter

    Type

    Required

    Description

    Example
    Id

    integer

    No

    ID dari pekerjaan sinkronisasi.

    11588
    Description

    string

    No

    Deskripsi pekerjaan sinkronisasi.

    DI Job Demo
    TableMappings

    array<object>

    No

    Daftar pemetaan transformasi objek. Setiap pemetaan menentukan sekumpulan aturan pemilihan untuk objek sumber dan daftar aturan transformasi yang berlaku pada objek yang dipilih.

    Catatan

    [ { "SourceObjectSelectionRules":[ { "ObjectType":"Database", "Action":"Include", "ExpressionType":"Exact", "Expression":"biz_db" }, { "ObjectType":"Schema", "Action":"Include", "ExpressionType":"Exact", "Expression":"s1" }, { "ObjectType":"Table", "Action":"Include", "ExpressionType":"Exact", "Expression":"table1" } ], "TransformationRuleNames":[ { "RuleName":"my_database_rename_rule", "RuleActionType":"Rename", "RuleTargetType":"Schema" } ] } ]

    array<object>

    No

    Sebuah pemetaan transformasi objek tunggal, yang menentukan sekumpulan aturan pemilihan untuk objek sumber dan daftar aturan transformasi yang akan diterapkan pada objek tersebut.

    SourceObjectSelectionRules

    array<object>

    No

    Aturan untuk memilih objek sumber. Setiap aturan dapat memilih jenis objek sumber yang berbeda untuk disinkronkan, seperti basis data sumber atau tabel.

    object

    No

    Aturan untuk memilih objek sumber yang akan disinkronkan, seperti basis data atau tabel.

    Action

    string

    No

    Tindakan pemilihan. Nilai yang valid: Include dan Exclude.

    Include
    Expression

    string

    No

    Ekspresi.

    mysql_table_1
    ExpressionType

    string

    No

    Jenis ekspresi. Nilai yang valid: Exact dan Regex.

    Exact
    ObjectType

    string

    No

    Jenis objek. Nilai yang valid:

    • Table (tabel)

    • Schema (skema)

    • Database (basis data)

    Table
    TransformationRules

    array<object>

    No

    Aturan transformasi untuk objek sumber.

    object

    No

    Sebuah aturan transformasi tunggal untuk objek sumber.

    RuleName

    string

    No

    Nama aturan transformasi. Nama harus unik untuk kombinasi RuleActionType dan RuleTargetType tertentu dan dapat memiliki panjang hingga 50 karakter.

    rename_rule_1
    RuleActionType

    string

    No

    Jenis tindakan. Nilai yang valid:

    • DefinePrimaryKey: Mendefinisikan kunci utama.

    • Rename: Mengubah nama objek.

    • AddColumn: Menambahkan kolom.

    • HandleDml: Menangani operasi DML.

    Rename
    RuleTargetType

    string

    No

    Jenis objek target. Nilai yang valid:

    • Table (tabel)

    • Schema (skema)

    • Database (basis data)

    Table
    JobSettings

    object

    No

    Pengaturan untuk pekerjaan sinkronisasi. Ini mencakup pengaturan penanganan DDL, pemetaan jenis data untuk kolom antara sumber dan tujuan, serta parameter runtime.

    ChannelSettings

    string

    No

    Pengaturan pekerjaan untuk saluran sinkronisasi data tertentu. Anda dapat menerapkan konfigurasi khusus pada saluran tertentu. Saat ini, Holo2Holo (sinkronisasi dari Hologres ke Hologres) dan Holo2Kafka (sinkronisasi dari Hologres ke Kafka) didukung.

    1. Holo2Kafka

    • Contoh: {"destinationChannelSettings":{"kafkaClientProperties":[{"key":"linger.ms","value":"100"}],"keyColumns":["col3"],"writeMode":"canal"}} kafkaClientProperties: Parameter produser Kafka yang digunakan saat menulis ke Kafka.

    • keyColumns: Kolom yang nilainya ditulis ke kunci pesan Kafka.

    • writeMode: Format penulisan data ke Kafka. Nilai yang valid: json dan canal.

    1. Holo2Holo

    • Contoh: {"destinationChannelSettings":{"conflictMode":"replace","dynamicColumnAction":"replay","writeMode":"replay"}}

    • conflictMode: Kebijakan penanganan konflik untuk menulis data ke Hologres. Nilai yang valid: replace (timpa) dan ignore (abaikan).

    • writeMode: Metode untuk menulis data ke Hologres. Nilai yang valid: replay dan insert.

    • dynamicColumnAction: Tindakan untuk menangani kolom dinamis saat menulis data ke Hologres. Nilai yang valid: replay, insert, dan ignore.

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

    array<object>

    No

    Sebuah array pemetaan jenis data kolom.

    Catatan

    ["ColumnDataTypeSettings":[ { "SourceDataType":"Bigint", "DestinationDataType":"Text" } ]

    object

    No

    Sebuah pemetaan jenis data kolom tunggal.

    DestinationDataType

    string

    No

    Jenis data tujuan. Contoh: bigint, boolean, string, text, datetime, timestamp, decimal, dan binary. Jenis data yang didukung bergantung pada sumber data tujuan.

    text
    SourceDataType

    string

    No

    Jenis data sumber. Contoh: bigint, boolean, string, text, datetime, timestamp, decimal, dan binary. Jenis data yang didukung bergantung pada sumber data sumber.

    bigint
    CycleScheduleSettings

    object

    No

    Pengaturan untuk penjadwalan periodik.

    ScheduleParameters

    string

    No

    Parameter penjadwalan.

    bizdate=$bizdate

    DdlHandlingSettings

    array<object>

    No

    Sebuah array pengaturan penanganan DDL.

    Catatan

    ["DDLHandlingSettings":[ { "Type":"Insert", "Action":"Normal" } ]

    object

    No

    Sebuah pengaturan penanganan DDL tunggal.

    Action

    string

    No

    Tindakan penanganan. Nilai yang valid:

    • Ignore: Mengabaikan pesan DDL.

    • Critical: Melaporkan kesalahan dan menghentikan pekerjaan sinkronisasi.

    • Normal: Memproses pesan DDL secara normal.

    Critical
    Type

    string

    No

    Jenis DDL. Nilai yang valid:

    • RenameColumn

    • ModifyColumn

    • CreateTable

    • TruncateTable

    • DropTable

    • DropColumn

    • AddColumn

    AddColumn
    RuntimeSettings

    array<object>

    No

    Pengaturan runtime.

    object

    No

    Sebuah pengaturan runtime tunggal.

    Name

    string

    No

    Nama pengaturan. Nilai yang valid:

    • src.offline.datasource.max.connection: Jumlah maksimum koneksi konkuren ke sumber untuk pekerjaan sinkronisasi offline.

    • dst.offline.truncate: Menentukan apakah akan memotong tabel tujuan sebelum pekerjaan sinkronisasi offline.

    • runtime.offline.speed.limit.enable: Menentukan apakah akan mengaktifkan pembatasan kecepatan untuk pekerjaan sinkronisasi offline.

    • runtime.offline.concurrent: Tingkat konkurensi untuk pekerjaan sinkronisasi offline.

    • runtime.enable.auto.create.schema: Menentukan apakah akan membuat skema secara otomatis di tujuan.

    • runtime.realtime.concurrent: Tingkat konkurensi untuk pekerjaan sinkronisasi waktu nyata.

    • runtime.realtime.failover.minute.dataxcdc: Jumlah menit untuk menunggu sebelum percobaan ulang failover.

    • runtime.realtime.failover.times.dataxcdc: Jumlah percobaan ulang failover.

    src.offline.datasource.max.connection
    Value

    string

    No

    Nilai pengaturan.

    1
    ResourceSettings

    object

    No

    Pengaturan sumber daya.

    OfflineResourceSettings

    object

    No

    Pengaturan sumber daya untuk pekerjaan sinkronisasi offline.

    RequestedCu

    number

    No

    Jumlah CU untuk grup sumber daya Integrasi Data yang digunakan oleh pekerjaan sinkronisasi offline.

    2
    ResourceGroupIdentifier

    string

    No

    Nama grup sumber daya Integrasi Data yang digunakan oleh pekerjaan sinkronisasi offline.

    S_res_group_111_222
    RealtimeResourceSettings

    object

    No

    Pengaturan sumber daya untuk pekerjaan sinkronisasi waktu nyata.

    RequestedCu

    number

    No

    Jumlah CU untuk grup sumber daya Integrasi Data yang digunakan oleh pekerjaan sinkronisasi waktu nyata.

    2
    ResourceGroupIdentifier

    string

    No

    Nama grup sumber daya Integrasi Data yang digunakan oleh pekerjaan sinkronisasi waktu nyata.

    S_res_group_111_222
    ScheduleResourceSettings

    object

    No

    Pengaturan sumber daya penjadwalan.

    RequestedCu

    number

    No

    Jumlah CU untuk grup sumber daya penjadwalan yang digunakan oleh pekerjaan sinkronisasi offline.

    2
    ResourceGroupIdentifier

    string

    No

    Nama grup sumber daya penjadwalan yang digunakan oleh pekerjaan sinkronisasi offline.

    S_res_group_222_333
    TransformationRules

    array<object>

    No

    Daftar definisi aturan transformasi.

    Catatan

    [ { "RuleName":"my_database_rename_rule", "RuleActionType":"Rename", "RuleTargetType":"Schema", "RuleExpression":"{"expression":"${srcDatasoureName}_${srcDatabaseName}"}" } ]

    object

    No

    Sebuah definisi aturan transformasi tunggal.

    RuleActionType

    string

    No

    Jenis tindakan. Nilai yang valid:

    • DefinePrimaryKey: Mendefinisikan kunci utama.

    • Rename: Mengubah nama objek.

    • AddColumn: Menambahkan kolom.

    • HandleDml: Menangani operasi DML.

    • DefineIncrementalCondition: Mendefinisikan kondisi inkremental.

    • DefineCycleScheduleSettings: Mendefinisikan pengaturan penjadwalan periodik.

    • DefinePartitionKey: Mendefinisikan kunci partisi.

    Rename
    RuleExpression

    string

    No

    Ekspresi aturan, ditentukan sebagai string JSON.

    1. Aturan ubah nama (Rename)

    • Contoh: {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922"}

    • expression: Ekspresi untuk aturan transformasi ubah nama. Ekspresi mendukung variabel, termasuk ${srcDatasourceName} (nama sumber data sumber), ${srcDatabaseName} (nama basis data sumber), dan ${srcTableName} (nama tabel sumber).

    1. Aturan tambah kolom (AddColumn)

    • Contoh: {"columns":[{"columnName":"my_add_column","columnValueType":"Constant","columnValue":"123"}]}

    • Jika aturan ini tidak ditentukan, tidak ada kolom yang ditambahkan.

    • columnName: Nama kolom yang akan ditambahkan.

    • columnValueType: Jenis nilai kolom yang ditambahkan. Nilai yang valid: Constant dan Variable.

    • columnValue: Nilai kolom yang ditambahkan. Jika columnValueType adalah Constant, nilainya adalah konstanta kustom bertipe string. Jika columnValueType adalah Variable, nilainya adalah variabel bawaan. Variabel bawaan yang valid: EXECUTE_TIME (waktu eksekusi, tipe Long), DB_NAME_SRC (nama basis data sumber, tipe String), DATASOURCE_NAME_SRC (nama sumber data sumber, tipe String), TABLE_NAME_SRC (nama tabel sumber, tipe String), DB_NAME_DEST (nama basis data tujuan, tipe String), DATASOURCE_NAME_DEST (nama sumber data tujuan, tipe String), TABLE_NAME_DEST (nama tabel tujuan, tipe String), dan DB_NAME_SRC_TRANSED (nama basis data yang telah ditransformasi, tipe String).

    1. Aturan definisi kunci utama (DefinePrimaryKey)

    • Contoh: {"columns":["ukcolumn1","ukcolumn2"]}

    • Jika aturan ini tidak ditentukan, kunci utama dari sumber digunakan secara default.

    • Integrasi Data tidak memodifikasi struktur tabel tujuan yang sudah ada. Jika kolom kunci utama yang ditentukan tidak ada dalam tabel, pekerjaan sinkronisasi akan gagal.

    • Saat tabel tujuan dibuat secara otomatis, Integrasi Data menyertakan kolom kunci utama yang didefinisikan dalam struktur. Jika kolom kunci utama yang ditentukan tidak ada dalam kumpulan kolom tujuan, pekerjaan sinkronisasi akan gagal.

    1. Aturan penanganan DML (HandleDml)

    • Contoh: {"dmlPolicies":[{"dmlType":"Delete","dmlAction":"Filter","filterCondition":"id > 1"}]}

    • Jika aturan ini tidak ditentukan, tindakan default untuk operasi Insert, Update, dan Delete adalah Normal.

    • dmlType: Jenis operasi DML. Nilai yang valid: Insert, Update, dan Delete.

    • dmlAction: Kebijakan penanganan DML. Nilai yang valid: Normal (memproses operasi), Ignore (mengabaikan operasi), Filter (memproses operasi secara kondisional, digunakan ketika dmlType adalah Update atau Delete), dan LogicalDelete (melakukan penghapusan logis).

    • filterCondition: Kondisi filter DML, digunakan ketika dmlAction adalah Filter.

    1. Aturan kondisi inkremental (DefineIncrementalCondition)

    • Contoh: {"where":"id > 0"}

    • Klausa WHERE untuk kondisi inkremental.

    1. Aturan penjadwalan periodik (DefineCycleScheduleSettings)

    • Contoh: {"cronExpress":" * * * * * *", "cycleType":"1"}

    • Menentukan parameter penjadwalan untuk pekerjaan periodik.

    1. Aturan definisi kunci partisi (DefinePartitionKey)

    • Contoh: {"columns":["id"]}

    • Menentukan kunci partisi.

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

    string

    No

    Nama aturan transformasi. Nama harus unik untuk kombinasi RuleActionType dan RuleTargetType tertentu dan dapat memiliki panjang hingga 50 karakter.

    rename_rule_1
    RuleTargetType

    string

    No

    Jenis objek target. Nilai yang valid:

    • Table (tabel)

    • Schema (skema)

    • Database (basis data)

    Table
    ProjectId

    integer

    No

    ID dari ruang kerja DataWorks. Anda dapat memanggil operasi ListProjects untuk mendapatkan ID ruang kerja.

    10000
    DIJobId deprecated

    integer

    No

    Parameter ini sudah tidak digunakan. Gunakan parameter Id sebagai gantinya.

    11588
    Owner

    string

    No

    Pemilik pekerjaan sinkronisasi.

    95279527
    FileSpec

    string

    No

    Konfigurasi pekerjaan dalam mode skrip.

    { "resourceSettings": { "realtimeResourceSettings": { "requestedCu": 2, "resourceGroupIdentifier": "Serverless_res_group_123_456" }, "offlineResourceSettings": { "requestedCu": 2, "resourceGroupIdentifier": "Serverless_res_group_123_456" } }, "tableMappings": [ { "sourceObjectSelectionRules": [ { "expression": "autotest_hologres", "action": "Include", "expressionType": "Exact", "objectType": "Datasource" }, { "expression": "auto_holo_2661647", "action": "Include", "expressionType": "Exact", "objectType": "Table" }, { "expression": "public", "action": "Include", "expressionType": "Exact", "objectType": "Schema" } ], "transformationRules": [ { "ruleTargetType": "Table", "ruleActionType": "SourceSchema", "ruleName": "SourceSchema_Table_BStf8aXPSCJjOWGe" }, { "ruleTargetType": "Schema", "ruleActionType": "Rename", "ruleName": "Rename_Schema_3qWNOIsljtInvKJy" }, { "ruleTargetType": "Table", "ruleActionType": "Rename", "ruleName": "Rename_Table_o3PVQq1aIKDGoVVW" }, { "ruleTargetType": "Table", "ruleActionType": "DefineDstTableSettings", "ruleName": "DefineDstTableSettings_Table_BhJltOmOCIc81fzi" }, { "ruleTargetType": "Table", "ruleActionType": "ColumnMapping", "ruleName": "ColumnMapping_Table_nP4hJPX1wh2W3fpo" } ] } ], "sourceDataSourceSettings": [ { "dataSourceProperties": { "timeZone": "Asia/Shanghai" }, "dataSourceName": "autotest_hologres" } ], "jobSettings": { "runtimeSettings": [ ], "ddlHandlingSettings": [ ], "columnDataTypeSettings": [ ], "cycleScheduleSettings": { }, "channelSettings": { "destinationChannelSettings": { "conflictMode": "replace", "dynamicColumnAction": "replay", "writeMode": "replay" }, "sourceChannelSettings": { } } }, "destinationDataSourceType": "Hologres", "transformationRules": [ { "ruleTargetType": "Table", "ruleName": "SourceSchema_Table_BStf8aXPSCJjOWGe", "ruleActionType": "SourceSchema", "ruleExpression": { "columns": [ { "name": "id", "category": "normal", "type": "BIGINT" }, { "name": "decimal", "category": "normal", "type": "DECIMAL" } ] } }, { "ruleTargetType": "Schema", "ruleName": "Rename_Schema_3qWNOIsljtInvKJy", "ruleActionType": "Rename", "ruleExpression": { "expression": "public" } }, { "ruleTargetType": "Table", "ruleName": "Rename_Table_o3PVQq1aIKDGoVVW", "ruleActionType": "Rename", "ruleExpression": { "expression": "auto_holo_2661647_dst" } }, { "ruleTargetType": "Table", "ruleName": "DefineDstTableSettings_Table_BhJltOmOCIc81fzi", "ruleActionType": "DefineDstTableSettings", "ruleExpression": { "ddlString": "BEGIN; CREATE TABLE IF NOT EXISTS public.auto_holo_2661647_dst ( id BIGINT PRIMARY KEY, "decimal" DECIMAL(38,18) ); CALL SET_TABLE_PROPERTY('public.auto_holo_2661647_dst', 'time_to_live_in_seconds', '3153600000'); CALL SET_TABLE_PROPERTY('public.auto_holo_2661647_dst', 'orientation', 'column'); CALL SET_TABLE_PROPERTY('public.auto_holo_2661647_dst', 'binlog.level', 'replica'); CALL SET_TABLE_PROPERTY('public.auto_holo_2661647_dst', 'binlog.ttl', '2592000'); CALL SET_TABLE_PROPERTY('public.auto_holo_2661647_dst', 'bitmap_columns', '"text","char","varchar"'); CALL SET_TABLE_PROPERTY('public.auto_holo_2661647_dst', 'dictionary_encoding_columns', '"text":auto,"bytea":auto,"char":auto,"varchar":auto'); CALL SET_TABLE_PROPERTY('public.auto_holo_2661647_dst', 'distribution_key', '"id"'); COMMIT; ", "ddlType": "STRUCT" } }, { "ruleTargetType": "Table", "ruleName": "ColumnMapping_Table_nP4hJPX1wh2W3fpo", "ruleActionType": "ColumnMapping", "ruleExpression": { "columnMapping": [ { "sourceColName": "id", "dstColName": "id" }, { "sourceColName": "decimal", "dstColName": "decimal" } ] } } ], "migrationType": "FullAndRealtimeIncremental", "destinationDataSourceSettings": [ { "dataSourceProperties": { }, "dataSourceName": "autotest_hologres" } ], "sourceDataSourceType": "Hologres" }

    Elemen respons

    Element

    Type

    Description

    Example

    object

    Skema respons.

    Success

    boolean

    Menunjukkan apakah permintaan berhasil. Nilai yang valid:

    • true: Permintaan berhasil.

    • false: Permintaan gagal.

    true
    RequestId

    string

    ID permintaan. Anda dapat menggunakan ID ini untuk memecahkan masalah.

    AAC30B35-820D-5F3E-A42C-E96BB****

    Contoh

    Respons sukses

    JSONformat

    {
  "Success": true,
  "RequestId": "AAC30B35-820D-5F3E-A42C-E96BB****"
}

    Kode kesalahan

    Lihat Error Codes untuk daftar lengkap.

    Catatan rilis

    Lihat Release Notes untuk daftar lengkap.