Platform For AI:Variabel global

Prosedur

1. Konfigurasikan variabel global.

   Buka pipeline yang sudah ada, klik area kosong pada kanvas, lalu buat variabel global di panel sisi kanan.

   Untuk mereferensikan variabel global, gunakan format ${variable_name}. Nama variabel harus terdiri dari 1 hingga 20 karakter, dimulai dengan huruf, dan hanya boleh mengandung huruf, garis bawah (_), serta angka. Saat Anda menggunakan variabel global untuk penjadwalan offline, Anda harus mendefinisikan parameter penjadwalan dengan nama yang sama di DataWorks. Nilai yang dikonfigurasi di PAI Designer hanya berlaku untuk eksekusi eksperimen online.

2. Pada bidang parameter tempat Anda ingin menggunakan variabel global, masukkan ${variable_name}.

Contoh 1: Pipeline online

Contoh ini menunjukkan cara menetapkan variabel global para1 untuk mengganti nama kolom tabel status menjadi ifHealth dan mereferensikannya dalam skrip SQL.

1. Buat pipeline.

   Setelah pipeline dibuat, pertahankan hanya dua node pertama dan hapus node lainnya.

2. Klik area kosong pada kanvas dan buat variabel global di panel sisi kanan.

   Tetapkan nama variabel global menjadi para1 dan nilainya menjadi ifHealth.

3. Gunakan variabel global tersebut.

   Ubah komponen SQL Script agar mereferensikan variabel menggunakan ${para1}.

   Dalam editor SQL untuk komponen SQL Script-1, gunakan ${para1} sebagai alias kolom output di akhir pernyataan SELECT. Pada klausa FROM, gunakan ${t1} untuk mereferensikan sumber input dari komponen Read Table-1. Selain itu, centang kotak pilihan Automatically add CREATE TABLE statement. Saat opsi ini dipilih, pernyataan terakhir harus berupa pernyataan SELECT.

4. Jalankan pipeline.

   Setelah eksekusi selesai, klik kanan komponen SQL Script dan pilih View Data > Output of SQL Script. Nama kolom status berubah menjadi ifHealth.

Contoh 2: Penjadwalan offline DataWorks

Contoh ini menunjukkan cara menggunakan variabel global gDate untuk memfilter data berdasarkan tanggal tertentu dalam pipeline. Anda kemudian mengonfigurasi parameter penjadwalan yang sesuai di DataWorks agar pipeline dapat dijalankan sebagai pekerjaan terjadwal.

1. Buat tabel data uji.

   Pada contoh ini, buat tabel bernama dwtest di Konsol MaxCompute. Untuk informasi lebih lanjut, lihat SQL Reference.

   Tabel dwtest memiliki empat kolom: t1 (numerik, contoh nilai: 1,0; 0,0; 1,2; 0,1), t2 (numerik, contoh nilai: 1,1; 1,0; 0,0; 0,1), label (string, contoh nilai: A, B, C, D, E, F), dan ds (partisi tanggal, contoh nilai: 20190519, 20190520). Tabel ini berisi 10 baris data uji.

2. Buat pipeline dan konfigurasikan variabel global.

   1. Klik area kosong pada kanvas dan buat variabel global bernama gDate di panel sisi kanan.

      Tetapkan nilai variabel menjadi 20190520.

   2. Konfigurasikan komponen pipeline.

      

      • Table Name: Tetapkan Table Name ke tabel dwtest.

      • SQL Script: Gunakan variabel global gDate dalam kueri.

        select * from ${t1} where ds=${gDate}

3. Jalankan pipeline.

   Setelah eksekusi selesai, klik kanan komponen SQL Script dan pilih View Data > Output of SQL Script. Data keluaran difilter berdasarkan nilai variabel global gDate.

   Dalam hasil kueri, nilai pada kolom ds adalah 20190520, yang sesuai dengan nilai variabel global gDate. Hal ini mengonfirmasi bahwa variabel global berhasil diteruskan.

4. Di pojok kiri atas kanvas, klik Periodic Scheduling lalu klik Create Scheduling Node. Tindakan ini akan mengarahkan Anda ke DataWorks untuk mengonfigurasi penjadwalan offline. Di kotak dialog Create Node, tentukan nama node lalu klik Confirm.

5. Pilih eksperimen PAI Designer, lalu klik Properties di panel sisi kanan. Untuk informasi lebih lanjut tentang konfigurasi ini, lihat node scheduling configuration.

   Untuk contoh ini, konfigurasikan parameter berikut dan biarkan pengaturan lainnya tetap pada nilai default:

   • Scheduling Parameters: Tambahkan parameter penjadwalan bernama gDate dan tetapkan nilainya ke $bizdate.

   • Schedule: Untuk properti rerun, tentukan bahwa node dapat dijalankan ulang terlepas dari hasil eksekusi sebelumnya.

   • Dependencies: Tetapkan dependensi hulu ke node root ruang kerja.

6. Klik ikon dan di bilah alat. Ikuti petunjuk di layar untuk menyimpan dan mengirimkan node.

7. Di bagian atas halaman, klik Operation Center untuk melihat status eksekusi dan log operasi tugas.

   Anda juga dapat melakukan backfill data dan menjalankan pipeline percobaan. Untuk informasi lebih lanjut, lihat manage auto-triggered tasks.

Dokumen terkait

• Create a Pipeline

• node scheduling configuration

• manage auto-triggered tasks