SchedulerX:Manajemen Pekerjaan

Buat pekerjaan

1. Masuk ke Konsol SchedulerX.

2. Di bilah navigasi atas, pilih Wilayah.

3. Di panel navigasi kiri, pilih task management.

4. Di halaman , pilih namespace dan klik Create Task. Di halaman wizard Basic Configuration, konfigurasikan parameter pekerjaan, lalu klik Next.

   Tabel berikut menjelaskan parameter konfigurasi dasar.

   Parameter	Deskripsi
   Name	Nama kustom untuk pekerjaan tersebut.
   Description	Deskripsi singkat untuk membantu Anda menemukan dan mengelola pekerjaan tersebut.
   Application ID	Kelompok aplikasi tempat pekerjaan tersebut berada. Anda dapat memilih kelompok aplikasi dari daftar drop-down.
   Job Type	Bahasa pemrograman yang digunakan untuk mengimplementasikan pekerjaan tersebut. Jenis yang didukung meliputi Java, XXL-JOB, SpringSchedule, Golang, script task, Http, dan DataWorks. Jika Anda memilih script task, Anda juga harus memilih bahasa skrip (shell, python, atau go) dan menulis skrip pekerjaan di editor.
   Class full path	Catatan Parameter ini hanya tersedia jika Anda mengatur Job type ke Java. Jalur lengkap JobProcessor, misalnya, xxx.xxx.xxx.HelloProcessor.
   Execution Mode	Mode eksekusi pekerjaan tersebut. Mode berikut didukung: Standalone: Menjalankan pekerjaan pada worker yang dipilih secara acak. broadcast run: Menjalankan pekerjaan pada semua worker yang tersedia secara bersamaan dan menunggu hingga selesai. Visual MapReduce: Model Map dengan daftar visual subtask. Anda dapat menjalankan hingga 300 subtask. Edisi Profesional mendukung hingga 1.000 subtask dan memungkinkan Anda mengkueri subtask berdasarkan kata kunci bisnis. MapReduce: Model MapReduce standar yang mendukung sejumlah besar subtask yang berjalan secara paralel. Anda hanya dapat mengkueri informasi ringkasan untuk subtask. Mode ini direkomendasikan untuk 1.000.000 subtask atau kurang. shard run: Mirip dengan model elastic-job. Anda mengonfigurasi parameter sharding untuk mendistribusikan shard secara merata di antara beberapa worker untuk dieksekusi. Mode ini mendukung berbagai bahasa pemrograman. Catatan Parameter dalam pengaturan lanjutan bervariasi berdasarkan Execution Mode yang dipilih.
   Job Parameters	String arbitrer yang dapat Anda ambil dari konteks saat runtime.

   Tabel berikut menjelaskan parameter konfigurasi lanjutan.

   Parameter	Mode eksekusi yang berlaku	Deskripsi	Bawaan
   Job retry attempts on failure	General	Jumlah percobaan ulang otomatis jika pekerjaan gagal. Catatan Pekerjaan gagal jika workernya dimulai ulang. Gunakan parameter ini untuk menjalankan ulang pekerjaan segera.	0
   Job retry interval on failure	General	Interval antar percobaan ulang. Satuan: detik.	30
   Job concurrency	General	Jumlah instans konkuren yang diizinkan untuk pekerjaan tersebut. Nilai 1 menunjukkan bahwa instans pekerjaan tidak dapat berjalan secara konkuren.	1
   Cleanup policy	General	Kebijakan pembersihan untuk riwayat eksekusi pekerjaan.	Keep the last N records
   Number of records to keep	General	Jumlah catatan eksekusi historis yang disimpan.	300
   Subtask concurrency per worker	Visual MapReduce MapReduce shard run	Dalam model terdistribusi, parameter ini menentukan jumlah subtask yang dapat diproses secara konkuren oleh satu worker. Anda dapat meningkatkan nilai ini untuk mempercepat eksekusi. Jika layanan atau database downstream tidak mampu menangani beban tersebut, Anda dapat menurunkan nilai ini.	5
   Subtask retry attempts on failure	Visual MapReduce MapReduce shard run	Dalam model terdistribusi, parameter ini menentukan jumlah kali subtask dicoba ulang secara otomatis jika gagal.	0
   Subtask retry interval on failure	Visual MapReduce MapReduce shard run	Dalam model terdistribusi, parameter ini menentukan interval antar percobaan ulang otomatis untuk subtask yang gagal. Satuan: detik.	0
   Subtask failover policy	Visual MapReduce MapReduce shard run	Menentukan apakah subtask akan didistribusikan ulang ke worker lain jika worker yang mengeksekusi offline. Jika Anda mengaktifkan fitur ini, subtask mungkin dieksekusi lebih dari sekali selama failover. Pastikan kode Anda idempoten. Catatan Fitur ini memerlukan versi worker 1.8.13 atau lebih baru.
   Master node participation in execution	Visual MapReduce MapReduce shard run	Menentukan apakah node master juga mengeksekusi subtask. Diperlukan minimal dua worker online. Kami menyarankan agar Anda menonaktifkan parameter ini ketika jumlah subtask sangat besar. Catatan Fitur ini memerlukan versi worker 1.8.13 atau lebih baru.
   Subtask dispatching mode	Visual MapReduce MapReduce shard run	push model: Subtask didistribusikan secara merata ke setiap worker. pull model: Setiap worker menarik subtask, yang menghindari efek "worker paling lambat". Semua subtask di-cache di node master selama proses ini, sehingga meningkatkan tekanan memori. Mode ini direkomendasikan untuk 10.000 subtask atau kurang.	push model
   Dispatching strategy	Visual MapReduce MapReduce	Strategi untuk mendispatch subtask. Secara bawaan, subtask didispatch ke worker secara round-robin. Round-robin strategy: Subtask didistribusikan secara merata ke setiap worker. Strategi ini cocok untuk skenario di mana setiap subtask membutuhkan waktu pemrosesan yang kurang lebih sama. Load-optimal strategy: Node master mendeteksi beban di setiap worker secara dinamis. Strategi ini cocok untuk skenario di mana waktu pemrosesan bervariasi signifikan di antara subtask atau worker. Catatan Fitur ini memerlukan versi worker 1.10.14 atau lebih baru.
   Dispatching rate	Visual MapReduce MapReduce	Laju pendispatch-an subtask. Anda dapat menentukan jumlah subtask yang didispatch per detik atau per menit.
   Number of subtasks per pull (pull model only)	Visual MapReduce MapReduce shard run	Jumlah subtask yang ditarik oleh worker dari node master dalam satu permintaan.	5
   Subtask queue capacity (pull model only)	Visual MapReduce MapReduce shard run	Ukuran antrian cache subtask di worker.	10
   Global subtask concurrency (pull model only)	Visual MapReduce MapReduce shard run	Model pull mendukung batas konkurensi global untuk subtask, yang dapat digunakan untuk pembatasan laju.	1.000

