Anda dapat menggunakan node PolarDB for PostgreSQL di DataWorks untuk mengembangkan dan menjadwalkan tugas PolarDB for PostgreSQL secara berkala, serta mengintegrasikannya dengan pekerjaan lain. Topik ini menjelaskan proses utama pengembangan tugas menggunakan node PolarDB for PostgreSQL.
Informasi latar belakang
PolarDB for PostgreSQL adalah produk database relasional cloud-native yang dikembangkan oleh Alibaba Cloud. Produk ini 100% kompatibel dengan PostgreSQL dan menyediakan kompatibilitas tinggi dengan sintaks Oracle. Layanan ini menawarkan database yang cepat, elastis, berkinerja tinggi, aman, andal, serta memiliki kemampuan penyimpanan massal. PolarDB for PostgreSQL juga mendukung mesin informasi spasial-temporal multi-dimensi dan multi-modal Ganos yang dikembangkan oleh Alibaba Cloud serta mesin informasi geografis open source PostGIS. Untuk informasi selengkapnya, lihat PolarDB for PostgreSQL.
Prasyarat
Buat Business Flow.
DataStudio mengorganisasi pengembangan berdasarkan Business Flow. Anda harus membuatnya terlebih dahulu sebelum membuat node. Untuk informasi selengkapnya, lihat Create a workflow.
Anda telah membuat sumber data PolarDB for PostgreSQL.
Anda harus menambahkan database PolarDB for PostgreSQL Anda sebagai sumber data PolarDB for PostgreSQL di DataWorks agar dapat mengakses datanya melalui sumber data tersebut. Untuk informasi selengkapnya tentang cara membuat sumber data, lihat Data Source Management. Untuk informasi lebih lanjut tentang cara menggunakan sumber data PolarDB for PostgreSQL di DataWorks, lihat PolarDB data sources.
CatatanNode PolarDB for MySQL hanya mendukung sumber data PolarDB for MySQL yang dibuat dengan string koneksi JDBC.
Koneksi jaringan antara sumber data dan resource group telah dibuat.
Pastikan sumber data dapat terhubung ke resource group yang ingin Anda gunakan. Untuk informasi tentang cara mengonfigurasi konektivitas jaringan, lihat Network connection solutions.
(Opsional; wajib untuk Pengguna RAM) Tambahkan Pengguna RAM ke ruang kerja dan tetapkan peran Develop atau Workspace Administrator. Berikan peran Workspace Administrator dengan hati-hati karena hak istimewanya yang tinggi. Untuk informasi selengkapnya, lihat Add members to a workspace.
Batasan
Wilayah yang didukung: China (Hangzhou), China (Shanghai), China (Beijing), China (Shenzhen), China (Chengdu), China (Hong Kong), Singapura, Malaysia (Kuala Lumpur), Jerman (Frankfurt), AS (Silicon Valley), dan AS (Virginia).
Langkah 1: Buat node PolarDB for PostgreSQL
Buka halaman DataStudio.
Masuk ke DataWorks console. 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, atur parameter Name untuk node tersebut dan klik OK. Setelah node dibuat, Anda dapat mengembangkan dan mengonfigurasi tugas pada tab konfigurasi node.
Langkah 2: Kembangkan tugas PolarDB for PostgreSQL
(Opsional) Pilih sumber data PolarDB for PostgreSQL
Jika terdapat beberapa sumber data PolarDB for PostgreSQL di ruang kerja Anda, Anda harus memilih sumber data yang diinginkan pada halaman pengeditan node. Jika hanya terdapat satu sumber data PolarDB for PostgreSQL, 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 PostgreSQL, tulis kode untuk tugas yang ingin Anda eksekusi. Kode berikut memberikan contohnya.
SELECT * FROM usertablename;Kembangkan kode SQL: Gunakan parameter penjadwalan
DataWorks menyediakan scheduling parameters yang memungkinkan Anda meneruskan nilai secara dinamis ke variabel dalam kode untuk penjadwalan berulang. Anda dapat mendefinisikan variabel dalam format ${variable_name} pada kode tugas Anda. Kemudian, pada tab Schedule di panel navigasi kanan, klik Scheduling parameters untuk memberikan nilai pada variabel tersebut. Untuk informasi selengkapnya tentang format dan konfigurasi scheduling parameters yang didukung, lihat Supported formats of scheduling parameters dan Configure and use scheduling parameters.
Kode berikut memberikan contohnya.
SELECT '${var}'; -- Anda dapat menggunakan ini bersama scheduling parameters.Langkah 3: Konfigurasi penjadwalan tugas
Untuk menjadwalkan tugas, klik Scheduling Configuration di sebelah kanan dan konfigurasikan propertinya. Untuk informasi selengkapnya, lihat Overview.
Konfigurasikan Rerun Property dan Upstream Dependent Node sebelum menyerahkan.
Langkah 4: Debug kode tugas
Debug tugas untuk memastikan eksekusi yang benar:
(Opsional) Pilih resource group debugging dan tetapkan nilai parameter.
Klik ikon
di bilah alat. Pada kotak dialog Parameters, pilih resource group.Tetapkan nilai untuk setiap parameter penjadwalan guna debugging. Untuk informasi selengkapnya tentang logika penetapan parameter, lihat Task debugging process.
Simpan dan jalankan kode tugas.
Klik ikon
untuk menyimpan, lalu klik ikon
untuk menjalankan.(Opsional) Jalankan pengujian asap.
Jalankan pengujian asap selama atau setelah penyerahan untuk memverifikasi eksekusi di lingkungan pengembangan. Untuk informasi selengkapnya, lihat Perform smoke testing.
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 Code review.
Pada ruang kerja mode standar, klik Publish di pojok kanan atas untuk men-deploy ke produksi. Untuk informasi selengkapnya, lihat Publish tasks.
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 Operation Center. Di Operation Center, Anda dapat melihat status penjadwalan dan eksekusi tugas berulang tersebut. Untuk informasi selengkapnya, lihat Manage recurring tasks.