Function Compute：非同步呼叫

應用情境

非同步呼叫適用的情境樣本如下：

• 音視頻處理

  使用者使用Function Compute處理音視頻業務時，涉及處理編碼、解碼或轉碼等耗時較長的任務，非同步呼叫這些任務使其在後台運行，前端無需等待，提升使用者體驗。另外，如果音視頻專案較大，需要將其分割成多個任務平行處理或者需要將一個視頻轉換為多種格式，非同步呼叫多個函數可以輕鬆實現以上平行處理需求，縮短任務處理時間。

• 資料ETL處理

  ETL流程中，從源頭提取資料、轉換處理和載入到目標系統這三個步驟可能涉及多個獨立的操作，例如資料庫查詢、檔案讀寫或資料清洗等，採用非同步呼叫可以讓這些操作並存執行，減少處理時間，提升系統效能。而針對耗時較長的任務，例如處理大規模資料集或複雜的資料轉換，非同步呼叫允許這些任務在後台運行，前端無需等待，提升使用者體驗。

• 開發Web應用

  Function Compute可以搭配其他雲產品快速構建Web應用。使用者在表單提交、搜尋查詢或載入內容較多的情況下，採用非同步呼叫可以避免頁面因長時間等待後端響應而出現的卡頓現象，此時使用者可以繼續與頁面的其他部分互動，而不會感受到延遲。高並發情境下，例如大量使用者同時訪問，非同步呼叫函數又可以分散請求壓力，防止服務過載。

延遲調用

針對某些情境，您提交一次非同步呼叫後，需要Function Compute對其進行延遲觸發。您可以通過調用API（SDK）實現延遲調用函數。

在代碼中添加HTTP要求標頭x-fc-async-delay，取值範圍為(0,3600)，單位為秒。Function Compute將從您觸發執行開始計算，延遲x-fc-async-delay設定的時間後觸發函數調用。

重試策略

非同步呼叫機制提供錯誤處理和重試機制，如果某個步驟失敗，可以重新調度該任務而不影響整個流程。當函數非同步呼叫執行失敗後，Function Compute會自動進行錯誤重試。

重試機制

對於常見錯誤，系統預設的重試策略如下表所示。

配置重試策略

Function Compute支援自訂重試次數和訊息最大存活時間長度。

1. 登入Function Compute控制台，在左側導覽列，單擊函數。

2. 在頂部功能表列，選擇地區，然後在函數頁面，單擊目標函數。

3. 在函數詳情頁面，選擇配置頁簽，然後在左側導覽列，選擇非同步配置，在非同步配置地區，單擊編輯。

4. 在非同步配置面板，設定以下配置項，然後單擊部署。

   配置項	解釋說明
   任務模式	是否開啟非同步任務模式，請參見非同步任務。
   最大重試次數	用於配置非同步呼叫流程中的訊息最大重試次數，取值範圍為[0,8]。 Function Compute在預設情況下，對非同步觸發失敗的訊息進行3次重試，您可以根據業務需求減少或增加對非同步呼叫的重試。
   訊息最大存活時間長度	用於配置非同步呼叫流程中的訊息最大存活時間長度，取值範圍[1,604800]，預設為86400，單位為秒。 該時間長度從觸發非同步呼叫時開始計算，如果超過配置的訊息最大存活時間長度，該條訊息將被丟棄。未被消費的訊息將計入CloudMonitor非同步呼叫觸發事件（次）指標。關於指標詳情，請參見監控指標。

結果回調

Function Compute接收非同步呼叫請求後，將請求持久化後會立即返迴響應，無需等待請求執行完成。如您需要保留執行失敗且超過最大重試次數被丟棄的請求，或通知下遊非同步呼叫結果，可以通過配置結果回調功能實現。配置非同步目標服務後，非同步呼叫請求執行完成，Function Compute根據執行結果自動回調對應的服務。

功能原理

結果回調流程如下圖所示。

適用情境

• 儲存丟棄的事件供後續使用

  當非同步請求執行失敗，並且按照指定的策略重試後仍然失敗，Function Compute將丟棄該請求。如果您配置了失敗目標，Function Compute將自動把失敗請求的上下文資訊推送到訊息佇列 RocketMQ 版等Message Service中，以便後續處理。您也可以將目標服務設定為另一個函數，Function Compute將自動把失敗請求的上下文資訊推送到該函數，執行您自訂的錯誤處理邏輯。

• 自動通知下遊服務執行結果

  請求執行成功後，如果您配置了成功目標，Function Compute系統會自動將成功請求的上下文資訊推送到下遊目標服務。例如，您配置了使用Function Compute實現自動解壓上傳到OSS的ZIP檔案，解壓完成後想要接收訊息通知，可採用為目標函數配置非同步呼叫結果回調目標服務。

支援的非同步呼叫目標服務

非同步呼叫目標服務的配置說明如下：

• 非同步呼叫目標的事件內容

  Simple Message Queue (formerly MNS)、Function Compute或訊息佇列 RocketMQ 版作為函數非同步呼叫目標時，事件內容樣本如下。

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

  表 1. 參數說明

  參數	說明
  timestamp	調用時間戳記。
  requestContext	請求上下文。
  requestContext.requestId	非同步呼叫的請求ID。
  requestContext.functionArn	非同步執行的函數ARN。
  requestContext.condition	調用錯誤碼。
  requestContext.approximateInvokeCount	非同步呼叫的執行次數。當該值大於1時，說明Function Compute對您的函數進行了重試。
  requestPayload	請求函數的原始負載。
  responseContext	返回上下文。
  responseContext.statusCode	調用函數的返回碼（系統）。當該返回碼不為200時，說明出現了系統錯誤。
  responseContext.functionError	調用錯誤資訊。
  responsePayload	執行函數返回的原始負載。

  事件匯流排 EventBridge作為函數非同步呼叫目標時，事件樣本如下。具體資訊，請參見事件概述。

  {
      "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"
  }

• 負載限制

  支援的非同步呼叫目標服務負載的最大限制如下：

  • Simple Message Queue (formerly MNS)：64 KB

  • Function Compute：128 KB

  • 事件匯流排 EventBridge：64 KB

  • 訊息佇列 RocketMQ 版：4 MB

• 避免迴圈調用

  當您在配置非同步執行目標時，請確保不要出現迴圈調用的情況。例如，您為函數A配置了成功調用時的非同步目標為函數B，為函數B配置了成功調用時的非同步目標為函數A。當您非同步觸發函數A並且執行成功後，則可能出現A到B，再到A的迴圈調用的情況。

常見問題

如何觸發函數的非同步呼叫？

您可以通過以下方式對Function Compute的函數發起一次非同步呼叫。

• 登入Function Compute控制台，找到目標函數，然後在測試頁簽，勾選我想通過非同步方式進行調用。

  

• 調用InvokeFunction - 調用函數介面，設定參數x-fc-invocation-type的值為Async。

• 使用Serverless Devs工具配置非同步呼叫，設定參數invocation-type的值為Async，詳情請參見調用函數。

• 建立支援非同步呼叫的觸發器非同步觸發函數，詳情請參見事件觸發。

後續操作

如果您希望獲得函數非同步請求各個階段的狀態，可通過開啟任務模式來實現，具體資訊，請參見非同步任務。