AnalyticDB:Gunakan DataWorks untuk menjadwalkan tugas XIHE SQL

Tujuan

Penjadwalan tugas memerlukan dependensi antar-tugas. Dalam topik ini, dua tugas AnalyticDB for MySQL dibuat di DataWorks. Gambar berikut menunjukkan hubungan antara tabel dan tugas.

• Task 1

  Eksekusi pernyataan yang berisi kondisi o_orderstatus = 'F' untuk menyaring pesanan yang sudah selesai dari tabel orders, lalu tulis pesanan tersebut ke tabel finished_orders.

• Task 2

  Eksekusi pernyataan yang berisi kondisi o_totalprice > 10000 untuk menyaring pesanan dengan total harga lebih dari 10.000 dari tabel finished_orders, lalu tulis pesanan tersebut ke tabel high_value_finished_orders.

Prasyarat

1. Sebuah kluster AnalyticDB for MySQL telah dibuat, dan daftar putih telah dikonfigurasi untuk kluster tersebut. Untuk informasi lebih lanjut, lihat Proses Memulai dengan Edisi Gudang Data.

   Catatan

   Pastikan bahwa kluster AnalyticDB for MySQL berada di wilayah yang sama dengan DataWorks.

   • Jika Anda ingin terhubung ke AnalyticDB for MySQL dari DataWorks menggunakan titik akhir publik, Anda harus mengajukan permohonan untuk titik akhir publik, lalu tambahkan alamat IP dalam daftar putih DataWorks ke daftar putih AnalyticDB for MySQL.

   • Jika Anda ingin terhubung ke AnalyticDB for MySQL dari DataWorks menggunakan titik akhir Virtual Private Cloud (VPC), Anda harus membuat kelompok sumber daya eksklusif di DataWorks. VPC dari kelompok sumber daya eksklusif harus sama dengan VPC dari kluster AnalyticDB for MySQL.

   • Dalam topik ini, tabel dengan nama orders digunakan sebagai data uji. Setelah terhubung ke database AnalyticDB for MySQL, Anda dapat mengeksekusi pernyataan berikut untuk membuat tabel uji:

     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. Sebuah ruang kerja telah dibuat di DataWorks. Untuk informasi lebih lanjut, lihat Buat Ruang Kerja.

   Catatan

   Pilih mode standar untuk ruang kerja.

Langkah 1. Tambahkan sumber data AnalyticDB for MySQL di DataWorks

Untuk informasi lebih lanjut, lihat Sumber Data AnalyticDB for MySQL 3.0.

DataWorks menerapkan kontrol keamanan pada layanan yang terhubung. Anda harus menambahkan titik akhir dan port database AnalyticDB for MySQL ke daftar putih DataWorks.

Langkah 2. Buat node AnalyticDB for MySQL di DataWorks

Untuk informasi lebih lanjut, lihat Node AnalyticDB for MySQL.

Langkah 3: Konfigurasikan dependensi tugas

Di DataWorks, tugas dapat dipicu oleh konfigurasi penjadwalan berdasarkan waktu atau dependensi. Beberapa tugas dieksekusi pada titik waktu tertentu berdasarkan dependensi yang ditentukan. Untuk informasi lebih lanjut, lihat Konfigurasikan Properti Waktu dan Konfigurasikan Dependensi Penjadwalan Siklus yang Sama.

Sebagai contoh, Anda dapat mengonfigurasi tugas finished_orders untuk dieksekusi pada 02:00:00 setiap hari. Setelah tugas finished_orders dieksekusi, tugas high_value_finished_orders akan dieksekusi.

Langkah 4. Publikasikan tugas

Setelah Anda mengonfigurasi tugas, Anda dapat mempublikasikan dan memelihara tugas-tugas tersebut. Untuk informasi lebih lanjut, lihat Deploy Node.

Setelah Anda mempublikasikan tugas, Anda dapat melihat tugas yang akan dipublikasikan.

Setelah tugas dipublikasikan, Anda dapat melihat dan memelihara tugas tersebut di halaman O&M tugas.