Function Compute：Tugas asinkron

Keterbatasan

• Keterbatasan kasus penggunaan

  Tugas asinkron menawarkan lebih banyak fitur tetapi juga menimbulkan overhead sistem. Kami menyarankan untuk menonaktifkan mode tugas dalam skenario berikut:

  • Aplikasi Anda sangat sensitif terhadap latensi end-to-end permintaan dan memerlukan latensi rata-rata kurang dari 100 ms.

  • Anda perlu melakukan pemanggilan asinkron dengan laju ribuan permintaan per detik (RPS) atau lebih tinggi.

• Keterbatasan wilayah

  Tugas asinkron didukung di wilayah-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), Malaysia (Kuala Lumpur), Indonesia (Jakarta), Thailand (Bangkok), Jepang (Tokyo), dan Korea Selatan (Seoul).

• Periode retensi

  Anda dapat mengkueri status tugas yang dibuat dalam 7 hari terakhir.

Perbandingan dengan pekerjaan Kubernetes

Untuk menjalankan tugas asinkron, Anda dapat menggunakan fitur tugas asinkron Function Compute atau pekerjaan Kubernetes. Function Compute menyediakan platform siap pakai berarsitektur tanpa server untuk menjalankan tugas asinkron yang lebih efisien, terkontrol, dan mudah diamati. Tabel berikut membandingkan kedua metode tersebut.

Manajemen tugas

Status tugas asinkron

Untuk setiap pemanggilan tugas, Function Compute mencatat transisi status dan memungkinkan kueri status secara real-time. Anda dapat melihat status spesifik suatu tugas dengan menggunakan SDK atau Konsol Function Compute. Suatu tugas dapat berada dalam salah satu status berikut:

Panggil operasi API GetAsyncTask untuk mendapatkan detail eksekusi tugas, atau panggil operasi API ListAsyncTasks untuk memfilter tugas berdasarkan status.

Kelola tugas

{
  "asyncTask": true
}

Pemicu event

Anda dapat memicu tugas asinkron dengan membuat pemicu yang mendukung pemanggilan asinkron. Pemicu berikut mendukung fitur ini:

• Pemicu HTTP

• Pemicu Waktu

• Pemicu OSS

• Pemicu topik MNS

• Pemicu yang terintegrasi dengan EventBridge, termasuk:

  • Pemicu antrian MNS

  • Pemicu RocketMQ

  • Pemicu RabbitMQ

  • Pemicu Kafka

  • Pemicu MQTT

  • Pemicu DTS

  Penting

  Pastikan bahwa Invocation Method untuk pemicu HTTP dan pemicu yang terintegrasi dengan EventBridge diatur ke Async Invocation.

Deduplikasi tugas

Untuk mencegah eksekusi ganda, Function Compute memungkinkan Anda menetapkan ID unik global untuk setiap tugas. Jika pengiriman tugas gagal, misalnya karena timeout, Anda dapat mencoba ulang permintaan tersebut dengan aman menggunakan ID tugas yang sama. Untuk informasi selengkapnya tentang perilaku percobaan ulang, lihat kebijakan retry.

Function Compute menggunakan TaskID unik global untuk deduplikasi. Kami menyarankan agar Anda menentukan TaskID untuk setiap pengiriman tugas dan menggunakannya untuk percobaan ulang jika terjadi timeout atau kegagalan lainnya. Function Compute menolak pengiriman berikutnya dengan TaskID duplikat dengan error 409.

Tetapkan TaskID

Anda dapat mengirimkan tugas dari Function Compute console, menggunakan Serverless Devs, atau dengan memanggil operasi API. Untuk menetapkan TaskID, tentukan header x-fc-async-task-id dalam permintaan pemanggilan.

Untuk contoh kode cara menetapkan TaskID saat memicu tugas, lihat Contoh Kode (Situs Internasional).

Pemantauan tugas

