View a markdown version of this page

Memuat data dari cluster DB PostgreSQL Aurora atau RDS untuk instance PostgreSQL DB - Amazon Aurora

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Memuat data dari cluster DB PostgreSQL Aurora atau RDS untuk instance PostgreSQL DB

Setelah Anda menyelesaikan pengaturan sumber daya dan otentikasi, sambungkan ke titik akhir cluster dan panggil prosedur rds_aurora.limitless_data_load_start tersimpan dari database tanpa batas, seperti. postgres_limitless Basis data tanpa batas adalah database pada grup pecahan DB tempat Anda ingin memigrasikan data.

Fungsi ini menghubungkan secara asinkron di latar belakang ke database sumber yang ditentukan dalam perintah, membaca data dari sumber, dan memuat data ke pecahan. Untuk kinerja yang lebih baik, data dimuat menggunakan thread paralel. Fungsi mengambil snapshot tabel point-in-time dengan menjalankan SELECT perintah untuk membaca data tabel yang disediakan dalam perintah.

Anda dapat memuat data ke dalam tabel sharded, referensi, dan standar.

Anda dapat memuat data di database, skema, atau tingkat tabel dalam rds_aurora.limitless_data_load_start panggilan.

  • Database - Anda dapat memuat satu database pada satu waktu di setiap panggilan, tanpa batas pada skema atau jumlah tabel dalam database.

  • Skema - Anda dapat memuat maksimum 15 skema di setiap panggilan, tanpa batas jumlah tabel dalam setiap skema.

  • Tabel — Anda dapat memuat maksimal 15 tabel di setiap panggilan.

catatan

Fitur ini tidak menggunakan snapshot Amazon RDS atau isolasi point-in-time database. Untuk konsistensi di seluruh tabel, kami sarankan untuk mengkloning database sumber dan menunjuk ke database kloning itu sebagai sumbernya.

Prosedur tersimpan menggunakan sintaks berikut:

CALL rds_aurora.limitless_data_load_start('source_type',
    'source_DB_cluster_or_instance_ID',
    'source_database_name',
    'streaming_mode',
    'data_loading_IAM_role_arn',
    'source_DB_secret_arn',
    'destination_DB_secret_arn',
    'ignore_primary_key_conflict_boolean_flag',
    'is_dry_run',
    (optional parameter) schemas/tables => ARRAY['name1', 'name2', ...]);

Parameter input adalah sebagai berikut:

  • source_type— Jenis sumber: aurora_postgresql atau rds_postgresql

  • source_DB_cluster_or_instance_ID— Sumber pengidentifikasi cluster Aurora PostgreSQL DB atau RDS untuk pengidentifikasi instans PostgreSQL DB

  • source_database_nameNama database sumber, seperti postgres

  • streaming_mode— Apakah akan menyertakan pengambilan data perubahan (CDC): full_load atau full_load_and_cdc

  • data_loading_IAM_role_arn— Peran IAM Nama Sumber Daya Amazon (ARN) untuk aurora-data-loader

  • source_DB_secret_arn— Sumber DB rahasia ARN

  • destination_DB_secret_arn— Arn rahasia DB tujuan

  • ignore_primary_key_conflict_boolean_flag— Apakah akan melanjutkan jika konflik kunci utama terjadi:

    • Jika disetel ketrue, pemuatan data mengabaikan perubahan baru untuk baris dengan konflik kunci primer.

    • Jika disetel kefalse, pemuatan data menimpa baris yang ada pada tabel tujuan saat menghadapi konflik kunci primer.

  • is_dry_run— Apakah akan menguji bahwa pekerjaan pemuatan data dapat terhubung ke database sumber dan tujuan:

    • Jika disetel ketrue, uji koneksi tanpa memuat data

    • Jika diatur kefalse, memuat data

  • (opsional) schemas atau tables — Sebuah array skema atau tabel untuk memuat. Anda dapat menentukan salah satu dari berikut ini:

    • Daftar tabel dalam format tables => ARRAY['schema1.table1', 'schema1.table2', 'schema2.table1', ...]

    • Daftar skema dalam format schemas => ARRAY['schema1', 'schema2', ...]

    Jika Anda tidak menyertakan parameter ini, seluruh database sumber yang ditentukan akan dimigrasikan.

Parameter output adalah ID pekerjaan dengan pesan.

Contoh berikut menunjukkan bagaimana menggunakan prosedur rds_aurora.limitless_data_load_start tersimpan untuk memuat data dari cluster Aurora PostgreSQL DB.

CALL rds_aurora.limitless_data_load_start('aurora_postgresql',
    'my-db-cluster',
    'postgres',
    'full_load_and_cdc',
    'arn:aws:iam::123456789012:role/aurora-data-loader-8f2c66',
    'arn:aws:secretsmanager:us-east-1:123456789012:secret:secret-source-8f2c66-EWrr0V',
    'arn:aws:secretsmanager:us-east-1:123456789012:secret:secret-destination-8f2c66-d04fbD',
    'true',
    'false',
    tables => ARRAY['public.customer', 'public.order', 'public.orderdetails']);

INFO: limitless data load job id 1688761223647 is starting.