SchedulerX:Manajemen Pekerjaan

Buat pekerjaan

1. Masuk ke konsol SchedulerX.

2. Di bilah navigasi atas, pilih wilayah.

3. Di panel navigasi sisi kiri, klik Task Management.

4. Di halaman Task Management, pilih namespace dan klik Create task. Di langkah Basic Configuration, konfigurasikan parameter dan klik Next Step.

   

   Tabel berikut menjelaskan parameter dasar:

   Parameter	Deskripsi
   Task name	Nama pekerjaan.
   Description	Deskripsi pekerjaan. Tentukan deskripsi yang ringkas dan jelas untuk memudahkan pencarian dan pengelolaan pekerjaan.
   Application ID	Grup tempat pekerjaan termasuk. Pilih nilai dari daftar drop-down.
   Task type	Bahasa pemrograman yang ingin Anda gunakan untuk membuat pekerjaan. Nilai valid: Java, XXL-JOB, SpringSchedule, Golang, ScriptTask, Http, dan DataWorks. Jika Anda memilih ScriptTask, Anda harus memilih shell, python, atau go untuk parameter Script, dan masukkan skrip di editor yang muncul.
   Class full path	Catatan Parameter ini hanya tersedia jika parameter Task type diatur ke java. Path lengkap JobProcessor. Contoh: xxx.xxx.xxx.HelloProcessor.
   Execution mode	Mode di mana pekerjaan dieksekusi. Nilai valid: Stand-alone operation: Pekerjaan dieksekusi pada worker acak. Broadcast run: Pekerjaan dieksekusi secara bersamaan di semua worker, dan sistem menunggu hingga semua worker menyelesaikan pekerjaan. Visual MapReduce: model Map. Tidak lebih dari 300 pekerjaan diperbolehkan dalam daftar pekerjaan. Di Edisi Profesional, maksimum 1.000 pekerjaan diperbolehkan, dan pekerjaan dapat dicari berdasarkan kata kunci. MapReduce: model MapReduce reguler. Dalam mode ini, Anda dapat memproses sejumlah besar pekerjaan secara paralel. Namun, Anda hanya dapat menanyakan informasi ringkasan pekerjaan. Kami merekomendasikan Anda memilih mode ini jika jumlah pekerjaan kurang dari 1.000.000. Shard run: Mode ini mirip dengan model elastic-job. Shard didistribusikan secara merata untuk dijalankan pada beberapa agen berdasarkan pengaturan sharding yang ditentukan. Mode eksekusi ini mendukung pekerjaan yang menggunakan bahasa pemrograman berbeda. Catatan Pengaturan lanjutan pekerjaan bervariasi berdasarkan execution mode pekerjaan.
   Task parameters	String arbitrer yang dapat diperoleh dari konteks saat SchedulerX menjalankan pekerjaan.

   Tabel berikut menjelaskan parameter untuk konfigurasi lanjutan:

   Parameter	Mode eksekusi yang berlaku	Deskripsi	Nilai default
   Jumlah percobaan ulang kegagalan tugas	Semua mode	Jumlah percobaan ulang otomatis jika pekerjaan gagal. Catatan Jika pekerjaan sedang berjalan di worker dan worker di-restart, pekerjaan gagal. Jika Anda ingin segera menjalankan ulang pekerjaan, Anda dapat menentukan parameter ini.	0
   Interval percobaan ulang kegagalan tugas	Semua mode	Interval antara dua percobaan ulang berturut-turut. Unit: detik.	30
   Konkurensi tugas	Semua mode	Jumlah instans yang menjalankan pekerjaan yang sama pada waktu yang sama. Nilai 1 menentukan bahwa eksekusi bersamaan tidak diizinkan.	1
   Strategi pembersihan	Semua mode	Kebijakan pembersihan untuk riwayat eksekusi pekerjaan.	Simpan N entri terakhir
   Jumlah yang Disimpan	Semua mode	Jumlah catatan eksekusi pekerjaan yang disimpan.	300
   Jumlah sub-tugas konkuren satu mesin	Visual MapReduce MapReduce Shard run	Jumlah tugas yang berjalan bersamaan pada satu worker dalam model terdistribusi. Untuk mempercepat eksekusi, Anda dapat menentukan nilai yang lebih besar. Jika downstream atau database tidak dapat menahan nilai yang Anda tentukan, Anda dapat menentukan nilai yang lebih kecil.	5
   Jumlah percobaan ulang kegagalan sub-tugas	Visual MapReduce MapReduce Shard run	Jumlah percobaan ulang otomatis jika tugas gagal dalam model terdistribusi.	0
   Interval percobaan ulang kegagalan sub-tugas	Visual MapReduce MapReduce Shard run	Interval antara dua percobaan ulang berturut-turut jika tugas gagal dalam model terdistribusi. Unit: detik.	0
   Strategi Failover Sub-tugas	Visual MapReduce MapReduce Shard run	Menentukan apakah akan mendistribusikan tugas ke worker baru setelah worker gagal mengeksekusi tugas dan dihentikan. Jika Anda mengaktifkan saklar, sistem mungkin mengeksekusi tugas lebih dari sekali ketika failover dipicu. Anda harus mengimplementasikan idempotensi tugas. Catatan Parameter ini berlaku untuk agen V1.8.13 dan yang lebih baru.
   Node master berpartisipasi dalam eksekusi	Visual MapReduce MapReduce Shard run	Menentukan apakah node master berpartisipasi dalam eksekusi tugas. Setidaknya dua worker harus tersedia untuk menjalankan tugas. Jika ada sejumlah besar tugas yang sangat besar, kami sarankan Anda mematikan saklar. Catatan Parameter ini berlaku untuk agen V1.8.13 dan yang lebih baru.
   Metode distribusi sub-tugas	Visual MapReduce MapReduce Shard run	Push model: Tugas didistribusikan secara merata ke worker. Pull model: Setiap worker menarik tugas. Teori Wooden Bucket tidak berlaku untuk model ini. Selama proses penarikan, semua tugas disimpan di node master. Ini memberi tekanan pada memori. Kami sarankan Anda tidak mendistribusikan lebih dari 10.000 tugas sekaligus.	Model push
   Kebijakan distribusi	Visual MapReduce MapReduce	Kebijakan distribusi tugas. Nilai default: Skema Polling. Skema Polling: Sistem mendistribusikan jumlah tugas yang sama ke setiap worker. Kebijakan ini cocok untuk skenario di mana setiap worker membutuhkan waktu hampir sama untuk memproses tugas. Strategi optimal WorkerLoad: Node master secara otomatis mendeteksi beban worker. Kebijakan ini cocok untuk skenario di mana perbedaan besar ada antara jumlah waktu yang dibutuhkan setiap worker untuk memproses tugas. Catatan Parameter ini berlaku untuk agen V1.10.14 dan yang lebih baru.
   Laju distribusi	Visual MapReduce MapReduce	Laju distribusi tugas. Anda dapat menentukan jumlah tugas yang akan didistribusikan per detik atau per menit.
   Jumlah sub-tugas yang ditarik per kali	Visual MapReduce MapReduce Shard run	Jumlah tugas yang ditarik oleh node slave dari node master sekaligus. Parameter ini ditampilkan hanya jika parameter Metode distribusi sub-tugas disetel ke Model pull.	5
   Kapasitas antrian sub-tugas	Visual MapReduce MapReduce Shard run	Ukuran antrian yang menyimpan tugas pada node slave. Parameter ini ditampilkan hanya jika parameter Metode distribusi sub-tugas disetel ke Model pull.	10
   Konkurensi global sub-tugas	Visual MapReduce MapReduce Shard run	Jumlah total tugas konkuren pada semua worker dalam model pull. Parameter ini membantu Anda membatasi jumlah tugas konkuren. Parameter ini ditampilkan hanya jika parameter Metode distribusi sub-tugas disetel ke Model pull.	1000