Anda dapat menggunakan metrik pemantauan yang disediakan oleh Function Compute untuk mendapatkan pembaruan status real-time untuk tugas asinkron serta segera mendeteksi kesalahan, timeout, dan pengecualian lainnya.

Prasyarat

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

Prosedur

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

2. Di bilah navigasi atas, pilih wilayah. Pada halaman Function, klik fungsi target.

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

   • Klik tab Function Metrics untuk melihat metrik terkait pemanggilan asinkron, seperti Asynchronous Invocation Processing (count), Asynchronous Invocation Processing Latency (ms), Asynchronous Invocation Trigger Events (count), dan Asynchronous Requests Backlogs (count).

   • Klik tab Instance Metrics untuk melihat penggunaan sumber daya tingkat instans untuk tugas asinkron.

     Catatan

     Sebelum Anda dapat melihat metrik tingkat instans, Anda harus mengaktifkan fitur logging. Untuk informasi selengkapnya, lihat Konfigurasi logging.

4. Tetapkan aturan peringatan untuk metrik.

   Untuk memantau metrik seperti penggunaan memori atau penggunaan vCPU, klik ikon lonceng di pojok kanan atas grafik metrik. Anda akan diarahkan ke panel Buat Aturan Peringatan Berbasis Metrik. Atur kondisi peringatan dan ambang batas sesuai petunjuk, lalu klik OK.

   Gambar berikut menunjukkan contoh konfigurasi aturan peringatan. Dalam contoh ini, jika jumlah backlog pemanggilan asinkron untuk suatu fungsi lebih besar dari atau sama dengan 5, peringatan tingkat menengah dikirimkan 24/7 ke kontak yang ditentukan melalui DingTalk, email, telepon, dan webhook.

   

Orkestrasi tugas

Integrasikan dengan CloudFlow untuk menggunakan pemanggilan fungsi asinkron dalam alur kerja tugas kompleks berskala besar. Anda dapat menggunakan state seperti Pass, Map, dan Parallel untuk mengorkestrasikan tugas asinkron Function Compute. CloudFlow mengoordinasikan eksekusi secara andal sesuai langkah-langkah yang telah ditentukan, melacak transisi status setiap tugas, dan menerapkan logika retry Anda sesuai kebutuhan untuk memastikan alur kerja selesai dengan sukses. Untuk informasi selengkapnya, lihat Integrasi dengan Function Compute.

Prasyarat

• Buat tugas asinkron. Untuk informasi selengkapnya, lihat Manajemen tugas.

• Berikan akses CloudFlow ke Function Compute. Untuk informasi selengkapnya, lihat Gunakan role fungsi untuk memberikan izin Function Compute mengakses layanan cloud lainnya.

Prosedur

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

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

3. Pada kotak dialog Create Workflow, pilih metode dan mode pembuatan alur kerja.

   CloudFlow mendukung dua mode alur kerja: Standard dan Express. Untuk informasi selengkapnya tentang kedua mode tersebut, lihat Alur kerja Standard dan Express. Untuk informasi selengkapnya tentang pembuatan alur kerja, lihat Buat alur kerja dari kanvas kosong.

4. Edit alur kerja yang baru saja Anda buat.

   1. Definisikan alur.

      Anda dapat menggunakan editor CloudFlow Studio atau editor YAML. Contoh ini menggunakan editor YAML.

      Di pojok kanan atas halaman detail alur, klik YAML. Masukkan bahasa definisi alur di editor kode di sebelah kiri, lalu klik Save.

      Berikut adalah contohnya:

      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 eksekusi.

      Di pojok kanan atas halaman detail alur, klik Configure Workflow. Pilih Execution Role, lalu klik Save.

      Catatan

      Pastikan role yang Anda konfigurasikan untuk alur dilengkapi kebijakan AliyunFCInvocationAccess.

5. Pada halaman detail alur, Anda dapat mengklik Execute di pojok kanan atas untuk menguji alur kerja.