5. Di halaman wizard Schedule Configuration, atur parameter penjadwalan dan parameter konfigurasi lanjutan, lalu klik Next.

   Tabel berikut menjelaskan parameter penjadwalan.

   Parameter	Deskripsi
   Time Type	none: Tidak dijadwalkan. Pekerjaan biasanya dipicu oleh alur kerja. cron: Pekerjaan dipicu berdasarkan ekspresi CRON. api: Pekerjaan dipicu oleh panggilan API. fixed_rate: Pekerjaan dipicu dengan frekuensi tetap. second_delay: Pekerjaan dipicu setelah penundaan tetap dalam hitungan detik. onetime: Pekerjaan hanya dijalankan sekali. unix cron: Pekerjaan dipicu berdasarkan ekspresi CRON dalam format UNIX standar.
   Cron Expression (tersedia hanya jika Anda mengatur Time type ke cron)	Masukkan ekspresi CRON. Anda dapat menulis ekspresi secara manual atau menggunakan tool untuk menghasilkan dan memvalidasinya.
   Fixed frequency (tersedia hanya jika Anda mengatur Time type ke fixed_rate)	Masukkan interval tetap dalam detik. Nilainya harus 60 atau lebih besar. Misalnya, nilai 200 berarti pekerjaan dijadwalkan setiap 200 detik.
   Fixed delay (tersedia hanya jika Anda mengatur Time type ke second_delay)	Masukkan penundaan tetap dalam detik. Nilainya harus bilangan bulat dari 1 hingga 60. Misalnya, nilai 5 berarti pekerjaan dipicu setelah penundaan 5 detik.
   Scheduling time (tersedia hanya jika Anda mengatur Time type ke onetime)	Masukkan waktu spesifik untuk menjalankan pekerjaan, misalnya, 2023-7-13 00:00:00.
   unix cron expression (tersedia hanya jika Anda mengatur Time type ke unix cron)	Masukkan ekspresi CRON dalam format UNIX standar.

   Tabel berikut menjelaskan parameter konfigurasi lanjutan.

   Parameter	Deskripsi
   Time offset	Offset waktu data relatif terhadap waktu terjadwal. Anda dapat mengambil nilai ini dari konteks saat runtime.
   Time Zone	Pilih zona waktu sesuai kebutuhan Anda. Anda dapat memilih dari negara dan wilayah umum atau menggunakan format GMT standar.

