Function Compute：Pemanggilan Asinkron

Kasus penggunaan

Berikut adalah contoh kasus penggunaan umum untuk pemanggilan asinkron:

• Pengolahan audio dan video

  Function Compute dapat menangani file audio dan video secara efisien, di mana tugas seperti encoding, decoding, dan transkoding sering kali memakan waktu. Dengan memicu operasi ini secara asinkron, proses berlangsung di backend, memungkinkan antarmuka depan untuk terus berjalan tanpa penundaan — meningkatkan pengalaman pengguna. Selain itu, pemanggilan asinkron memungkinkan eksekusi bersamaan dari beberapa fungsi, mengurangi waktu pemrosesan keseluruhan. Sebagai contoh, proyek besar dapat dibagi menjadi beberapa subtugas untuk pemrosesan paralel, atau satu video dapat dikonversi ke berbagai format secara bersamaan.

• Pengolahan ETL data

  Selama operasi ekstrak, transformasi, dan muat (ETL), tugas seperti kueri database, I/O file, dan pembersihan data sering kali independen dan dapat dieksekusi secara paralel. Pemanggilan asinkron memungkinkan proses ini berjalan bersamaan, secara signifikan mengurangi waktu pemrosesan dan meningkatkan kinerja sistem. Untuk tugas yang lebih kompleks atau intensif sumber daya, seperti transformasi data skala besar, pemanggilan asinkron memastikan pemrosesan backend tanpa memblokir antarmuka depan, menghasilkan pengalaman pengguna yang lebih lancar.

• Pengembangan aplikasi web

  Function Compute terintegrasi dengan mulus dengan layanan cloud lainnya untuk membangun aplikasi web yang kuat. Pemanggilan asinkron membantu mencegah pembekuan halaman yang disebabkan oleh operasi backend yang panjang, seperti pengiriman formulir, kueri, atau pemuatan data besar. Ini memungkinkan pengguna untuk terus berinteraksi dengan komponen lain dari aplikasi tanpa gangguan. Dalam skenario dengan konkurensi tinggi — seperti ketika banyak pengguna mengakses aplikasi secara bersamaan — pemanggilan asinkron membantu mendistribusikan beban, melindungi layanan backend dari kelebihan beban.

Pemanggilan Tertunda

Dalam skenario tertentu, Anda mungkin memerlukan Function Compute untuk menunda eksekusi fungsi setelah mengirimkan permintaan pemanggilan asinkron. Untuk mencapai ini, Anda dapat menggunakan API atau SDK Function Compute untuk mengatur pemanggilan tertunda.

Cukup sertakan header permintaan HTTP x-fc-async-delay dalam kode permintaan Anda. Rentang valid untuk parameter ini adalah (0, 3600) detik. Function Compute akan memanggil fungsi setelah periode penundaan yang ditentukan telah berakhir.

Kebijakan Pengulangan

Penanganan kesalahan dan mekanisme pengulangan didukung dalam pemanggilan asinkron. Tugas dapat dijadwalkan ulang tanpa memengaruhi seluruh proses jika tugas gagal. Function Compute secara otomatis mengulang pemanggilan asinkron jika pemanggilan gagal.

Mekanisme Pengulangan

Tabel berikut menjelaskan mekanisme pengulangan default untuk kesalahan umum.

Konfigurasikan Kebijakan Pengulangan

Anda dapat menentukan jumlah maksimum pengulangan dan masa hidup maksimum (TTL) untuk pesan di Function Compute.

1. Masuk ke Konsol Function Compute. Di panel navigasi sisi kiri, klik Functions.

2. Di bilah navigasi atas, pilih wilayah. Di halaman Functions, klik fungsi yang ingin Anda kelola.

3. Di halaman Detail Fungsi, navigasikan ke tab Tasks. Di bagian Task Mode, klik Modify. Sesuaikan parameter berikut di panel Task Mode yang muncul, lalu klik Deploy untuk menyimpan perubahan Anda.