5. Di langkah Timing configuration, konfigurasikan pengaturan penjadwalan dan pengaturan lanjutan, lalu klik Next Step.

   

   Tabel berikut menjelaskan parameter untuk penjadwalan pekerjaan:

   Parameter	Deskripsi
   Time type	none: Pekerjaan dipicu menggunakan alur kerja. cron: Pekerjaan dipicu berdasarkan ekspresi CRON. api: Pekerjaan dipicu dengan memanggil operasi API. fixed_rate: Pekerjaan dipicu pada interval tertentu. second_delay: Pekerjaan dipicu dengan penundaan beberapa detik. one_time: Pekerjaan dipicu hanya sekali pada titik waktu tertentu. unix cron: Pekerjaan dipicu berdasarkan ekspresi CRON yang tersedia di sistem Unix.
   cron expression	Masukkan ekspresi CRON yang sesuai dengan sintaks cron atau gunakan alat yang disediakan oleh SchedulerX untuk menghasilkan ekspresi. Kemudian, verifikasi ekspresi CRON. Parameter ini tersedia hanya jika parameter Tipe waktu disetel ke cron.
   Fixed frequency	Tentukan interval di mana pekerjaan dipicu. Parameter ini tersedia hanya jika parameter Tipe waktu disetel ke fixed_rate. Nilainya harus lebih besar dari 60. Unit: detik. Misalnya, nilai 200 menunjukkan bahwa pekerjaan dipicu pada interval 200 detik.
   Fixed delay	Tentukan penundaan. Parameter ini tersedia hanya jika parameter Tipe waktu disetel ke second_delay. Nilai valid: 1 hingga 60. Unit: detik. Misalnya, nilai 5 menunjukkan bahwa pekerjaan dipicu dengan penundaan lima detik.
   Scheduling time	Tentukan tanggal dan titik waktu di mana pekerjaan dipicu. Parameter ini tersedia hanya jika parameter Tipe waktu disetel ke one_time. Contoh: 2023-7-13 00:00:00.
   unix cron expression	Masukkan ekspresi CRON yang tersedia di sistem UNIX. Parameter ini tersedia hanya jika parameter Tipe waktu disetel ke unix cron.

   Tabel berikut menjelaskan parameter untuk konfigurasi lanjutan:

   Parameter	Deskripsi
   Time offset	Offset antara timestamp data yang akan diproses dan waktu ketika pekerjaan dipicu. Anda dapat memperoleh nilai offset dari konteks saat SchedulerX menjalankan pekerjaan.
   Time zone	Pilih zona waktu negara atau wilayah. Anda juga dapat memilih zona waktu Coordinated Universal Time (UTC) berdasarkan kebutuhan bisnis Anda.