6. Di halaman wizard Notification Configuration, atur parameter peringatan dan kontak, lalu klik Finish.

   Parameter peringatan mencakup sakelar Timeout Alert, Timeout (dalam detik), sakelar Kill on Timeout, sakelar Success Notification, sakelar Failure Alert, Consecutive Failures, dan sakelar No Available Worker Alert. Untuk Notification channel and contact, Anda dapat memilih Application group contact atau Custom.

   Untuk Notification channel and contact, Anda dapat memilih Application group contact atau Custom.

   • Application group contact

     Semua kontak dalam kelompok aplikasi menerima notifikasi.

   • Custom

     Anda dapat menentukan Contact Group atau Contact individual untuk menerima notifikasi.

     • Contact Group

       Semua kontak dalam kelompok kontak yang dipilih menerima notifikasi. Untuk informasi selengkapnya tentang cara membuat kelompok kontak, lihat Buat kontak notifikasi atau kelompok kontak.

     • Contact

       1. Tambahkan kontak yang akan menerima notifikasi. Anda dapat menambahkan beberapa kontak notifikasi. Setelah mengklik Add contact, klik Go to create contact.

       Di bagian Notification channel and contact, pilih Custom, centang kotak webhook untuk Notification channel, dan pilih Contact untuk Notification contact. Jika daftar drop-down kontak menampilkan No options, berarti tidak ada kontak yang tersedia.

       2. Di halaman yang muncul, klik Create Contact dan masukkan informasi kontak.

       Informasi kontak mencakup Name (wajib diisi), Phone number, Email, webhook, dan Contact group.

7. Kembali ke halaman task management untuk memverifikasi bahwa pekerjaan telah dibuat dan dikonfigurasi dengan benar.

   Catatan

   Secara bawaan, pekerjaan diaktifkan saat dibuat. Anda dapat menonaktifkan dan mengaktifkannya kembali sesuai kebutuhan. Untuk informasi selengkapnya, lihat Aktifkan dan nonaktifkan pekerjaan terjadwal.

Edit pekerjaan

1. Di halaman Task Management, temukan pekerjaan tersebut dan klik Edit di kolom Actions.

2. Di panel Edit, konfigurasikan pengaturan dasar, penjadwalan, dan peringatan.

   Catatan

   Anda tidak dapat mengubah Application ID dan jenis tugas. Pengaturan untuk parameter lainnya sama seperti saat membuat pekerjaan.

Jalankan pekerjaan

Di halaman Task Management, klik Run Once di kolom Actions untuk menjalankan pekerjaan tersebut.

Aktifkan dan nonaktifkan pekerjaan

Replikasi pekerjaan

Di halaman Task Management, pilih More > Copy di kolom Actions untuk pekerjaan tersebut. Anda kemudian dapat mengedit konfigurasi pekerjaan baru tersebut.

Menjalankan ulang pekerjaan

Anda dapat melakukan rebrush pekerjaan untuk mengisi kembali data untuk periode sebelumnya. Ini berguna ketika persyaratan bisnis Anda berubah, misalnya, jika Anda menambahkan bidang baru ke database atau jika Anda perlu memperbaiki data dari bulan sebelumnya.

Jika data dari eksekusi pekerjaan sebelumnya mengalami kesalahan atau hilang, Anda dapat menjalankan ulang pekerjaan dengan parameter tertentu untuk memproses ulang data untuk periode tersebut.

1. Masuk ke Konsol SchedulerX.

2. Di halaman Task Management, temukan pekerjaan tersebut, klik More di kolom Actions, lalu klik Rebrush task.

3. Di panel Rebrush task, atur Start and end date dan Data time, lalu klik OK.

   • Start and end date: Rentang tanggal untuk menjalankan ulang pekerjaan tersebut.

   • Data time: Waktu dalam sehari yang digunakan sebagai waktu data logis untuk setiap hari dalam rentang yang ditentukan.

   Sebagai contoh, pertimbangkan konfigurasi berikut:

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

   • Start and end date diatur dari 1 Oktober 2018 hingga 7 Oktober 2018. Rentang ini mencakup periode dari 00:00:00 pada 1 Oktober 2018 hingga 23:59:59 pada 7 Oktober 2018.

   • Data time diatur ke 11:11:11.

   Dalam skenario ini, pekerjaan dijalankan ulang tujuh kali, menghasilkan tujuh instans baru.

   No.	Scheduling time	Data time
   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

Catatan eksekusi dan operasi

• Untuk melihat catatan eksekusi, buka halaman Task Management, temukan pekerjaan tersebut, lalu klik More > Historical records di kolom Actions.

• Untuk melihat catatan operasi, buka halaman Task Management, temukan pekerjaan tersebut, lalu klik More > Operation Record di kolom Actions. Di halaman Operation Record, Anda dapat menyaring catatan berdasarkan Type dan Task ID. Tabel mencantumkan Task ID, Operation Time, Operation Type, Operator, dan Extensions. Untuk melihat detail catatan, klik View di kolom Operation.

Hapus pekerjaan

1. Di halaman Task Management, temukan pekerjaan yang ingin dihapus, lalu pilih More > Delete di kolom Actions.

2. Di kotak dialog konfirmasi, klik Confirm.

Impor atau ekspor tugas

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

2. Klik Import Jobs atau Export Tasks.