Modul Rute Flink CDC - Realtime Compute for Apache Flink

Modul rute mendefinisikan aturan untuk memetakan tabel sumber ke tabel sink. Topik ini menjelaskan sintaks untuk mendefinisikan aturan routing.

Parameter

Parameter	Deskripsi	Diperlukan	Catatan
`source-table`	Menentukan tabel sumber.	Diperlukan	Mendukung ekspresi reguler.
`sink-table`	Menentukan tabel sink.	Diperlukan
`replace-symbol`	Menentukan string dalam nama tabel sink yang akan diganti dengan nama tabel sumber.	Opsional	Sebagai contoh, ketika `replace-symbol` diatur ke `<>`, Anda dapat mengonfigurasi `sink-table` sebagai `sinkdb.<>`. Jika tabel sumber adalah `table1`, data direplikasi ke tabel sink dengan nama identik `sinkdb.table1`.
`description`	Deskripsi dari aturan routing.	Opsional

Penting

Lakukan startup tanpa status setelah memodifikasi modul rute untuk menerapkan aturan baru.

Contoh

Menyinkronkan data dari tabel sumber ke tabel sink

Route data dari tabel sumber mysql_db.web_order ke tabel sink sink_db.ods_web_order:

route:
  - source-table: mysql_db.web_order
    sink-table: sink_db.ods_web_order
    description: sync data from a source table to a sink table

Menyinkronkan data dari tabel sumber ke beberapa tabel sink

Untuk menyalin data dari tabel sumber ke beberapa tabel sink, definisikan beberapa aturan routing. Kode berikut mereplikasi data dari mydb.orders ke sink_db.orders dan backup_sink_db.orders secara bersamaan.

route:
  - source-table: mydb.orders
    sink-table: sink_db.orders
  - source-table: mydb.orders
    sink-table: backup_sink_db.orders

Menyinkronkan data dari beberapa tabel sumber ke beberapa tabel sink

Tentukan beberapa aturan menggunakan tanda hubung (-), yang merupakan indikator daftar YAML. Semua aturan ini diterapkan secara bersamaan.

route:
  - source-table: mydb.orders
    sink-table: ods_db.ods_orders
    description: sync orders table to ods_orders
  - source-table: mydb.shipments
    sink-table: ods_db.ods_shipments
    description: sync shipments table to ods_shipments
  - source-table: mydb.products
    sink-table: ods_db.ods_products
    description: sync products table to ods_products

Menyinkronkan data dari beberapa tabel sumber ke tabel sink

Gabungkan semua tabel dari database source_db ke dalam tabel target sink_db.merged.

route:
  - source-table: source_db.\.*
    sink-table: sink_db.merged
    description: sync data from multiple source tables to a sink table

Sinkronisasi database

Sinkronkan semua tabel dari database source_db ke tabel-tabel yang sesuai di database sink_db, dengan tetap mempertahankan nama tabel.

route:
  - source-table: source_db.\.*
    sink-table: sink_db.<>
    replace-symbol: <>
    description: route all tables in source_db to sink_db

Simbol <> adalah placeholder untuk nama tabel sumber, yang memungkinkan pemetaan satu-satu dari tabel sumber ke tabel sink.