Melakukan Lease Tugas Pull

Setelah tugas berada dalam pull queue, worker melakukan lease untuk tugas tersebut. Setelah tugas diproses, worker harus menghapusnya.

API ini didukung untuk runtime generasi pertama dan dapat digunakan saat meng-upgrade ke runtime generasi kedua yang sesuai. Jika Anda mengupdate ke runtime App Engine Java 11/17, lihat panduan migrasi guna mempelajari opsi migrasi untuk layanan paket lama.

Sebelum memulai

• Buat pull queue.
• Buat tugas dan tambahkan ke pull queue.

Konteks penting

• Metode ini hanya berlaku untuk worker yang berjalan dalam layanan di lingkungan standar.
• Saat menggunakan pull queue, Anda bertanggung jawab untuk menskalakan worker berdasarkan volume pemrosesan Anda.

Tugas leasing

Setelah tugas berada dalam antrean, worker dapat me-lease satu atau beberapa tugas tersebut menggunakan metode leaseTasks(). Mungkin ada penundaan singkat sebelum tugas yang baru ditambahkan menggunakan add() menjadi tersedia melalui leaseTasks().

Saat meminta lease, Anda menentukan jumlah tugas yang akan di-lease (hingga maksimum 1.000 tugas) dan durasi lease dalam hitungan detik (hingga maksimum satu minggu). Durasi lease harus cukup lama untuk memastikan bahwa tugas paling lambat memiliki waktu untuk diselesaikan sebelum periode lease berakhir. Anda dapat mengubah lease tugas menggunakan modifyTaskLease().

Leasing tugas membuat tugas tidak tersedia untuk diproses oleh worker lain, dan tetap tidak tersedia hingga periode lease berakhir.

Catatan: leaseTasks() hanya beroperasi pada pull queue. Jika Anda mencoba me-lease tugas yang ditambahkan dalam push queue, App Engine akan menampilkan pengecualian.

Contoh kode berikut me-lease tugas dari antrean pull-queue selama satu jam:

List<TaskHandle> tasks = q.leaseTasks(3600, TimeUnit.SECONDS, numberOfTasksToLease);

Membuat batch dengan tag tugas

Beta

Produk atau fitur ini tunduk pada "Persyaratan Penawaran Pra-GA" di bagian Persyaratan Layanan Umum di Persyaratan Khusus Layanan. Produk dan fitur pra-GA tersedia "sebagaimana adanya" dan mungkin memiliki dukungan terbatas. Untuk mengetahui informasi selengkapnya, lihat deskripsi tahap peluncuran.

Tidak semua tugas itu sama; kode Anda dapat "memberi tag" pada tugas lalu memilih tugas untuk di-lease berdasarkan tag. Tag berfungsi sebagai filter.

q.add(
    TaskOptions.Builder.withMethod(TaskOptions.Method.PULL)
        .payload(content.toString())
        .tag("process".getBytes()));

Kemudian, lease tugas yang difilter:

// Lease only tasks tagged with "process"
List<TaskHandle> tasks =
    q.leaseTasksByTag(3600, TimeUnit.SECONDS, numberOfTasksToLease, "process");
// You can also specify a tag to lease via LeaseOptions passed to leaseTasks.

Mengatur laju polling

Worker yang melakukan polling pada antrean untuk tugas yang akan di-lease harus mendeteksi apakah mereka mencoba untuk melakukan lease tugas lebih cepat daripada yang dapat disediakan oleh antrean. Jika kegagalan ini terjadi, pengecualian berikut dari leaseTasks() dapat dihasilkan:

• TransientFailureException
• ApiDeadlineExceededException

Kode Anda harus menangkap pengecualian ini, berhenti memanggil leaseTasks(), lalu mencoba lagi nanti. Untuk menghindari masalah ini, sebaiknya tetapkan batas waktu RPC yang lebih tinggi saat memanggil leaseTasks(). Anda juga harus mundur saat permintaan sewa menampilkan daftar tugas kosong.

Jika Anda membuat lebih dari 10 permintaan LeaseTasks per antrean per detik, hanya 10 permintaan pertama yang akan menampilkan hasil. Jika permintaan melebihi batas ini, OK akan ditampilkan dengan nol hasil.

Memantau tugas di konsol Google Cloud

Untuk melihat informasi tentang semua tugas dan antrean dalam aplikasi Anda:

1. Buka halaman Cloud Tasks di konsol Google Cloud dan cari nilai Pull di kolom Type.

   Buka Cloud Tasks

2. Klik nama antrean yang Anda minati, lalu halaman detail antrean akan terbuka. Tindakan ini akan menampilkan semua tugas dalam antrean yang dipilih.

Menghapus tugas

Setelah menyelesaikan tugas, worker perlu menghapus tugas dari antrean. Jika Anda melihat tugas tersisa dalam antrean setelah worker selesai memprosesnya, kemungkinan worker tersebut gagal; dalam hal ini, tugas akan diproses oleh worker lain.

Anda dapat menghapus tugas satu per satu atau daftar tugas menggunakan deleteTask(). Anda harus mengetahui nama tugas untuk dapat menghapusnya. Anda dapat menemukan nama tugas di Task object yang ditampilkan oleh leaseTasks().

Contoh kode berikut menunjukkan cara menghapus tugas dari antrean:

q.deleteTask(task);