AnalyticDB:Jadwalkan XIHE SQL dengan DataWorks

Tujuan

Menentukan dependensi antar tugas merupakan fitur utama dalam penjadwalan tugas. Tutorial ini menunjukkan cara membuat dua tugas AnalyticDB for MySQL yang saling bergantung di DataWorks. Gambar berikut mengilustrasikan hubungan antara tabel dan tugas.

• Task 1

  Bersihkan tabel orders dengan memfilter pesanan yang telah selesai, yaitu o_orderstatus = 'F', lalu tulis hasilnya ke tabel finished_orders.

• Task 2

  Kueri tabel finished_orders untuk mencari pesanan dengan harga total lebih dari 10.000, yaitu o_totalprice > 10000, lalu tulis hasilnya ke tabel high_value_finished_orders.

Prasyarat

1. Lengkapi pengaturan awal, termasuk pembuatan kluster dan konfigurasi daftar putih, dengan mengikuti petunjuk dalam Panduan cepat untuk Edisi Gudang Data.

   Catatan

   Pastikan kluster AnalyticDB for MySQL dan ruang kerja DataWorks berada di wilayah yang sama.

   • Jika Anda menghubungkan AnalyticDB for MySQL dari DataWorks menggunakan titik akhir publik AnalyticDB for MySQL, Anda harus terlebih dahulu mengajukan titik akhir publik, lalu menambahkan daftar putih DataWorks ke daftar putih AnalyticDB for MySQL.

   • Jika Anda menghubungkan AnalyticDB for MySQL dari DataWorks menggunakan alamat VPC untuk mengakses AnalyticDB for MySQL, Anda harus terlebih dahulu menambahkan mode kelompok sumber daya eksklusif di DataWorks, dan VPC dari kelompok sumber daya eksklusif tersebut harus sama dengan VPC AnalyticDB for MySQL.

   • Tutorial ini menggunakan tabel orders dari . Setelah Anda terhubung ke database AnalyticDB for MySQL, jalankan pernyataan SQL berikut untuk membuat tabel yang diperlukan.

     CREATE TABLE orders(
           o_orderkey bigint NOT NULL COMMENT'',
           o_custkey int NOT NULL COMMENT'',
           o_orderstatus varchar NOT NULL COMMENT'',
           o_totalprice decimal(15,2) NOT NULL COMMENT'',
           o_orderdate date NOT NULL COMMENT'',
           o_orderpriority varchar NOT NULL COMMENT'',
           o_clerkvar char NOT NULL COMMENT'',
           o_shippriority int NOT NULL COMMENT'',
           o_comment varchar NOT NULL COMMENT'',
           dummy varchar
       )DISTRIBUTED BY HASH(o_orderkey);
     CREATE TABLE finished_orders (
            o_orderkey bigint NOT NULL,
            o_totalprice decimal(15,2) NOT NULL,
            primary key (o_orderkey)
        )DISTRIBUTED BY HASH(o_orderkey);
     
     CREATE TABLE high_value_finished_orders (
           o_orderkey bigint NOT NULL,
           o_totalprice decimal(15,2) NOT NULL,
           PRIMARY KEY (`o_orderkey`)
       )
       DISTRIBUTED BY HASH(o_orderkey);

2. Buat ruang kerja di DataWorks.

   Catatan

   Pilih mode standar untuk ruang kerja tersebut.

Langkah 1: Tambahkan sumber data AnalyticDB for MySQL di DataWorks

Untuk petunjuk lengkap, lihat Sumber data AnalyticDB for MySQL 3.0.

Karena alasan keamanan, DataWorks mengontrol layanan yang dapat membuat koneksi. Anda harus menambahkan titik akhir dan port database AnalyticDB for MySQL ke daftar putih.

Pada halaman Security Settings, di bagian Sandbox Whitelist, klik Add Sandbox Whitelist untuk menambahkan titik akhir koneksi dan port (misalnya 3306) AnalyticDB for MySQL ke daftar putih.

Langkah 2: Buat node AnalyticDB for MySQL

Untuk petunjuk lengkap, lihat AnalyticDB for MySQL.

Langkah 3: Konfigurasikan dependensi tugas

DataWorks memicu tugas berdasarkan properti waktu atau dependensi penjadwalan siklus yang sama, sehingga memungkinkan Anda menjalankan beberapa tugas pada waktu tertentu dan dalam urutan tertentu.

Sebagai contoh, Anda dapat menjadwalkan tugas finished_orders agar berjalan setiap hari pukul 02.00. Anda kemudian dapat mengonfigurasi tugas high_value_finished_orders agar hanya berjalan setelah tugas finished_orders berhasil diselesaikan.

Langkah 4: Terapkan node

Setelah Anda mengonfigurasi tugas dan dependensinya, terapkan tugas tersebut. Untuk detailnya, lihat Deploy a node.

Setelah Anda mengirimkan node untuk penerapan, Anda dapat melihat statusnya.

Setelah penerapan berhasil, buka halaman O&M tugas untuk memantau dan mengelola tugas Anda.