6. Di langkah Notification configuration, konfigurasikan pengaturan peringatan dan kontak, lalu klik Complete.

   

   Anda dapat memilih Application group contact atau user-defined untuk parameter Notification channel and contact person.

   • Application group contact

     Semua kontak grup aplikasi dapat menerima notifikasi.

   • user-defined

     Anda dapat menentukan Contact group atau Contact yang dapat menerima notifikasi.

     • Contact group

       Tambahkan grup kontak. Semua kontak dalam grup kontak dapat menerima notifikasi. Untuk informasi lebih lanjut tentang cara membuat grup kontak, lihat bagian Buat kontak notifikasi dan grup kontak notifikasi dari topik Kontak notifikasi dan grup kontak notifikasi.

     • Contact

       1. Tambahkan kontak untuk menerima notifikasi. Anda dapat menambahkan beberapa kontak sekaligus. Jika belum membuat kontak apa pun, klik Add contact lalu klik Create Contact.

       

       2. Di halaman yang muncul, klik New contact dan masukkan informasi kontak.

       

       

7. Kembali ke halaman Task Management dan periksa apakah pekerjaan ada dan menggunakan konfigurasi yang ditentukan.

   Catatan

   Secara default, pekerjaan diaktifkan setelah pembuatan. Anda dapat mengaktifkan atau menonaktifkan pekerjaan sesuai kebutuhan bisnis. Untuk informasi lebih lanjut, lihat bagian Aktifkan atau nonaktifkan pekerjaan dari topik ini.

Modifikasi pekerjaan

1. Di halaman Task Management, temukan pekerjaan yang ingin dikelola dan klik Edit di kolom Operation.

2. Di panel Edit, modifikasi konfigurasi dasar, pengaturan penjadwalan, dan pengaturan peringatan.

   Catatan

   Anda tidak dapat mengubah nilai parameter ID Aplikasi dan Jenis Tugas pekerjaan. Parameter lainnya dapat dikonfigurasi seperti saat membuat pekerjaan.

