E-MapReduce：Kelola alur kerja

Prasyarat

Proyek telah dibuat. Untuk informasi lebih lanjut, lihat Buat proyek.

Buat alur kerja

1. Buka tab Proyek.

   1. Masuk ke Konsol E-MapReduce (EMR).

   2. Di panel navigasi sebelah kiri, pilih EMR Studio > Workflow.

   3. Klik tab Project.

   4. Pada tab Project, klik nama proyek yang sudah ada.

2. Di halaman detail proyek, pilih Workflow > Workflow Definition di panel navigasi sebelah kiri.

3. Di halaman Workflow Definition, klik Create Workflow.

4. Di halaman Create Workflow, seret HIVECLI ke kanvas. Di kotak dialog Pengaturan Node Saat Ini, konfigurasikan parameter dan klik Confirm.

   Contoh ini menciptakan node HIVECLI. Untuk informasi lebih lanjut, lihat HIVECLI. Untuk informasi tentang tipe node lainnya, lihat Tipe Node.

5. Opsional. Konfigurasikan dependensi antar node.

   EMR Workflow memungkinkan Anda mengonfigurasi dependensi node kustom antar alur kerja.

   • Geser pointer ke ikon di sisi kanan node, lalu seret garis koneksi untuk menghubungkan node ke node lain.

   • Klik garis koneksi atau node, lalu klik ikon di sudut kanan atas kanvas untuk menghapus dependensi node atau node tersebut.

6. Simpan alur kerja.

   1. Klik Save di sudut kanan atas kanvas.

   2. Di kotak dialog Informasi Dasar, konfigurasikan parameter sesuai tabel berikut dan klik Confirm.

      Parameter	Deskripsi
      Workflow Name	Nama dari alur kerja.
      Description	Deskripsi fitur dari alur kerja.
      Timeout Alert	Secara default, Peringatan Timeout dimatikan. Jika Anda mengaktifkan Timeout Alert, Anda harus menentukan timeout period. Jika waktu eksekusi suatu node melebihi periode timeout, peringatan akan dipicu.
      Process execute type	Mode di mana instance alur kerja dijalankan. Nilai valid: parallel: Jika beberapa instance alur kerja dihasilkan oleh alur kerja yang sama, instance alur kerja dijalankan secara bersamaan. Serial wait: Jika beberapa instance alur kerja dihasilkan oleh alur kerja yang sama, instance alur kerja dijalankan secara berurutan.
      Global Variables	Variabel global berlaku untuk semua node dari alur kerja.

Operasi pada alur kerja

Jalankan alur kerja

Setiap kali alur kerja dijalankan, instance alur kerja dihasilkan dan ditampilkan di halaman Workflow Instance.

1. Di halaman Workflow Definition, temukan alur kerja yang ingin dijalankan dan klik ikon di kolom Operasi.

2. Klik ikon di kolom Operasi.

