全部产品
Search
文档中心

DataWorks:Konfigurasi dan gunakan parameter penjadwalan

更新时间:Dec 19, 2025

Dalam alur kerja data, kode tugas seperti SQL sering kali perlu berubah secara dinamis untuk memproses partisi data pada tanggal berbeda berdasarkan waktu penjadwalan. Untuk menghindari perubahan kode secara manual, Anda dapat menggunakan parameter penjadwalan dengan menetapkan placeholder dalam kode. Saat tugas dijadwalkan, sistem secara otomatis mengganti placeholder tersebut dengan nilai dinamis, seperti waktu data dan waktu proses terjadwal. Proses ini mengotomatiskan alur kerja Anda sehingga dapat berjalan dengan parameter yang sesuai.

Alur konfigurasi inti

Untuk menggunakan parameter penjadwalan, Anda perlu mendefinisikannya dan menetapkan nilainya di Scheduling Settings. Setelah menguji kode di Data Development dan memastikan kebenarannya, kirimkan kode yang berisi parameter penjadwalan ke Operation Center. Sistem kemudian akan menjadwalkan tugas secara otomatis serta mengganti nilai parameter penjadwalan secara dinamis berdasarkan logika penetapan nilai.

Langkah

Tindakan

Tujuan inti

1. Definisikan parameter

Dalam kode node, gunakan format ${param} untuk mendefinisikan satu atau beberapa parameter.

Menyediakan placeholder untuk nilai dinamis.

2. Konfigurasi parameter

Pada tab Scheduling Settings > Scheduling Parameters untuk node tersebut, tetapkan nilai ke variabel dalam kode.

Mengaitkan placeholder ${param} dengan parameter penjadwalan tertentu, seperti $bizdate dan $[yyyymmdd-1].

3. Uji

Anda dapat menggunakan fitur Smoke Testing untuk mensimulasikan waktu data tertentu dan memverifikasi bahwa penggantian parameter serta eksekusi kode sudah benar.

Memastikan konfigurasi sudah benar di lingkungan pengembang.

4. Publikasikan dan verifikasi

Di Operation Center, kirimkan node ke lingkungan produksi dan konfirmasi pengaturan parameter akhir.

Memastikan parameter untuk tugas online sesuai harapan.

Langkah-langkah

1. Definisikan parameter

image

  1. Klik ganda node target, seperti node MaxCompute SQL, untuk membuka editor node.

  2. Definisikan parameter dalam kode. Dalam node MaxCompute SQL, gunakan sintaks ${param} untuk mendefinisikan nama parameter. DataWorks merekomendasikan penggunaan nama parameter yang bermakna agar mudah dirujuk dan dikelola.

    Format pemanggilan parameter penjadwalan:

    Jenis format

    Sintaks pemanggilan

    Cakupan

    Catatan

    Format umum

    ${ParameterName}

    Berlaku untuk sebagian besar jenis node, seperti node MaxCompute SQL dan node sinkronisasi.

    Ini adalah format yang paling umum.

    Format khusus

    Bervariasi tergantung jenis node. Tidak dalam format ${...}.

    PyODPS, Shell

    Untuk informasi selengkapnya, lihat Contoh pengaturan parameter penjadwalan untuk berbagai jenis node.

    -- Contoh: Mendefinisikan variabel bernama pt_date untuk filter partisi
    SELECT * FROM my_table WHERE ds = '${pt_date}'; 
  3. Di panel kanan, klik Scheduling Settings untuk mengonfigurasi Scheduling Parameters.

  4. Konfigurasikan parameter penjadwalan. Metode konfigurasi dijelaskan pada bagian berikut.

2. Konfigurasi parameter

