Function Compute：Tugas asinkron

Batasan

• Skenario

  Meskipun fitur tugas asinkron menyediakan lebih banyak kemampuan, beban sistem yang lebih besar juga ditimbulkan. Kami menyarankan agar Anda menonaktifkan fitur ini dalam skenario berikut:

  • Aplikasi bisnis Anda sensitif terhadap latensi pada rantai pemrosesan permintaan dan memerlukan latensi rata-rata kurang dari 100 milidetik.

  • Anda perlu memulai setidaknya ribuan pemanggilan asinkron per detik.

• Wilayah yang didukung

  Fitur tugas asinkron didukung di wilayah berikut: Tiongkok (Hangzhou), Tiongkok (Shanghai), Tiongkok (Qingdao), Tiongkok (Beijing), Tiongkok (Zhangjiakou), Tiongkok (Ulanqab), Tiongkok (Shenzhen), Tiongkok (Chengdu), Tiongkok (Hong Kong), Singapura, Inggris (London), AS (Silicon Valley), AS (Virginia), Jerman (Frankfurt), Australia (Sydney), Malaysia (Kuala Lumpur), Indonesia (Jakarta), Thailand (Bangkok), Jepang (Tokyo), dan Korea Selatan (Seoul).

• Periode validitas

  Anda hanya dapat mengkueri informasi status tugas dalam tujuh hari terakhir.

Perbandingan antara tugas asinkron dan pekerjaan Kubernetes

Baik fitur tugas asinkron Function Compute maupun pekerjaan Kubernetes dapat digunakan untuk menjalankan tugas asinkron. Function Compute menyediakan platform eksekusi tugas asinkron siap pakai yang lebih efisien serta lebih mudah dikendalikan dan diamati berdasarkan fitur tugas asinkron. Tabel berikut membandingkan kedua metode tersebut:

Manajemen tugas

Status tugas asinkron

Untuk setiap pemanggilan tugas, Function Compute mencatat informasi perubahan status tugas dan memungkinkan Anda mengkueri status tugas secara real time. Anda dapat melihat status tugas menggunakan SDK Function Compute atau Konsol Function Compute. Sebuah tugas dapat berada dalam salah satu status berikut:

Anda dapat memanggil operasi GetAsyncTask untuk mengkueri detail tugas asinkron. Anda juga dapat memanggil operasi ListAsyncTasks untuk memfilter tugas dalam status tertentu.

Kelola tugas

{
  "asyncTask": true
}

Picu tugas menggunakan event

Anda dapat membuat pemicu yang mendukung pemanggilan asinkron untuk memicu tugas asinkron. Berikut adalah pemicu yang mendukung pemanggilan asinkron:

• Pemicu HTTP

• Pemicu waktu

• Pemicu OSS

• Pemicu topik Simple Message Queue (sebelumnya MNS)

• Pemicu berbasis EventBridge:

  • Pemicu antrian Simple Message Queue (sebelumnya MNS)

  • Pemicu ApsaraMQ for RocketMQ

  • Pemicu ApsaraMQ for RabbitMQ

  • Pemicu ApsaraMQ for Kafka

  • Pemicu ApsaraMQ for MQTT

  • Pemicu Data Transmission Service (DTS)

  Penting

  Pastikan pemicu HTTP dan pemicu berbasis EventBridge dipicu dalam mode asinkron.

Deduplikasi tugas

Untuk menghindari eksekusi tugas berulang, Function Compute memungkinkan Anda menetapkan ID unik global untuk setiap tugas yang dikirimkan. Jika operasi asinkron, seperti operasi pengiriman asinkron, mengalami timeout, Anda dapat mencoba ulang dengan mengirimkan tugas menggunakan ID yang sama. Untuk informasi selengkapnya, lihat Kebijakan pengulangan.

Function Compute memungkinkan Anda mengonfigurasi TaskID, yaitu ID tugas unik global. Kami menyarankan agar Anda menentukan ID tugas setiap kali mengirimkan tugas. Anda dapat menggunakan ID tugas tersebut untuk mencoba ulang tugas jika terjadi kesalahan seperti timeout. Function Compute memverifikasi tugas yang Anda kirimkan. Jika tugas dengan ID yang sama masuk ke sistem, permintaan akan ditolak dan kesalahan 409 dikembalikan.

Tetapkan TaskID

Anda dapat mengirimkan tugas untuk dieksekusi menggunakan Function Compute console, menggunakan Serverless Devs, atau memanggil operasi API. Jika Anda perlu mengonfigurasi TaskID, atur parameter x-fc-async-task-id saat memicu fungsi Anda.

Untuk informasi selengkapnya tentang contoh kode untuk menetapkan TaskID, lihat Contoh kode.

Pemantauan tugas

Anda dapat menggunakan metrik pemantauan tugas yang disediakan oleh Function Compute untuk memantau status tugas asinkron secara real time dan mendeteksi anomali seperti kesalahan dan timeout secara tepat waktu.