3. Di kotak dialog yang muncul, konfigurasikan parameter sesuai tabel berikut dan klik Confirm.

   Parameter	Deskripsi
   Failure Strategy	Kebijakan yang digunakan untuk menjalankan node konkuren lainnya jika sebuah node gagal dalam alur kerja. Continue: Jika sebuah node gagal, node lainnya berjalan sesuai harapan. End: Jika sebuah node gagal, node hilir dari node tersebut dihentikan.
   Notification Strategy	Status alur kerja berdasarkan sistem mengirim notifikasi tentang informasi eksekusi alur kerja ketika alur kerja berakhir. Nilai valid: None, Success, Failure, dan All.
   Workflow Priority	Prioritas node dalam alur kerja. Nilai default: MEDIUM. Nilai valid: HIGHEST HIGH MEDIUM LOW LOWEST
   Execution Cluster	Cluster yang digunakan untuk menjalankan alur kerja. Anda dapat memilih cluster yang dikaitkan di halaman Kelola Cluster dari tab Keamanan dari daftar drop-down.
   Alarm Group	Grup peringatan. Anda dapat memilih grup peringatan yang dibuat di halaman Kelola Grup Alarm dari tab Keamanan dari daftar drop-down.
   Complement Data	Menentukan apakah akan menghasilkan data retroaktif berdasarkan pengaturan backfill data ketika alur kerja dijalankan dalam rentang waktu tertentu. Jika Anda memilih Whether it is a complement process?, Anda harus mengonfigurasi parameter berikut: Mode of dependent: menentukan apakah akan menghasilkan data retroaktif untuk alur kerja yang bergantung pada alur kerja saat ini. Nilai valid: Close dan Open. Nilai default: Tutup. Data retroaktif dihasilkan untuk alur kerja yang bergantung pada alur kerja saat ini hanya jika alur kerja saat ini berada dalam status Online dan pengaturan penjadwalan dikonfigurasi untuk alur kerja saat ini. Mode of execution Mode di mana data retroaktif dihasilkan. Nilai valid: Serial execution: Sistem menghasilkan data retroaktif untuk setiap hari yang terkandung dalam rentang waktu yang ditentukan secara kronologis, dan beberapa instance alur kerja dihasilkan secara berurutan. Parallel execution: Sistem menghasilkan data retroaktif untuk beberapa hari yang terkandung dalam rentang waktu yang ditentukan pada saat yang sama, dan beberapa instance alur kerja dihasilkan pada saat yang sama. Dalam mode ini, Anda harus mengonfigurasi parameter Custom Parallelism untuk menentukan jumlah maksimum instance alur kerja untuk mana sistem menghasilkan data retroaktif pada saat yang sama. Catatan Jika Anda menentukan parallel sebagai mode di mana alur kerja menjalankan node ketika Anda membuat alur kerja, Anda harus memilih Parallel execution. Jika Anda menentukan Serial wait sebagai mode di mana alur kerja menjalankan node ketika Anda membuat alur kerja, Anda harus memilih Serial execution. Scheduling Date: rentang waktu selama alur kerja dijalankan.
   Startup Parameter	Parameter startup dan nilainya. Nilai tersebut digunakan untuk mendefinisikan variabel global atau menimpa nilai yang ada dari variabel global ketika instance alur kerja baru dimulai.
   Whether Dry-Run	Menentukan apakah akan melakukan uji coba kering untuk alur kerja. Jika Anda melakukan uji coba kering untuk alur kerja, log sukses dicatat.

4. Di halaman detail proyek, pilih Workflow > Workflow Instance di panel navigasi sebelah kiri untuk melihat status instance alur kerja.

Impor alur kerja

1. Di halaman Workflow Definition dari halaman project details, klik Import Workflow.

2. Di kotak dialog Unggah, klik Upload. Pilih alur kerja yang diekspor ke komputer Anda. Alur kerja yang diekspor adalah file JSON.

3. Klik Confirm.

Konfigurasikan alur kerja terjadwal

1. Di halaman Workflow Definition, temukan alur kerja yang ingin dikelola dan klik ikon di kolom Operasi.

2. Di kotak dialog yang muncul, konfigurasikan parameter Start and stop time, Timing, dan Execution Cluster, lalu klik Confirm.

   • Start and stop time: Rentang waktu di mana alur kerja dijadwalkan untuk dijalankan. Tidak ada instance alur kerja terjadwal yang dihasilkan jika alur kerja tidak dijalankan dalam rentang waktu yang ditentukan.

   • Timing: Interval di mana alur kerja dijadwalkan untuk dijalankan.

3. Ubah status alur kerja terjadwal menjadi Online.

   Setelah mengonfigurasi pengaturan penjadwalan untuk alur kerja, alur kerja terjadwal berada dalam status Offline. Untuk membuat alur kerja terjadwal berlaku, lakukan operasi berikut untuk mengubah status alur kerja terjadwal menjadi Online:

   1. Di halaman Workflow Definition, temukan alur kerja dan klik ikon di kolom Operasi.

   2. Di halaman Cron manage, temukan alur kerja terjadwal dan klik ikon di kolom Operasi.