Di DataWorks, Anda dapat menggunakan node CDH Presto untuk analitik data real-time. Node ini menyediakan mesin kueri SQL terdistribusi guna meningkatkan kemampuan analitik data di lingkungan CDH Anda. Topik ini menjelaskan cara mengonfigurasi dan menggunakan node CDH Presto.
Prasyarat
Anda telah membuat kluster Alibaba Cloud CDH dan mengaitkannya dengan ruang kerja DataWorks. Untuk informasi selengkapnya, lihat Associate a CDH compute engine.
PentingPastikan komponen Presto telah diinstal pada kluster CDH Anda dan Anda telah mengonfigurasi informasi terkait saat melakukan bind kluster.
-
(Opsional, untuk pengguna RAM) Pengguna RAM untuk pengembangan task telah ditambahkan ke ruang kerja yang sesuai dan diberikan peran Development atau Workspace Administrator. Peran Workspace Administrator memiliki izin yang luas, jadi berikan dengan hati-hati. Untuk informasi selengkapnya tentang penambahan anggota, lihat Add members to a workspace.
CatatanJika Anda menggunakan Akun Alibaba Cloud, Anda dapat melewati langkah ini.
Anda telah mengonfigurasi sumber data Hive di DataWorks dan memverifikasi bahwa sumber data tersebut lulus uji konektivitas. Untuk informasi selengkapnya, lihat Manage data sources.
Create a node
Untuk petunjuknya, lihat Create a node.
Node development
Anda dapat mengembangkan kode task di editor SQL dengan mendefinisikan variabel menggunakan format ${variable_name}. Tetapkan nilai variabel tersebut di bagian Scheduling Parameters pada panel Scheduling Settings di sisi kanan halaman pengeditan node. Pendekatan ini memungkinkan Anda untuk secara dinamis pass parameter ke kode saat node dijalankan sesuai jadwal. Untuk informasi selengkapnya tentang scheduling parameters, lihat Sources and expressions of scheduling parameters. Kode berikut memberikan contohnya.
SHOW TABLES;
SELECT * FROM userinfo ;
-- You can use this with scheduling parameters.
SELECT '${var}'; Node debugging
Pada tab Run Configuration, konfigurasikan Compute Resource dan Resource Group di bagian Compute Resource.
Untuk Compute resource, pilih nama kluster CDH yang telah Anda daftarkan di DataWorks.
Pilih kelompok sumber daya penjadwalan yang telah lulus uji konektivitas dengan sumber data. Untuk informasi selengkapnya, lihat Network Connectivity Solutions.
Pada bilah alat di bagian atas halaman pengeditan node, klik Run.
Langkah berikutnya
Configure node scheduling: Jika Anda perlu menjalankan node secara berkala, konfigurasikan Scheduling Policy-nya di panel Scheduling Settings di sisi kanan.
Publish a node: Untuk menjalankan task di lingkungan produksi, klik ikon
untuk memublikasikan node. Node hanya akan dijalankan sesuai jadwal setelah dipublikasikan ke lingkungan produksi.Task O&M: Setelah task dipublikasikan, Anda dapat memantau status eksekusi berkala-nya di Operation Center. Untuk informasi selengkapnya, lihat Get started with Operation Center.