Prasyarat

Fungsi telah dibuat. Untuk informasi selengkapnya, lihat Buat fungsi.

Prosedur

1. Masuk ke Konsol Function Compute. Di panel navigasi sebelah kiri, pilih Function Management > Functions.

2. Di bilah navigasi atas, pilih wilayah. Di halaman Functions, klik fungsi yang diinginkan.

   Di halaman detail fungsi, klik tab Monitoring untuk melihat metrik terkait pemanggilan asinkron dan penggunaan sumber daya tingkat instans tugas asinkron. Untuk informasi selengkapnya tentang metrik, lihat Metrik pemantauan.

   • Klik tab Function Metrics untuk melihat metrik terkait pemanggilan asinkron. Gambar berikut menunjukkan contohnya:

     

   • Klik tab Instance Metrics untuk melihat penggunaan sumber daya tingkat instans tugas asinkron. Gambar berikut menunjukkan contohnya:

     Catatan

     Sebelum mengaktifkan metrik tingkat instans, Anda harus mengaktifkan fitur logging. Untuk informasi selengkapnya, lihat Konfigurasikan fitur logging.

     

3. Konfigurasikan aturan peringatan berbasis metrik.

   Jika Anda ingin memantau metrik, seperti penggunaan memori dan penggunaan vCPU, klik di pojok kanan atas metrik untuk membuka panel Create Metric-based Alert Rule. Konfigurasikan kondisi dan ambang batas peringatan sesuai kebutuhan bisnis Anda, lalu klik OK.

   Gambar berikut memberikan contoh konfigurasi aturan peringatan, di mana peringatan dengan tingkat keparahan Sedang dilaporkan ke kontak melalui DingTalk, email, telepon, dan webhook sepanjang waktu jika backlog pemanggilan asinkron suatu fungsi lebih besar dari atau sama dengan lima.

   

Orkestrasi pekerjaan

Anda dapat mengintegrasikan Function Compute dengan CloudFlow sehingga pemanggilan asinkron fungsi dapat diterapkan pada proses tugas dalam skenario berskala besar dan kompleks. Anda dapat mengorkestrasikan tugas asinkron Function Compute berdasarkan logika kendali CloudFlow, seperti Sequence, Choice, dan Parallel. CloudFlow mengkoordinasikan eksekusi tugas sesuai langkah-langkah yang ditentukan secara andal, melacak transisi status setiap tugas, dan mengeksekusi logika pengulangan yang telah ditentukan bila diperlukan untuk memastikan kelancaran dan keberhasilan penyelesaian tugas. Untuk informasi selengkapnya, lihat Integrasikan CloudFlow dengan Function Compute.

Prasyarat

• Tugas asinkron telah dibuat. Untuk informasi selengkapnya, lihat Manajemen tugas.

• Izin untuk mengakses CloudFlow telah diberikan kepada Function Compute. Untuk informasi selengkapnya, lihat Gunakan peran fungsi untuk memberikan akses Function Compute ke layanan Alibaba Cloud lainnya.

Prosedur

1. Masuk ke Konsol CloudFlow. Di bilah navigasi atas, pilih wilayah.

2. Di panel navigasi sebelah kiri, klik Workflows. Di halaman Workflows, klik Create Workflow.

3. Di kotak dialog Create Workflow, pilih metode untuk membuat alur kerja, lalu pilih mode untuk alur kerja tersebut.

   CloudFlow memungkinkan Anda membuat alur kerja dalam mode standar atau mode express. Untuk informasi selengkapnya tentang kedua mode tersebut, lihat Mode standar dan mode express. Untuk informasi selengkapnya, lihat Buat alur kerja berdasarkan kanvas kosong.

4. Edit alur yang telah dibuat.

   1. Edit alur.

      Anda dapat menggunakan CloudFlow Studio atau YAML untuk mengedit alur. Dalam contoh ini, YAML digunakan.

      Di pojok kanan atas halaman detail alur, klik YAML. Di editor kode sebelah kiri, masukkan kode yang akan digunakan oleh alur tersebut lalu klik Save.

      Kode contoh:

      Type: StateMachine
      Name: MyFlow
      SpecVersion: v1
      StartAt: InvokeFunction
      States:
        - Type: Task
          Name: InvokeFunction
          Action: FC:InvokeFunction
          TaskMode: RequestComplete
          Parameters:
            invocationType: Async
            resourceArn: acs:fc:us-west-1:103435468****:functions/func-i1****/LATEST
          End: true

   2. Konfigurasikan peran alur.

      Di pojok kanan atas halaman detail alur, klik Configure Workflow, pilih peran dari daftar drop-down Execution Role di bagian Role Configuration, lalu klik Save.

      Catatan

      Pastikan peran yang dikonfigurasi untuk alur telah dilampirkan kebijakan AliyunFCInvocationAccess.

5. Di halaman detail alur, klik Execute di pojok kanan atas untuk memicu alur dan memeriksa apakah alur berfungsi sesuai harapan.