Microservices Engine：Manajemen tugas

Buat tugas penjadwalan

1. Masuk ke Konsol MSE SchedulerX.

2. Di panel navigasi sebelah kiri, klik Task Management dan pilih wilayah serta Namespace.

3. Klik Create Task. Pada langkah Basic Configuration, konfigurasikan parameter dan klik Next.

   Tabel berikut menjelaskan parameter konfigurasi dasar.

   Nama Konfigurasi	Deskripsi
   Task Name	Nama kustom untuk pekerjaan.
   Description	Deskripsi pekerjaan. Tentukan deskripsi yang ringkas untuk memudahkan pencarian pekerjaan.
   Application ID	Kelompok tempat pekerjaan tersebut berada. Pilih nilai dari daftar tarik-turun.
   Task Type	Bahasa yang digunakan untuk mengimplementasikan pekerjaan. Nilai yang valid: Java, XXL-JOB, SpringSchedule, Golang, ScriptTask, Http, dan DataWorks. Jika Anda memilih Script Task, Anda harus memilih bahasa skrip: shell, python, atau go. Anda dapat menulis skrip tugas di editor.
   Class Full Path	Catatan Parameter ini hanya tersedia jika parameter Task Type diatur ke Java. Jalur lengkap JobProcessor. Contoh: xxx.xxx.xxx.HelloProcessor.
   Execution Mode	Mode eksekusi pekerjaan. Mode berikut didukung: Stand-alone Operation: Pekerjaan dijalankan pada worker acak. Broadcast Run: Pekerjaan dijalankan secara konkuren di semua worker, dan sistem menunggu hingga semua worker menyelesaikan pekerjaan tersebut. Visual MapReduce: Model Map yang mendukung kurang dari 300 subtugas dan menyediakan daftar subtugas. Dalam Edisi Profesional, maksimal 1.000 pekerjaan diperbolehkan, dan pekerjaan dapat dicari berdasarkan kata kunci bisnis. MapReduce: Model MapReduce standar untuk memproses banyak subtugas secara paralel. Anda hanya dapat mencari informasi ringkasan untuk subtugas tersebut. Gunakan mode ini untuk pekerjaan dengan kurang dari 1.000.000 subtugas. Shard Run: Mirip dengan model elastic-job. Sharding didistribusikan secara merata ke beberapa klien untuk dieksekusi berdasarkan parameter sharding yang dikonfigurasi. Mode ini mendukung berbagai bahasa pemrograman. Catatan Parameter dalam Pengaturan Lanjutan bervariasi tergantung pada Execution Mode yang dipilih.
   Task Parameters	String arbitrer yang dapat diperoleh dari konteks saat waktu proses.

   Tabel berikut menjelaskan parameter konfigurasi lanjutan.

   Parameter	Mode eksekusi yang berlaku	Deskripsi	Nilai default
   Jumlah percobaan ulang saat tugas gagal	Semua mode	Jumlah percobaan ulang otomatis jika pekerjaan gagal. Catatan Jika pekerjaan sedang berjalan di worker dan worker tersebut direstart, pekerjaan akan gagal. Jika Anda ingin segera menjalankan ulang pekerjaan tersebut, Anda dapat menentukan parameter ini.	0
   Interval percobaan ulang saat tugas gagal	Semua mode	Interval antara dua percobaan ulang berturut-turut. Satuan: detik.	30
   Konkurensi tugas	Semua mode	Jumlah instans yang menjalankan pekerjaan yang sama secara bersamaan. Nilai 1 berarti eksekusi konkuren tidak diizinkan.	1
   Strategi pembersihan	Semua mode	Kebijakan pembersihan riwayat eksekusi pekerjaan.	Pertahankan N entri terakhir
   Jumlah yang Dipertahankan	Semua mode	Jumlah catatan eksekusi pekerjaan yang dipertahankan.	300
   Jumlah konkurensi subtugas per mesin tunggal	Visual MapReduce MapReduce Shard run	Jumlah tugas yang berjalan secara konkuren pada satu worker dalam model terdistribusi. Untuk mempercepat eksekusi, Anda dapat menentukan nilai yang lebih besar. Jika sistem downstream atau database tidak mampu menangani nilai yang Anda tentukan, Anda dapat menentukan nilai yang lebih kecil.	5
   Jumlah percobaan ulang saat subtugas gagal	Visual MapReduce MapReduce Shard run	Jumlah percobaan ulang otomatis jika tugas gagal dalam model terdistribusi.	0
   Interval percobaan ulang saat subtugas gagal	Visual MapReduce MapReduce Shard run	Interval antara dua percobaan ulang berturut-turut jika tugas gagal dalam model terdistribusi. Satuan: detik.	0
   Strategi Failover Subtugas	Visual MapReduce MapReduce Shard run	Menentukan apakah tugas didistribusikan ke worker baru setelah worker gagal mengeksekusi tugas dan berhenti. Jika Anda mengaktifkan sakelar ini, sistem mungkin mengeksekusi tugas lebih dari sekali ketika failover dipicu. Anda harus menerapkan idempotensi tugas. Catatan Parameter ini berlaku untuk agen V1.8.13 dan versi 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 jumlah tugas sangat besar, kami menyarankan agar Anda menonaktifkan sakelar ini. Catatan Parameter ini berlaku untuk agen V1.8.13 dan versi yang lebih baru.
   Metode distribusi subtugas	Visual MapReduce MapReduce Shard run	Push model: Tugas didistribusikan secara merata ke worker. Pull model: Setiap worker menarik tugas. Teori Ember Kayu tidak berlaku untuk model ini. Selama proses pull, semua tugas di-cache di node master. Hal ini memberikan tekanan pada memori. Kami menyarankan agar 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 memerlukan waktu hampir sama untuk memproses tugas. Strategi optimal Beban Worker: Node master secara otomatis mendeteksi beban worker. Kebijakan ini cocok untuk skenario di mana terdapat perbedaan besar antara waktu yang dibutuhkan setiap worker untuk memproses tugas. Catatan Parameter ini berlaku untuk agen V1.10.14 dan versi yang lebih baru.
   Laju distribusi	Visual MapReduce MapReduce	Laju distribusi tugas. Anda dapat menentukan jumlah tugas yang didistribusikan per detik atau per menit.
   Jumlah subtugas yang ditarik per kali	Visual MapReduce MapReduce Shard run	Jumlah tugas yang ditarik oleh node slave dari node master sekaligus. Parameter ini hanya ditampilkan jika parameter metode distribusi subtugas diatur ke Model pull.	5
   Kapasitas antrian subtugas	Visual MapReduce MapReduce Shard run	Ukuran antrian yang menyimpan cache tugas di node slave. Parameter ini hanya ditampilkan jika parameter metode distribusi subtugas diatur ke Model pull.	10
   Konkurensi global subtugas	Visual MapReduce MapReduce Shard run	Jumlah total tugas konkuren di semua worker dalam model pull. Parameter ini membantu Anda membatasi jumlah tugas konkuren. Parameter ini hanya ditampilkan jika parameter metode distribusi subtugas diatur ke Model pull.	1000