Anda dapat mengatur parameter penjadwalan menggunakan salah satu dari dua metode: Define With Table dan Define With Expression. Anda dapat beralih antara metode ini dengan mengklik Define With Expression di pojok kanan atas daftar parameter. Metode default adalah Define With Table.

  1. Konfigurasi parameter

    Define with table

    Di panel kanan node, klik Scheduling Settings untuk membuka antarmuka konfigurasi parameter penjadwalan.

    image

    • Tambahkan parameter

      Di panel kanan node, klik Scheduling Settings. Di bagian Scheduling Parameters, Anda dapat menambahkan parameter dengan cara berikut.

      1. Klik Add Parameter dan masukkan secara manual nama serta nilai parameter. Nama parameter harus sesuai dengan nama variabel yang didefinisikan dalam kode.

      2. Klik Load Parameters From Code. DataWorks secara otomatis mengurai variabel dalam kode, seperti ${pt_date}, dan mengisi kembali parameter tersebut. Anda hanya perlu memasukkan nilai parameternya.

    • Tetapkan nilai parameter

      Anda dapat menetapkan nilai dari parameter bawaan sistem, parameter waktu kustom, parameter ruang kerja, parameter keluaran node leluhur, atau konstanta.

      • Klik kotak input. Daftar drop-down menampilkan ekspresi parameter umum yang dapat Anda pilih. Anda juga dapat memasukkan ekspresi kustom atau variabel bawaan sistem secara manual.

      • Anda dapat memasukkan nilai sesuai kebutuhan. Untuk informasi lebih lanjut tentang rentang nilai parameter yang didukung, lihat Format yang didukung untuk parameter penjadwalan.

      • Anda juga dapat mengikat parameter konteks secara cepat saat menetapkan nilai ke parameter penjadwalan. Klik tombol image di samping parameter. Di kotak dialog Bind Output Parameters Of Ancestor Nodes, pilih node yang telah dikonfigurasi parameter keluarannya untuk mengikat dependensi secara cepat. Untuk informasi lebih lanjut tentang parameter keluaran, lihat Konfigurasi dan gunakan parameter konteks node.

    Define with expression

    Klik Define With Expression untuk mengonfigurasi parameter menggunakan ekspresi.

    image

    • Saat mendefinisikan parameter menggunakan ekspresi, pisahkan beberapa parameter dengan spasi.

    • Saat menambahkan, menghapus, atau memodifikasi parameter penjadwalan menggunakan metode Define With Expression, DataWorks memvalidasi sintaks ekspresi tersebut. Jika sintaks tidak valid, Anda tidak dapat menyimpan parameter penjadwalan.

      Sebagai contoh, DataWorks memeriksa aturan sintaks, seperti tidak boleh ada spasi di kedua sisi tanda sama dengan (=).

  2. Pratinjau parameter

    Setelah mendefinisikan parameter, klik Preview Scheduling Parameters untuk melihat pratinjau parameter pada sejumlah instance tertentu pada waktu data yang ditentukan. Hal ini membantu memverifikasi bahwa definisi parameter sesuai harapan. Anda dapat menyesuaikan waktu data dan jumlah instance untuk pratinjau.

    image

Catatan

Beberapa node, seperti node sinkronisasi offline, memiliki parameter bawaan ${bizdate}. Nama parameter ini secara otomatis diberi nilai $bizdate. Anda dapat mengganti nama parameter bizdate dalam kode dengan nama parameter kustom. Parameter ${bizdate} itu sendiri tidak memiliki makna khusus dan sama seperti parameter kustom lainnya.

image

3. Pengujian asap

Setelah menetapkan nilai ke parameter penjadwalan, Anda dapat menjalankan pengujian asap selama proses penerbitan. Konfigurasikan waktu data untuk mensimulasikan skenario penjadwalan tugas target. Hal ini memverifikasi bahwa penggantian parameter dan eksekusi kode sesuai harapan dalam skenario tersebut. Jika tidak, Anda dapat segera melakukan penyesuaian untuk menghindari gangguan pada penjadwalan normal tugas.

  1. Publikasikan kode node.

    image

    1. Konfigurasikan waktu penjadwalan dan dependensi penjadwalan.

    2. Klik Simpan untuk menyimpan kode dan konfigurasi. Lalu, klik tombol Publikasikan di bilah alat. Anda dapat memulai pengujian asap selama proses penerbitan.

      Catatan

      Jika kode atau parameter pengujian asap bukan yang terbaru, klik Republish To Production.

  2. Jalankan pengujian asap.

    Klik Start Smoke Test. Di kotak dialog Smoke Test, pilih waktu data dan klik OK.

  3. Lihat log pengujian asap.

    1. Klik tombol image Catatan Pengujian Asap di menu sebelah kiri. Di daftar catatan pengujian asap, klik Log.

      image

    2. Di log, periksa keluaran parameter untuk memastikan sesuai harapan.

