配置MNS無效信件佇列處理非同步任務執行失敗-Function Compute-阿里雲

非同步任務可以即時感知業務狀態、控制執行函數，讓您對一些異常情況進行更好的處理，例如警示通知、自動化重試等情況。本文介紹Function Compute非同步任務的最佳實務。

背景資訊

FaaS早期主要支援無狀態、短時和輕量級的計算能力，例如API後端、圖片處理和資料流式處理等。在各類情境中，對於FaaS函數的調用方式可分為非同步呼叫和同步調用。同步調用和非同步呼叫存在的差異是同步調用會立即執行函數，而非同步呼叫則會立刻返回調用方202 HttpCode，並將非同步呼叫訊息入隊，由後端服務排隊處理。

使用情境

隨著業務的發展，一些線上直播情境的使用者在慢慢遷移至FaaS內，這類業務情境通常具有執行時間長、對延時敏感和可用性要求高等特徵，開發人員需即時感知業務狀態和控制函數的執行。由於非同步呼叫對延時不敏感，同步調用長連結的穩定性比較差，並且佔用用戶端資源，所以既無法使用非同步呼叫也無法使用同步調用。但由於非同步呼叫在大量突增流量的離線業務下，具有削峰填穀的特點，可以平滑緩衝對業務下遊系統的衝擊，所以Function Compute對非同步呼叫進行相關拓展，引入非同步任務。非同步任務主要適用於以下業務情境：

對執行具有可觀測性
- 在執行過程中您可以即時查看執行的狀態，例如是否已出隊、是否已觸發函數執行和執行結果是否已正常發送到Destination目標。
- 業務具有明顯的任務屬性，如下所示：
  - 可以查看某個執行的觸發事件和即時的執行日誌。
  - 可以根據執行的名稱、執行的時間或執行的狀態等過濾查詢記錄。
對執行具有可操作性
業務具有明顯的任務屬性，如下所示：
- 當執行時間較長時，在某些情況下可以手動停止執行函數。
- 可以重新執行歷史失敗或成功的執行。

關於非同步任務的詳細資料，請參見功能概覽。

樣本

本文以非同步呼叫目標輕量訊息佇列（原 MNS）為例，介紹如何結合使用Serverless Devs和Function Compute控制台實現非同步呼叫。

您可以通過非同步任務實現以下效果：

函數開始非同步執行後，您可以通過Function Compute控制台、SDK或API查看操作執行。
當函數執行失敗或手動停止後，Function Compute系統會將非同步訊息推送至輕量訊息佇列（原 MNS）的隊列中實現無效信件佇列的功能，方便您感知非同步函數執行失敗的訊息並進行後續處理。

前提條件

安裝Serverless Devs工具及依賴
配置Serverless Devs
建立Simple Message Queue (formerly MNS)隊列。詳細資料，請參見建立隊列。

建立RAM角色，並授予以下權限原則，您也可以直接使用AliyunFCDefaultRolePolicy策略。關於權限原則的詳細資料，請參見建立RAM角色。

{
    "Version": "1",
    "Statement": [
        {
            "Action": [
                "fc:InvokeFunction",
                "mns:SendMessage",
                "mns:PublishMessage",
                "log:*"
            ],
            "Resource": "*",
            "Effect": "Allow"
        }
    ]
}

操作步驟

執行以下命令，複製專案工程。

git clone https://github.com/awesome-fc/Stateful-Async-Invocation.git

執行以下命令，進入專案目錄。
```
cd Stateful-Async-Invocation
```
修改s.yaml檔案。
修改第一個{please_replace_me}為您的阿里雲帳號ID，修改後兩個{please_replace_me}的值為您配置的非同步呼叫目標輕量訊息佇列（原 MNS）的隊列名稱。
在目標目錄中執行以下命令部署函數。
```
s deploy -y
```
部署成功後，您可以登入Function Compute控制台，查看是否成功建立服務和函數並為該函數開啟非同步任務功能。

更多資訊

非同步配置僅在非同步呼叫時才會成功生效。您可以通過SDK或CLI工具發送非同步呼叫請求。
本樣本中您可以在樣本工程的目標目錄中執行以下命令發送非同步觸發請求，並查看Simple Message Queue (formerly MNS)。
```
s invoke --invocation-type async -e '{"failure":true}'
```
您可以在Function Compute控制台查看、操作非同步呼叫。更多資訊，請參見任務管理。
說明
如果您需要查看詳細資料例如函數日誌，您需要為函數配置Log Service。詳細資料，請參見配置日誌。

當函數執行完成後，如已配置了Destination目標，則可前往目標查看推送記錄。

本文樣本中，如果配置了Destination目標，您可以在輕量訊息佇列（原 MNS）控制台接收Destination推送的資訊，如下所示。

{
  "timestamp":xxxx,
  "requestContext":{
    "requestId":"xxxx",
    "functionArn":"acs:fc:::services/Stateful-Invocation-demo.LATEST/functions/main",
    "condition":"UnhandledInvocationError",
    "approximateInvokeCount":1
  },
  "requestPayload":"{\"failure\":true}",
  "responseContext":{
    "statusCode":200,
    "functionError":"UnhandledInvocationError"
  },
  "responsePayload":"{\"errorMessage\":\"Process exited unexpectedly before completing request (duration: 13689ms, maxMemoryUsage: 10.86MB)\"}"
}

說明

當非同步呼叫失敗或手動終止後，您可以在輕量訊息佇列（原 MNS）中接收到非同步呼叫時間的詳細錯誤資訊。