4. Pada langkah Timing Configuration, konfigurasikan penjadwalan dan pengaturan lanjutan, lalu klik Next Step.

   

   Tabel berikut menjelaskan parameter waktu.

   Item Konfigurasi	Deskripsi
   Time Type	none: Pekerjaan tidak dijadwalkan untuk berjalan secara otomatis. Biasanya dipicu oleh alur kerja. cron: Ekspresi cron. api: Pemicu API. fixed_rate: Interval tetap. second_delay: Penundaan tetap dalam hitungan detik. onetime: Tugas satu kali. unix cron: Ekspresi cron bergaya Unix.
   Cron Expression (Hanya untuk jenis waktu cron)	Masukkan ekspresi cron yang sesuai dengan sintaks cron. Anda juga dapat menggunakan alat untuk menghasilkan dan memverifikasi ekspresi tersebut.
   Fixed Frequency (hanya untuk jenis waktu fixed_rate)	Masukkan interval penjadwalan dalam detik. Nilainya harus lebih besar dari 60. Misalnya, jika Anda memasukkan 200, pekerjaan akan berjalan setiap 200 detik.
   Fixed Delay (Hanya berlaku untuk jenis waktu second_delay)	Masukkan penundaan tetap antara 1 hingga 60 detik. Misalnya, nilai 5 akan memicu pekerjaan setelah penundaan 5 detik.
   Scheduling Time (Hanya untuk jenis waktu onetime)	Tentukan waktu eksekusi untuk tugas tersebut. Contoh: 2023-7-13 00:00:00.
   UNIX Cron Expression (Hanya untuk jenis waktu UNIX Cron)	Masukkan ekspresi cron dalam format UNIX.

   Tabel berikut menjelaskan parameter konfigurasi lanjutan.

   Item Konfigurasi	Deskripsi
   Time Offset	Offset antara waktu data dan waktu jadwal. Anda dapat mengambil nilai ini dari konteks selama penjadwalan.
   Time Zone	Pilih zona waktu untuk suatu negara atau wilayah. Anda juga dapat memilih zona waktu GMT standar.