Callback Hasil

Setelah menerima permintaan pemanggilan asinkron, Function Compute menyimpan permintaan tersebut dan segera mengembalikan respons tanpa menunggu permintaan selesai. Jika Anda ingin menyimpan permintaan yang gagal dieksekusi setelah diulang untuk jumlah maksimum yang ditentukan atau jika Anda ingin memberi tahu aplikasi hilir tentang hasil pemanggilan asinkron, Anda dapat mengonfigurasi panggilan balik hasil. Setelah Anda mengonfigurasi layanan tujuan untuk pemanggilan asinkron, Function Compute secara otomatis memicu panggilan balik ke layanan yang sesuai berdasarkan hasil eksekusi.

Cara Kerjanya

Gambar berikut menunjukkan proses panggilan balik hasil.

Skenario

• Simpan acara yang dibuang untuk digunakan nanti

  Jika permintaan asinkron gagal dieksekusi setelah sistem mengulang permintaan berdasarkan kebijakan pengulangan, Function Compute membuang permintaan tersebut. Jika tujuan dikonfigurasi untuk pemanggilan yang gagal, Function Compute mendorong informasi konteks permintaan yang gagal ke layanan tujuan seperti ApsaraMQ for RocketMQ untuk pemrosesan selanjutnya. Anda juga dapat mengatur layanan tujuan ke fungsi lain. Function Compute secara otomatis mendorong informasi konteks permintaan yang gagal ke fungsi ini untuk mengeksekusi logika penanganan kesalahan kustom.

• Beritahukan layanan hilir tentang hasil eksekusi

  Anda dapat mengonfigurasi tujuan untuk pemanggilan yang berhasil. Setelah permintaan berhasil dieksekusi, Function Compute mendorong informasi konteks permintaan ke layanan tujuan hilir. Misalnya, jika Anda menggunakan Function Compute untuk secara otomatis mengekstrak file ZIP yang diunggah ke Object Storage Service (OSS), Anda dapat mengonfigurasi panggilan balik hasil untuk fungsi ekstraksi jika Anda ingin menerima notifikasi setelah ekstraksi.

Layanan Tujuan yang Didukung untuk Pemanggilan Asinkron

Perhatikan item berikut saat Anda mengonfigurasi layanan tujuan untuk pemanggilan asinkron:

• Konten acara yang dikirim ke tujuan untuk pemanggilan asinkron

  Kode sampel berikut memberikan contoh konten acara ketika tujuan untuk pemanggilan asinkron adalah Simple Message Queue (formerly MNS), Function Compute, atau ApsaraMQ for RocketMQ.

  {
    "timestamp": 1660120276975,
    "requestContext": {
      "requestId": "xxx",
      "functionArn": "acs:fc:{regionid}:{accountid}:functions/xxxx",
         "condition": "FunctionResourceExhausted", 
          "approximateInvokeCount": 3
    },
    "requestPayload": "",
    "responseContext": {
      "statusCode": 200,
      "functionError": ""
    },
    "responsePayload": ""
  }

  Tabel 1. Deskripsi Parameter

  Parameter	Deskripsi
  timestamp	Cap waktu pemanggilan.
  requestContext	Konteks permintaan.
  requestContext.requestId	ID permintaan pemanggilan asinkron.
  requestContext.functionArn	Nama Sumber Daya Alibaba Cloud (ARN) dari fungsi yang dipanggil secara asinkron.
  requestContext.condition	Kode kesalahan pemanggilan.
  requestContext.approximateInvokeCount	Jumlah kali eksekusi pemanggilan asinkron. Nilai lebih dari 1 menunjukkan bahwa Function Compute mengulang eksekusi tersebut.
  requestPayload	Muatan awal dari permintaan fungsi.
  responseContext	Konteks respons.
  responseContext.statusCode	Kode status sistem yang dikembalikan. Kode status selain 200 menunjukkan bahwa terjadi kesalahan sistem.
  responseContext.functionError	Pesan kesalahan pemanggilan.
  responsePayload	Muatan awal yang dikembalikan setelah fungsi dieksekusi.

  Kode sampel berikut memberikan contoh konten acara ketika tujuan untuk pemanggilan asinkron adalah EventBridge. Untuk informasi lebih lanjut, lihat Ikhtisar.

  {
      "datacontenttype": "application/json",
      "aliyunaccountid": "143xxxx",
      "data": {
          "requestContext": {
              "condition": "",
              "approximateInvokeCount": 1,
              "requestId": "0fcb7f0c-xxxx",
              "functionArn": "acs:fc:{regionid}:{accountid}:functions/xxxx"
          },
          "requestPayload": "",
          "responsePayload": "",
          "responseContext": {
              "functionError": "",
              "statusCode": 200
          },
          "timestamp": 1660120276975
      },
      "subject": "acs:fc:{regionid}:{accountid}:functions/xxxx",
      "source": "acs:fc",
      "type": "fc:AsyncInvoke:succeeded",
      "aliyunpublishtime": "2021-01-03T09:44:31.233Asia/Shanghai",
      "specversion": "1.0",
      "aliyuneventbusname": "xxxxxxx",
      "id": "ecc4865xxxxxx",
      "time": "2021-01-03T01:44:31Z",
      "aliyunregionid": "cn-shanghai-vpc",
      "aliyunpublishaddr": "199.99.xxx.xxx"
  }

