AnalyticDB：Gunakan Azkaban untuk menjadwalkan pekerjaan SQL XIHE

Prasyarat

• Klien MySQL terpasang di server tempat Azkaban dipasang. Untuk informasi lebih lanjut, lihat Dokumentasi MySQL.

• Azkaban telah dipasang. Untuk informasi lebih lanjut, lihat Dokumentasi Azkaban.

• Alamat IP server yang menjalankan Azkaban ditambahkan ke daftar putih alamat IP dari sebuah kluster AnalyticDB for MySQL. Untuk informasi lebih lanjut, lihat Konfigurasikan daftar putih.

Persiapan data

Dalam kluster AnalyticDB for MySQL, buatlah database bernama azkaban_test. Dalam database tersebut, buatlah tabel bernama azkaban_test.names dan masukkan data uji ke dalam tabel. Contoh:

-- Buat database.
CREATE DATABASE azkaban_test;
-- Buat tabel.
CREATE TABLE azkaban_test.names (
  id BIGINT,
  name STRING
);
-- Masukkan data ke dalam tabel.
INSERT INTO azkaban_test.names VALUES(1, 'Li'), (2, 'Yang');

Prosedur

1. Tulis file alur kerja.

   1. Buat folder alur kerja. Buat skrip untuk memulai, menanyakan, dan mengakhiri pekerjaan di folder tersebut.

      • Skrip untuk memulai pekerjaan:

        #start
        type=command
        command=echo 'pekerjaan dimulai'

      • Skrip untuk menanyakan pekerjaan:

        type=command
        dependencies=start
        command=mysql -hamv-bp165vrm0g8s****.ads.aliyuncs.com -utest -padb14**** -P3306 -e "create table azkaban_test.duplicated_names as select * from azkaban_test.names"

        Parameter:

        • -h: titik akhir dari kluster AnalyticDB for MySQL. Anda dapat masuk ke Konsol AnalyticDB for MySQL dan pergi ke halaman Cluster Information untuk melihat titik akhir.

        • -u: nama akun basis data dari kluster AnalyticDB for MySQL.

        • -p: nama basis data dari kluster AnalyticDB for MySQL.

        • -P: nomor port dari kluster AnalyticDB for MySQL. Atur nilainya menjadi 3306.

        • -e: Pernyataan SQL.

      • Skrip untuk mengakhiri pekerjaan:

        #end
        type=command
        dependencies=exec_query
        command=echo 'pekerjaan selesai'

   2. Kompres folder alur kerja dalam format ZIP.

2. Buat proyek dan unggah file alur kerja yang dibuat pada Langkah 1.