All Products
Search

This Product

    AnalyticDB:Jadwalkan job XIHE SQL dengan DolphinScheduler

    Document Center

    AnalyticDB:Jadwalkan job XIHE SQL dengan DolphinScheduler

    Last Updated:Jun 06, 2026

    DolphinScheduler adalah platform orkestrasi alur kerja open-source yang terdistribusi dan dapat diperluas, dilengkapi antarmuka visual Directed Acyclic Graph (DAG) untuk mengeksekusi dan mengelola alur kerja pemrosesan data besar. Anda dapat menggunakan DolphinScheduler untuk menjadwalkan task XIHE SQL pada AnalyticDB for MySQL guna meningkatkan efisiensi pemrosesan data.

    Prasyarat

    • DolphinScheduler telah diinstal. Untuk detailnya, lihat dokumentasi resmi DolphinScheduler.

    • Driver MySQL (versi 8.0.0 atau lebih baru) telah dikonfigurasi di direktori instalasi DolphinScheduler. Untuk mengunduh driver tersebut, lihat mysql-connector-java.

    • Anda telah menambahkan alamat IP server DolphinScheduler ke daftar putih kluster AnalyticDB for MySQL Anda. Untuk informasi selengkapnya, lihat Whitelist.

    Prosedur

    1. Buat sumber data.

      1. Di UI web DolphinScheduler, klik Datasource pada bilah navigasi atas.

      2. Klik Create DataSource dan pilih MYSQL sebagai tipe sumber data.

      3. Di kotak dialog Add Data Source, konfigurasikan parameter berikut:

        Parameter

        Deskripsi

        Data source

        Pilih MYSQL.

        Data source name

        Nama sumber data.

        Hostname

        Hostname kluster AnalyticDB for MySQL. Anda dapat menemukan hostname tersebut di halaman Cluster Information di console.

        Port

        Nomor port kluster AnalyticDB for MySQL. Nilainya tetap 3306.

        Username

        Akun database untuk kluster AnalyticDB for MySQL.

        Database name

        Nama database di kluster AnalyticDB for MySQL.
        Catatan

        Parameter lain bersifat opsional. Untuk informasi selengkapnya, lihat dokumentasi resmi DolphinScheduler tentang sumber data MySQL.

      4. Klik Test Connection. Setelah pengujian koneksi berhasil, klik OK.

    2. Buat proyek.

      1. Di bilah navigasi atas, klik Projects.

      2. Klik Create Project.

      3. Di kotak dialog Create Project, konfigurasikan parameter seperti Project Name dan Username. Untuk detailnya, lihat Create Project.

    3. Buat alur kerja.

      1. Klik nama proyek yang telah Anda buat untuk membuka halaman Workflow Definition.

      2. Klik Create Workflow untuk membuka halaman workflow DAG edit.

      3. Dari daftar task di sebelah kiri, seret node SQL ke kanvas di sebelah kanan.

      4. Di kotak dialog Configure Current Node, konfigurasikan parameter berikut:

        Parameter

        Deskripsi

        Data source type

        Pilih MySQL.

        Data source instance

        Pilih sumber data yang telah Anda buat di Langkah 1.

        SQL type

        Tipe job SQL, seperti Query atau Non-query.

        SQL statement

        Masukkan pernyataan SQL yang akan dieksekusi.

      5. Klik OK.

      6. Di pojok kanan atas halaman, klik Save. Di kotak dialog Basic Information yang muncul, konfigurasikan parameter seperti Workflow Name.

      7. Klik OK.

    4. Jalankan alur kerja.

      1. Di kolom Actions alur kerja, klik ikon image untuk memublikasikannya.

      2. Di kolom Actions alur kerja, klik ikon image.

      3. Di kotak dialog Configure Parameters, konfigurasikan parameter yang diperlukan.

      4. Klik OK untuk menjalankan alur kerja.

    5. Lihat detail alur kerja.

      1. Di panel navigasi sebelah kiri, klik Task Instances.

      2. Di kolom Operation, klik ikon image untuk melihat hasil eksekusi dan log.