4. Publikasikan dan verifikasi

Setelah diverifikasi di lingkungan pengembang, Anda dapat mengirimkan dan menerbitkan tugas ke Operation Center untuk produksi dan penjadwalan otomatis. Setelah tugas diterbitkan, periksa parameter penjadwalan di lingkungan produksi untuk mencegah kesalahan waktu proses.

Catatan

Jika pengaturan parameter penjadwalan untuk tugas yang dipicu otomatis tidak sesuai harapan, atau jika Anda tidak dapat menemukan tugas target di Operation Center, pastikan bahwa tugas telah berhasil diterbitkan. Untuk informasi lebih lanjut tentang cara menerbitkan tugas, lihat Publikasikan tugas.

  1. Periksa definisi parameter.

    Buka Operation Center. Beralih ke wilayah tujuan dan ruang kerja. Buka halaman Auto Triggered Task O&M > Auto Triggered Tasks. Di daftar tugas, klik nama tugas untuk melihat panel Properties dan verifikasi parameter waktu proses.

    image

  2. Jalankan pengujian asap di Operation Center.

    Anda juga dapat menjalankan pengujian asap di Operation Center untuk memastikan bahwa tugas yang telah diterbitkan melakukan penggantian parameter dan eksekusi kode sesuai harapan di lingkungan produksi. Untuk informasi selengkapnya, lihat Jalankan pengujian dan lihat instance pengujian.

    Penting

    Pengujian asap dijalankan pada data nyata di lingkungan produksi. Jalankan dengan hati-hati untuk menghindari kerusakan data di database produksi.

    image

  3. Amati hasil penjadwalan aktual.

    Setelah tugas dijadwalkan secara otomatis, Anda dapat memeriksa parameter di Recurring Instance untuk lebih lanjut memverifikasi bahwa parameter tersebut diganti dengan benar.

    image

Contoh konfigurasi lengkap

Topik ini menggunakan node MaxCompute SQL sebagai contoh. Topik ini menunjukkan cara menggunakan fitur pengujian asap di lingkungan pengembang untuk menguji apakah parameter penjadwalan yang dikonfigurasi sesuai harapan. Topik ini juga menunjukkan cara melihat pengaturan parameter penjadwalan untuk tugas di Operation Center setelah tugas diterbitkan.

Catatan

