Artikel ini menjelaskan cara menggunakan Kettle untuk mengimpor data lokal ke AnalyticDB for MySQL . Contoh ini menggunakan data Excel.
Informasi latar belakang
Kettle adalah alat ETL (ekstraksi-transformasi-pemuatan) sumber terbuka populer yang digunakan untuk pengumpulan, konversi, dan migrasi data. Kettle mendukung berbagai database relasional serta database NoSQL seperti HBase dan MongoDB, serta sumber data khusus seperti Microsoft Office Excel dan Access. Dengan ekstensi dan plugin, Kettle dapat mendukung lebih banyak jenis sumber data.
Persiapan
Instal Kettle.
Tambahkan alamat IP perangkat tempat Kettle diinstal ke daftar putih kluster AnalyticDB for MySQL. Untuk informasi lebih lanjut, lihat Konfigurasikan Daftar Putih Alamat IP.
Jika Anda ingin terhubung ke kluster AnalyticDB for MySQL melalui Internet, ajukan titik akhir publik untuk kluster tersebut. Untuk informasi lebih lanjut, lihat Ajukan atau Lepaskan Titik Akhir Publik.
Prosedur
Mulai Kettle, lalu pilih untuk membuat tugas konversi.
Pilih untuk membuat koneksi database untuk tugas konversi.
Parameter
Deskripsi
Connection Name
Nama koneksi. Kami sarankan Anda menentukan nama deskriptif yang mudah dikenali.
Connection Type
Mesin database sumber. Pilih MySQL.
Access
Mode akses koneksi. Pilih Native (JDBC).
Host Name
Titik akhir yang digunakan untuk terhubung ke kluster AnalyticDB for MySQL. Anda dapat melihat informasi koneksi tentang kluster pada halaman Cluster Information dari konsol AnalyticDB for MySQL. Untuk informasi lebih lanjut, lihat Terhubung ke kluster AnalyticDB for MySQL.
Database Name
Nama database AnalyticDB for MySQL.
Port Number
Nomor port yang digunakan untuk terhubung ke kluster AnalyticDB for MySQL. Nomor port default adalah 3306.
User Name
Nama akun database yang digunakan untuk terhubung ke kluster AnalyticDB for MySQL. Anda dapat menggunakan salah satu jenis akun berikut:
Akun istimewa
Akun standar
Password
Kata sandi akun yang digunakan untuk terhubung ke kluster AnalyticDB for MySQL.
CatatanJangan pilih Use Result Streaming Cursor saat mengonfigurasi parameter.
Setelah mengonfigurasi parameter sebelumnya, klik Test. Di kotak dialog Database Connection Test, ikuti petunjuk untuk memverifikasi apakah koneksi ke database AnalyticDB for MySQL berhasil. Setelah koneksi lulus tes, klik OK.
Di panel navigasi kiri Kettle, klik tab Core objects dan pilih Input > Excel Input. Kemudian, seret dan jatuhkan Input Excel ke ruang kerja.
Klik dua kali Excel Input di ruang kerja. Di kotak dialog Excel Input, klik Browse dan Add untuk menambahkan file Excel ke Selected Files.
Konfigurasikan parameter pada tab-tab seperti Worksheet, Content, dan Field, lalu klik Preview untuk memeriksa apakah nilai yang ditentukan sesuai dengan persyaratan Anda.
Di panel navigasi kiri Kettle, klik tab Core objects dan pilih Output > Table Output. Kemudian, seret dan jatuhkan Output Tabel ke ruang kerja.
Tambahkan garis koneksi dari Excel Input ke Table Output.
Klik dua kali Table Output di ruang kerja. Di kotak dialog Table Output, konfigurasikan parameter.
Target Schema: Masukkan nama database AnalyticDB for MySQL.
Target Table: Masukkan nama tabel di database AnalyticDB for MySQL.
Pilih Specify database fields.
Pilih Use batch update for inserts.
Di tab Bidang Database kotak dialog Table Output, klik Get fields dan Enter field mapping untuk memetakan kolom di file Excel ke kolom di tabel AnalyticDB for MySQL.
Klik panah putih untuk menjalankan konversi. Selama proses ini, Anda dapat memeriksa log operasi dan statusnya.
Setelah data di file Excel diimpor ke database AnalyticDB for MySQL, Anda dapat menggunakan AnalyticDB for MySQL untuk menganalisis data.