Jalankan pekerjaan

Di halaman Task Management, temukan pekerjaan yang ingin dikelola dan klik Run once di kolom Operation untuk menjalankan pekerjaan sekali.

Aktifkan atau nonaktifkan pekerjaan

Aktifkan atau nonaktifkan pekerjaan tunggal

1. Di halaman Task Management, temukan pekerjaan yang ingin dikelola dan pilih more > Disable atau Enable di kolom Operation.

2. Di kotak dialog yang muncul, klik Confirm.

Aktifkan atau nonaktifkan beberapa pekerjaan sekaligus

Di Edisi Profesional, Anda dapat mengaktifkan atau menonaktifkan beberapa pekerjaan sekaligus. Di halaman Task Management, pilih pekerjaan yang ingin dikelola dan klik Batch disable atau Batch enable di bawah daftar pekerjaan.

Replikasi pekerjaan

Di halaman Task Management, temukan pekerjaan yang ingin dikelola dan pilih more > Replication di kolom Operation. Anda dapat menyalin konfigurasi pekerjaan dan memodifikasi konfigurasi pekerjaan yang disalin untuk membuat pekerjaan baru.

Perbarui output pekerjaan

Jika beban kerja Anda diperbarui, Anda dapat menjalankan pekerjaan yang sesuai lagi untuk memproses ulang data dalam periode waktu tertentu. Misalnya, jika Anda menambahkan bidang baru ke database atau data yang dihasilkan pada titik waktu bulan sebelumnya mengandung kesalahan, Anda dapat memperbarui output pekerjaan yang sesuai.

Jika output pekerjaan mengandung penyimpangan atau beberapa nilai dalam output hilang, Anda dapat memodifikasi parameter penjadwalan pekerjaan dan mengonfigurasi properti pekerjaan tertentu untuk memperbarui output pekerjaan.

1. Masuk ke konsol SchedulerX.

2. Di halaman Task Management, temukan pekerjaan yang ingin dikelola dan pilih more > Rebrush task di kolom Operation.

3. Di panel Rebrush task, tentukan parameter Start and end date dan Data Time dan klik OK.

   • Start and end date: Menentukan rentang waktu pekerjaan.

   • Data Time: Menentukan titik waktu data yang ingin diperbarui.

   

   Konfigurasi sampel:

   • Waktu saat ini adalah 10:00:00 pada 1 Januari 2019.

   • Rentang waktu pekerjaan adalah dari 1 Oktober 2018 hingga 7 Oktober 2018. Waktu mulai default adalah 00:00:00 pada 1 Oktober 2018 dan waktu akhir default adalah 23:59:59 pada 7 Oktober 2018.

   • Titik waktu data yang akan diproses ulang adalah 11:11:11.

   Pekerjaan dijalankan ulang tujuh kali dan tujuh instans pekerjaan dihasilkan.

   No.	Waktu Penjadwalan	Titik waktu pemrosesan ulang data
   1	2019.1.1 10:00:00	2018.10.1 11:11:11
   2	2019.1.1 10:00:00	2018.10.2 11:11:11
   3	2019.1.1 10:00:00	2018.10.3 11:11:11
   4	2019.1.1 10:00:00	2018.10.4 11:11:11
   5	2019.1.1 10:00:00	2018.10.5 11:11:11
   6	2019.1.1 10:00:00	2018.10.6 11:11:11
   7	2019.1.1 10:00:00	2018.10.7 11:11:11

Lihat catatan operasi dan catatan eksekusi pekerjaan

• Lihat catatan eksekusi: Di halaman Task Management, temukan pekerjaan yang ingin dikelola dan pilih more > Historical records di kolom Operation.

• Lihat catatan operasi: Di halaman Task Management, temukan pekerjaan yang ingin dikelola dan pilih more > Operation Record di kolom Operation.

Hapus pekerjaan

1. Di halaman Task Management, temukan pekerjaan yang ingin dikelola dan pilih more > Delete di kolom Operation.

2. Di kotak dialog yang muncul, klik Confirm.

Impor atau ekspor pekerjaan

1. Di halaman Task Management, pilih aplikasi Edisi Profesional.

2. Klik Import Task atau Export Tasks.