Untuk informasi lebih lanjut tentang pengaturan parameter penjadwalan untuk berbagai jenis node, lihat Contoh pengaturan parameter penjadwalan untuk berbagai jenis node.

  1. Edit kode node dan konfigurasikan parameter penjadwalan.

    Gambar berikut menunjukkan kode dan pengaturan parameter penjadwalan untuk node MaxCompute SQL.image

    1. Definisikan variabel dalam kode.

      -- Tetapkan parameter bawaan sistem
      SELECT '${var1}';
      SELECT '${var2}';
      -- Tetapkan parameter kustom
      SELECT '${var3}';
      SELECT '${var4}';
      -- Tetapkan konstanta
      SELECT '${var5}';
    2. Tetapkan nilai ke variabel.

      Di bagian Scheduling Settings > Scheduling Parameters, tetapkan nilai ke variabel seperti yang ditunjukkan di Area 2. Untuk informasi lebih lanjut tentang format penetapan nilai, lihat Format yang didukung untuk parameter penjadwalan.

      • var1=$bizdate, yaitu waktu data dalam format yyyymmdd.

      • var2=$cyctime, yaitu waktu proses terjadwal tugas dalam format yyyymmddhh24miss.

      • var3=${yyyymmdd}, yaitu waktu data dalam format yyyymmdd.

      • var4=$[yyyymmddhh24miss], yaitu waktu proses terjadwal tugas dalam format yyyymmddhh24miss.

      • var5=Hangzhou, yang menetapkan nilai var5 ke konstanta Hangzhou.

    3. Opsi: Konfigurasi waktu penjadwalan.

      Konfigurasikan periode penjadwalan untuk node MaxCompute SQL menjadi per jam, seperti yang ditunjukkan di Area 3.

      Catatan

      Anda dapat mengonfigurasi periode waktu sesuai kebutuhan. Topik ini menggunakan penjadwalan per jam sebagai contoh.

      • Waktu mulai penjadwalan adalah 16:00

      • Waktu akhir penjadwalan adalah 23:59

      • Interval penjadwalan adalah 1 jam.

      Untuk informasi lebih lanjut tentang pengaturan periode waktu, lihat Konfigurasi properti waktu.

    4. Tetapkan dependensi penjadwalan.

      Konfigurasikan dependensi penjadwalan untuk node pengembang. Untuk informasi lebih lanjut, lihat Konfigurasi dependensi penjadwalan. Contoh ini menggunakan node root sebagai node leluhur untuk node ini.

  2. Di bilah alat di bagian atas halaman editor node, klik tombol Simpan dan publikasikan pengaturan untuk node MaxCompute SQL.

  3. Mulai pengujian asap selama proses penerbitan.

    1. Klik tombol Start Smoke Test. Di kotak dialog Smoke Test, konfigurasikan waktu bisnis untuk mensimulasikan periode penjadwalan node.

      imageWaktu bisnis dikonfigurasi sebagai berikut:

      • Waktu data: 2025-10-16

      • Waktu mulai: 16:00

      • Waktu akhir: 17:00

      Jika node MaxCompute SQL dijadwalkan berjalan per jam, node tersebut menghasilkan dua instance pada pukul 16:00 dan 17:00 untuk waktu data 2025-10-17.

      Catatan

      Karena waktu data adalah hari sebelum tanggal eksekusi, tanggal eksekusi aktual tugas adalah 2025-10-17.

      Nilai yang diharapkan untuk instance pukul 16:00 adalah sebagai berikut:

      • var1=20251016.

      • var2=20251017160000.

      • var3=20251016.

      • var4=20251017160000.

      Nilai yang diharapkan untuk instance pukul 17:00 adalah sebagai berikut:

      • var1=20251016.

      • var2=20251017170000.

      • var3=20251016.

      • var4=20251017170000.

    2. Klik OK. Node mulai berjalan pada waktu yang ditentukan.

    3. Setelah waktu proses berakhir, klik tombol image Catatan Pengujian Asap di menu sebelah kiri untuk melihat log pengujian asap.

      Dua instance yang dihasilkan oleh node berjalan dengan sukses, dan hasil eksekusi node sesuai harapan.

      image

      image

      image

  4. Jika ruang kerja saat ini dalam mode standar, Anda harus menerbitkan node ke lingkungan produksi. Di halaman editor node MaxCompute SQL, klik Publish di pojok kanan atas bilah menu. Untuk informasi lebih lanjut tentang penerbitan node, lihat Publikasikan node.

  5. Buka Operation Center untuk mengonfirmasi pengaturan parameter penjadwalan node.

    生产环境参数配置

    1. Di pojok kanan atas bilah menu Operation Center, klik DataStudio untuk membuka halaman Operation Center.

    2. Di halaman Auto Triggered Task O&M > Auto Triggered Tasks, cari node target.

      Catatan

      Anda dapat mencari node di halaman Auto Triggered Tasks hanya setelah node berhasil diterbitkan.

    3. Klik nama node target. Di panel Properties, Anda dapat melihat Runtime Parameters.

      Dalam contoh ini, parameter waktu proses node adalah var1=$bizdate var2=$cyctime var3=${yyyymmdd} var4=$[yyyymmddhh24miss], yang sesuai harapan.

    4. Anda dapat melihat penggantian parameter dalam sebuah instance dengan melihat parameter waktu prosesnya. Setelah instance terjadwal dibuat, klik menu Recurring Instances, cari nama tugas, lalu klik nama instance tugas tersebut. Di panel Properties, lihat Runtime Parameters.

      Dalam contoh ini, parameter waktu proses node adalah var1=20251016 var2=20251017160000 var3=20251016 var4=20251017160000, yang sesuai harapan.

Referensi