5. Pada langkah Notification Configuration, konfigurasikan pengaturan peringatan dan kontak, lalu klik Complete.

   

   Anda dapat mengatur parameter Notification Channel and Contact Person menjadi Application Group Contact atau User-defined.

   • Application Group Contact

     Semua kontak dalam kelompok aplikasi menerima notifikasi.

   • User-defined

     Untuk notifikasi kustom, Anda dapat memilih Contact Group atau Contact.

     • Contact Group

       Semua kontak dalam grup kontak menerima notifikasi. Untuk informasi selengkapnya tentang cara membuat grup kontak, lihat Notification Contacts.

     • Contact

       1. Tambahkan satu atau beberapa kontak untuk menerima notifikasi. Klik Add Contact lalu klik Go To Create Contact.

       

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

       

       

6. Anda dapat kembali ke halaman Task Management dan memverifikasi bahwa pekerjaan yang Anda buat tercantum dan parameternya sesuai dengan konfigurasi.

   Catatan

   Secara default, pekerjaan terjadwal diaktifkan setelah dibuat. Anda juga dapat menonaktifkan atau mengaktifkan pekerjaan tersebut sesuai kebutuhan. Untuk informasi selengkapnya, lihat Mengaktifkan dan menonaktifkan tugas penjadwalan.

Edit tugas penjadwalan

1. Di halaman Task Management, di kolom Operation, klik Edit untuk pekerjaan target.

   

2. Di panel Edit, Anda dapat mengonfigurasi pengaturan dasar, penjadwalan, dan peringatan.

   Catatan

   Anda tidak dapat mengubah Application ID atau Task Type. Parameter lainnya dikonfigurasi sama seperti saat membuat tugas.

Jalankan tugas penjadwalan

Di halaman Job Management, Anda dapat mengklik Run Once di kolom Actions untuk menjalankan pekerjaan terjadwal satu kali.

Mengaktifkan dan menonaktifkan tugas penjadwalan

Salin tugas penjadwalan

Di halaman Task Management, klik More > Copy di kolom Actions untuk tugas target. Anda kemudian dapat mengedit konfigurasi tugas yang disalin untuk membuat tugas penjadwalan baru.

Jalankan ulang tugas penjadwalan

Jika bisnis Anda berubah, Anda mungkin perlu menjalankan ulang tugas untuk periode sebelumnya. Misalnya, Anda mungkin perlu memproses ulang data setelah menambahkan bidang ke database atau menemukan kesalahan pada data bulan sebelumnya.

Jika data dari eksekusi tugas sebelumnya salah atau hilang, Anda dapat mengatur ulang parameter eksekusi untuk menjalankan ulang tugas dan mengambil data yang benar.

1. Masuk ke Konsol MSE SchedulerX.

2. Di halaman Task Management, di kolom Actions untuk pekerjaan target, klik More > Rebrush Task.

3. Di panel Rebrush Task, tentukan parameter Start and End Date dan Data Time lalu klik OK.

   • Start and End Date: Menentukan rentang tanggal untuk menjalankan ulang.

   • Data Time: Menentukan waktu untuk backfill dalam rentang tanggal yang dipilih.

   

   Contoh konfigurasi:

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

   • Rentang tanggal menjalankan ulang 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.

   • Waktu data untuk menjalankan ulang adalah 11:11:11.

   Tugas dijalankan ulang tujuh kali, dan tujuh instans dihasilkan.

   Nomor Seri	Waktu penjadwalan	Waktu 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 eksekusi dan operasi tugas

• Untuk melihat catatan eksekusi: Di halaman Task Management, di kolom Actions tugas target, klik More > History.

• Lihat catatan operasi: Di halaman Task Management, klik More > Operation Record di kolom Actions untuk tugas yang diinginkan.

Hapus tugas penjadwalan

1. Di halaman Job Management, di kolom Actions untuk pekerjaan target, klik More > Delete.

   

2. Di kotak dialog konfirmasi, klik Confirm.

Impor atau ekspor tugas

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

   

2. Klik Import Task atau Export Tasks.