Anda dapat menggunakan node PolarDB for MySQL di DataWorks untuk mengembangkan tugas, menjadwalkannya agar berjalan secara berkala, serta mengintegrasikannya dengan pekerjaan lain. Topik ini menjelaskan alur kerja utama untuk mengembangkan tugas menggunakan node PolarDB for MySQL.
Informasi latar belakang
PolarDB for MySQL adalah database cloud-native generasi baru yang dikembangkan oleh Alibaba Cloud. Database ini menggunakan arsitektur terpisah penyimpanan-komputasi dan menggabungkan keunggulan perangkat lunak serta perangkat keras untuk menyediakan layanan database yang sangat elastis, berkinerja tinggi, aman, dan memiliki kapasitas penyimpanan massal. Layanan ini 100% kompatibel dengan ekosistem MySQL dan PostgreSQL serta sangat kompatibel dengan sintaks Oracle. Untuk informasi selengkapnya, lihat PolarDB for MySQL.
Prasyarat
Buat Business Flow.
DataStudio mengorganisasi pengembangan berdasarkan Business Flow. Anda harus membuatnya terlebih dahulu sebelum membuat node. Untuk informasi selengkapnya, lihat Buat alur kerja.
Sumber data PolarDB for MySQL telah dibuat.
Anda harus menambahkan database PolarDB for MySQL Anda sebagai sumber data di DataWorks untuk mengakses datanya. Untuk petunjuk cara membuat sumber data, lihat Manajemen Sumber Data. Untuk informasi lebih lanjut tentang cara menggunakan sumber data PolarDB for MySQL di DataWorks, lihat Sumber Data PolarDB.
CatatanNode PolarDB for MySQL hanya mendukung sumber data PolarDB for MySQL yang dibuat menggunakan string koneksi Java Database Connectivity (JDBC).
Koneksi jaringan antara sumber data dan kelompok sumber daya telah dibuat.
Pastikan sumber data dapat terhubung ke kelompok sumber daya yang ingin Anda gunakan. Untuk informasi tentang cara mengonfigurasi konektivitas jaringan, lihat Solusi koneksi jaringan.
(Opsional; wajib bagi pengguna RAM) Tambahkan pengguna RAM ke ruang kerja dan tetapkan peran Develop atau Workspace Administrator. Berikan peran Workspace Administrator dengan hati-hati karena memiliki hak istimewa yang tinggi. Untuk informasi selengkapnya, lihat Tambahkan anggota ke ruang kerja.
Batasan
Wilayah yang didukung: Tiongkok (Hangzhou), Tiongkok (Shanghai), Tiongkok (Beijing), Tiongkok (Shenzhen), Tiongkok (Chengdu), Tiongkok (Hong Kong), Singapura, Malaysia (Kuala Lumpur), Jerman (Frankfurt), AS (Silicon Valley), dan AS (Virginia).
Langkah 1: Buat node PolarDB for MySQL
Buka halaman DataStudio.
Masuk ke Konsol DataWorks. Di bilah navigasi atas, pilih wilayah yang diinginkan. Di panel navigasi kiri, pilih . Pada halaman yang muncul, pilih ruang kerja yang diinginkan dari daftar drop-down dan klik Go to Data Development.
Klik kanan proses bisnis target dan pilih .
Pada kotak dialog Create Node, masukkan Name untuk node tersebut dan klik OK. Setelah node dibuat, Anda dapat mengembangkan dan mengonfigurasi tugas tersebut.
Langkah 2: Kembangkan tugas PolarDB for MySQL
(Opsional) Pilih sumber data PolarDB for MySQL
Jika ruang kerja Anda memiliki beberapa sumber data PolarDB for MySQL, pilih sumber data yang diperlukan pada halaman pengeditan node. Jika hanya ada satu sumber data, sumber data tersebut akan digunakan secara default.
Node PolarDB for MySQL hanya mendukung sumber data PolarDB for MySQL yang dibuat menggunakan string koneksi Java Database Connectivity (JDBC).
Kembangkan kode SQL: Contoh sederhana
Pada editor kode node PolarDB for MySQL, tulis kode SQL untuk tugas tersebut. Kode berikut merupakan contohnya.
SELECT * FROM usertablename;Kembangkan kode SQL: Gunakan parameter penjadwalan
DataWorks menyediakan scheduling parameters untuk memungkinkan input dinamis dalam tugas yang dijadwalkan secara berulang. Anda dapat mendefinisikan variabel dalam kode menggunakan format ${variable_name}. Selanjutnya, Anda dapat memberikan nilai variabel tersebut di bagian Scheduling Parameters di bawah Schedule pada panel navigasi kanan halaman pengeditan node. Untuk informasi selengkapnya tentang format yang didukung dan cara mengonfigurasi parameter penjadwalan, lihat Format yang didukung untuk parameter penjadwalan dan Konfigurasi dan penggunaan parameter penjadwalan.
Kode berikut merupakan contohnya.
SELECT '${var}'; -- Anda dapat menggunakan ini bersama parameter penjadwalan.Langkah 3: Konfigurasi penjadwalan tugas
Untuk menjadwalkan tugas, klik Scheduling Configuration di sebelah kanan dan konfigurasikan propertinya. Untuk informasi selengkapnya, lihat Ikhtisar.
Konfigurasikan Rerun Property dan Upstream Dependent Node sebelum menyerahkan.
Langkah 4: Debug kode tugas
Debug tugas untuk memastikan eksekusi yang benar:
(Opsional) Pilih kelompok sumber daya debugging dan tetapkan nilai parameter.
Klik ikon
di bilah alat. Pada kotak dialog Parameters, pilih kelompok sumber daya.Tetapkan nilai untuk setiap parameter penjadwalan yang digunakan saat debugging. Untuk informasi selengkapnya tentang logika penetapan parameter, lihat Proses debugging tugas.
Simpan dan jalankan kode tugas.
Klik ikon
untuk menyimpan, lalu klik ikon
untuk menjalankan.(Opsional) Jalankan pengujian asap.
Lakukan pengujian asap selama atau setelah penyerahan untuk memverifikasi eksekusi di lingkungan pengembangan. Untuk informasi selengkapnya, lihat Lakukan pengujian asap.
Langkah 5: Serahkan dan publikasikan tugas
Serahkan dan publikasikan node untuk mengaktifkan penjadwalan.
Klik ikon
di bilah alat untuk menyimpan node.Klik ikon
di bilah alat untuk menyerahkan tugas node.Pada kotak dialog Submit, masukkan Change Description dan pilih opsi tinjauan kode.
CatatanKonfigurasikan Rerun Property dan Upstream Dependent Node sebelum menyerahkan.
Tinjauan kode memastikan kualitas. Jika diaktifkan, peninjau harus menyetujui kode sebelum dipublikasikan. Untuk informasi selengkapnya, lihat Tinjauan kode.
Di ruang kerja mode standar, klik Publish di sudut kanan atas untuk menerapkan ke produksi. Untuk informasi selengkapnya, lihat Tugas penerbitan.
Langkah selanjutnya
Setelah tugas diserahkan dan dipublikasikan, tugas tersebut akan dijalankan secara berkala sesuai konfigurasi node. Anda dapat mengklik O&M di pojok kanan atas tab konfigurasi node untuk membuka Pusat Operasi. Di Pusat Operasi, Anda dapat melihat status penjadwalan dan eksekusi tugas berkala tersebut. Untuk informasi selengkapnya, lihat Kelola tugas berkala.