CloudFlow：Integrasi Serverless Workflow dengan pemanggilan fungsi Function Compute secara asinkron

Langkah-langkah berikut harus dilakukan:

• Opsional: Aktifkan pemanggilan asinkron. Untuk informasi lebih lanjut, lihat Ikhtisar.

  Setelah mengaktifkan pemanggilan asinkron stateful, Anda dapat menghentikan instance fungsi saat tugas sedang dieksekusi, memberikan pandangan yang lebih rinci terhadap alur kerja.

• Berikan izin Function Compute untuk mengakses Serverless Workflow. Ini memastikan bahwa Serverless Workflow dapat dipanggil kembali untuk mengeksekusi langkah-langkah berikutnya setelah eksekusi fungsi asinkron selesai. Berikut adalah contoh konfigurasi kebijakan izin:

  {
      "Statement": [
          {
              "Effect": "Allow",
              "Action": [
                  "fnf:ReportTaskSucceeded",
                  "fnf:ReportTaskFailed"
              ],
              "Resource": [
                  "*"
              ]
          }
      ],
      "Version": "1"
  }

  Untuk detail lebih lanjut tentang otorisasi, lihat Berikan izin Function Compute untuk mengakses layanan Alibaba Cloud lainnya.

Secara default, Serverless Workflow menggunakan pola sinkron ketika Serverless Workflow mengatur tugas Function Compute untuk mengimplementasikan alur tugas. Dalam pola sinkron, Serverless Workflow tidak melanjutkan ke langkah berikutnya sampai alur kerja menerima hasil eksekusi fungsi sebelumnya. Cuplikan berikut menunjukkan alur yang menggunakan pola sinkron.

version: v1
type: flow
steps:
  - type: task
    name: mytask
    resourceArn: acs:fc:{region}:{account}:services/{serviceName}.{qualifier}/functions/{functionName}

Masalah berikut dapat terjadi saat menggunakan pola sinkron untuk pemanggilan fungsi:

• Pembatasan laju dapat terjadi akibat batasan sumber daya pada pemanggilan fungsi Function Compute. Secara default, maksimum 300 instance bayar sesuai penggunaan diperbolehkan dalam satu wilayah untuk akun Alibaba Cloud Function Compute.

  Saat menggunakan Serverless Workflow untuk memanggil fungsi, pemanggilan tersebut berbagi kuota yang sama dengan pemanggilan fungsi dari layanan lain. Hal ini dapat menyebabkan kesalahan pembatasan laju. Dalam kasus ini, Anda perlu mendefinisikan kebijakan percobaan ulang yang kompleks dalam alur Serverless Workflow, namun hal ini tidak menjamin keberhasilan eksekusi alur.

• Jika tugas memerlukan waktu lama untuk dieksekusi, koneksi persisten harus dibuat antara Serverless Workflow dan Function Compute. Kondisi jaringan yang tidak stabil dapat menyebabkan kesalahan tak terduga.

Serverless Workflow memungkinkan Anda menggabungkan fitur pemanggilan fungsi asinkron dengan berbagai pola integrasi untuk mengatasi masalah di atas, sekaligus memenuhi persyaratan berikut:

• Dalam beberapa skenario, sistem perlu melanjutkan ke langkah berikut tanpa menunggu penyelesaian eksekusi langkah saat ini.

• Jika kesalahan tak terduga terjadi selama eksekusi alur, sistem perlu melewati langkah saat ini dan melanjutkan ke langkah berikutnya.

Dalam skenario yang berbeda, Serverless Workflow menggunakan pola permintaan-respon (requestResponse), pola sinkron (sync), atau pola tunggu-balasan (waitForCallback) untuk memanggil fungsi Function Compute secara asinkron.

- type: task
    ...
    pattern: requestResponse 
    serviceParams:
        InvocationType: Async

- type: task
    ...
    pattern: sync 
    serviceParams:
        InvocationType: Async

- type: task
    ...
    pattern: waitForCallback
    serviceParams:
        InvocationType: Async

Dalam contoh-contoh berikut, Serverless Workflow menggunakan Function Compute sebagai node tugas, menggunakan resourceArn untuk menentukan Function Compute sebagai layanan tujuan, dan menggunakan serviceParams untuk menentukan parameter yang digunakan untuk memanggil fungsi Function Compute. serviceParams mendukung parameter berikut:

• InvocationType: jenis pemanggilan fungsi. Nilai valid adalah Sync dan Async. Sync menunjukkan pemanggilan sinkron, sedangkan Async menunjukkan pemanggilan asinkron.

• Opsional: StatefulAsyncInvocationID: ID pemanggilan asinkron stateful. Parameter ini dapat digunakan untuk mencari nama tugas tujuan di konsol Function Compute.

  Catatan

  Jika Anda mengatur InvocationType ke Async dan menentukan nilai untuk StatefulAsyncInvocationID, pola pemanggilan fungsi Serverless Workflow adalah pemanggilan asinkron stateful. Nilai parameter StatefulAsyncInvocationID harus unik untuk semua fungsi.

Saat alur mencapai langkah yang ditentukan, Serverless Workflow memanggil fungsi yang ditentukan secara asinkron dan mengeksekusinya. Kemudian, alur melanjutkan ke langkah berikutnya tanpa menunggu panggilan balik atau penyelesaian eksekusi langkah sebelumnya.

version: v1
type: flow
steps:
  - type: task
    name: mytask
    resourceArn: acs:fc:{region}:{account}:services/{serviceName}.{qualifier}/functions/{functionName}
    pattern: requestResponse  # Pemanggilan asinkron dengan pola sinkron
    serviceParams:
        InvocationType: Async

Serverless Workflow menggabungkan fitur pemanggilan fungsi asinkron dan fitur pemanggilan asinkron stateful untuk mendukung skenario tipe pekerjaan. Saat mengaktifkan fitur pemanggilan asinkron stateful dan menggunakan pola pemanggilan asinkron, Anda dapat melihat status eksekusi fungsi dan menghentikan eksekusi fungsi saat atau setelah fungsi dipanggil. Hal ini membuat alur lebih mudah diamati dan dioperasikan. Berikut adalah cuplikan bahasa definisi alur (FDL) Serverless Workflow:

version: v1
type: flow
steps:
  - type: task
    name: mytask
    resourceArn: acs:fc:::services/{serviceName}.{qualifier}/functions/{functionName}
    pattern: sync  # Pemanggilan asinkron dengan pola sinkron
    inputMappings:
      - target: id
        source: $context.execution.name
    serviceParams:
        InvocationType: Async
        StatefulAsyncInvocationID: $.id