Data Transmission Service:Sinkronisasi data dari instans set replika ApsaraDB for MongoDB ke fungsi Function Compute

Database sumber

Batasan lainnya

• DTS tidak dapat menyinkronkan database admin, config, atau local.

• Sinkronisasi data penuh tidak didukung — hanya inkremental.

• Sinkronisasi lintas wilayah tidak didukung.

• Fitur pemetaan nama objek tidak didukung.

• Tetapkan hanya satu tugas DTS per fungsi tujuan untuk menghindari kesalahan data.

• Konteks transaksi tidak dipertahankan. Setiap transaksi dikonversi menjadi catatan individual.

• Jika tugas DTS gagal, dukungan teknis DTS berusaha memulihkannya dalam waktu 8 jam. Tugas mungkin dimulai ulang dan parameter tugas (bukan parameter database) dapat dimodifikasi selama pemulihan.

Kasus khusus (MongoDB yang dikelola sendiri)

• Alih bencana primer/sekunder saat tugas sedang berjalan menyebabkan tugas gagal.

• Latensi sinkronisasi dihitung dari stempel waktu catatan terbaru yang disinkronkan dibandingkan dengan stempel waktu sumber saat ini. Jika tidak ada operasi tulis pada sumber dalam periode yang lama, latensi yang dilaporkan mungkin tidak akurat. Tulis catatan ke database sumber untuk memperbarui pembacaan latensi.

Jika Anda menyinkronkan seluruh database, buat tabel heartbeat. DTS memperbarui tabel heartbeat setiap detik, sehingga menjaga akurasi pembacaan latensi.

Langkah 1: Buka halaman Sinkronisasi Data

Gunakan salah satu konsol berikut:

Langkah 2: Konfigurasi database sumber dan tujuan

Klik Create Task, lalu konfigurasikan parameter yang dijelaskan dalam tabel berikut.

Umum

Database sumber

Database tujuan

Langkah 3: Uji konektivitas

Klik Test Connectivity and Proceed di bagian bawah halaman.

Blok CIDR server DTS harus ditambahkan ke pengaturan keamanan database sumber dan tujuan. Lihat Tambahkan blok CIDR server DTS. Jika sumber atau tujuan adalah database yang dikelola sendiri yang tidak menggunakan akses Alibaba Cloud Instance, klik Test Connectivity di kotak dialog CIDR Blocks of DTS Servers.

Langkah 4: Konfigurasi objek untuk disinkronkan

Pada langkah Configure Objects, atur parameter berikut.

Klik Next: Advanced Settings.

Langkah 5: Konfigurasi pengaturan lanjutan

Langkah 6: Jalankan pemeriksaan awal

Klik Next: Save Task Settings and Precheck.

Untuk melihat pratinjau parameter OpenAPI untuk konfigurasi tugas ini, arahkan pointer ke Next: Save Task Settings and Precheck lalu klik Preview OpenAPI parameters.

DTS menjalankan pemeriksaan awal sebelum memulai tugas. Jika pemeriksaan awal gagal:

• Untuk setiap item yang gagal, klik View Details, selesaikan masalahnya, lalu klik Precheck Again.

• Untuk item peringatan yang dapat diabaikan: klik Confirm Alert Details > Ignore > OK > Precheck Again. Mengabaikan peringatan dapat menyebabkan inkonsistensi data.

Langkah 7: Beli instans

1. Tunggu hingga Success Rate mencapai 100%, lalu klik Next: Purchase Instance.

2. Di halaman pembelian, konfigurasikan parameter berikut.

1. Setujui Ketentuan Layanan Data Transmission Service (Pay-as-you-go).

2. Klik Buy and Start, lalu klik OK di kotak dialog.

Tugas muncul di daftar tugas. Pantau perkembangannya dari sana.

Contoh DDL

Contoh DML

// Sisipkan beberapa catatan sekaligus
db.runCommand({insert: "user", documents: [{"name":"jack","age":20},{"name":"lili","age":20}]})

// Sisipkan satu catatan per waktu
db.user.insert({"name":"jack","age":20})
db.user.insert({"name":"lili","age":20})

{
  "Records": [
    {
      "data": [{"doc": "{\"_id\": {\"$oid\": \"64f9397f6e255f74d65a****\"}, \"name\": \"jack\", \"age\": 20}"}],
      "pkNames": ["_id"],
      "type": "INSERT",
      "es": 1694054783000,
      "database": "MongoDBTest",
      "id": 0,
      "isDdl": false,
      "table": "user",
      "ts": 1694054784427
    },
    {
      "data": [{"doc": "{\"_id\": {\"$oid\": \"64f9397f6e255f74d65a****\"}, \"name\": \"lili\", \"age\": 20}"}],
      "pkNames": ["_id"],
      "type": "INSERT",
      "es": 1694054783000,
      "database": "MongoDBTest",
      "id": 0,
      "isDdl": false,
      "table": "user",
      "ts": 1694054784428
    }
  ]
}

db.user.update({"name":"jack"},{$set:{"age":30}})

{
  "Records": [{
    "data": [{"doc": "{\"$set\": {\"age\": 30}}"}],
    "pkNames": ["_id"],
    "old": [{"doc": "{\"_id\": {\"$oid\": \"64f9397f6e255f74d65a****\"}}"}],
    "type": "UPDATE",
    "es": 1694054989000,
    "database": "MongoDBTest",
    "id": 0,
    "isDdl": false,
    "table": "user",
    "ts": 1694054990555
  }]
}

db.user.remove({"name":"jack"})

{
  "Records": [{
    "data": [{"doc": "{\"_id\": {\"$oid\": \"64f9397f6e255f74d65a****\"}}"}],
    "pkNames": ["_id"],
    "type": "DELETE",
    "es": 1694055452000,
    "database": "MongoDBTest",
    "id": 0,
    "isDdl": false,
    "table": "user",
    "ts": 1694055452852
  }]
}