• Batas Muatan

  Item berikut mencantumkan batas ukuran muatan untuk layanan tujuan yang berbeda:

  • Simple Message Queue (formerly MNS): 64 KB

  • Function Compute: Batas Sumber Daya Waktu Proses Fungsi

  • EventBridge: 64 KB

  • ApsaraMQ for RocketMQ: 4 MB

• Penghindaran Loop

  Saat Anda mengonfigurasi tujuan untuk pemanggilan asinkron, pastikan bahwa pemanggilan loop tidak terjadi. Sebagai contoh, sebuah loop terjadi jika Anda mengonfigurasi Fungsi B sebagai tujuan untuk pemanggilan asinkron yang berhasil dari Fungsi A dan mengonfigurasi Fungsi A sebagai tujuan untuk pemanggilan asinkron yang berhasil dari Fungsi B. Pemanggilan asinkron dan eksekusi Fungsi A dapat memulai loop tak terbatas di mana Fungsi A dan Fungsi B terus-menerus saling memanggil.

Tanya Jawab Umum

Bagaimana cara saya memicu pemanggilan asinkron suatu fungsi?

Anda dapat menggunakan salah satu metode berikut untuk memanggil fungsi Function Compute secara asinkron:

• Masuk ke Konsol Function Compute, temukan fungsi yang diinginkan dan pilih Invoke the function in asynchronous mode di tab Tests.

  

• Panggil operasi InvokeFunction dan atur nilai parameter x-fc-invocation-type ke Async.

• Gunakan Serverless Devs untuk mengonfigurasi pemanggilan asinkron. Atur nilai parameter invocation-type ke Async. Untuk informasi lebih lanjut, lihat Panggil fungsi.

• Buat pemicu yang mendukung pemanggilan asinkron. Untuk informasi lebih lanjut, lihat Picu tugas menggunakan acara.

• Picu melalui HTTP atau domain kustom. Dalam hal ini, atur header permintaan X-Fc-Invocation-Type ke Async. Sebagai contoh:

  curl -v -H "X-Fc-Invocation-Type: Async" https://example.cn-shenzhen.fcapp.run/$path

Apa yang Harus Dilakukan Selanjutnya

Jika Anda ingin mendapatkan informasi status setiap fase dari permintaan asinkron, Anda dapat mengaktifkan mode tugas. Untuk informasi lebih lanjut, lihat Tugas Asinkron.