Function Compute:非同期タスク

制限事項

• ユースケースにおける制限

  非同期タスクは機能が豊富ですが、システムオーバーヘッドも発生します。以下のシナリオでは、タスクモードを無効化することを推奨します。

  • アプリケーションがエンドツーエンドのリクエストレイテンシーに極めて敏感であり、平均レイテンシーが 100 ms 未満である必要があります。

  • 1 秒あたり数千 RPS（Requests Per Second）以上の頻度で非同期呼び出しを行う必要があります。

• リージョンにおける制限

  非同期タスクは、以下のリージョンでサポートされています：中国 (杭州)、中国 (上海)、中国 (青島)、中国 (北京)、中国 (張家口)、中国 (ウランチャブ)、中国 (深セン)、中国 (成都)、中国 (香港)、シンガポール、イギリス (ロンドン)、米国 (シリコンバレー)、米国 (バージニア)、ドイツ (フランクフルト)、マレーシア (クアラルンプール)、インドネシア (ジャカルタ)、タイ (バンコク)、日本 (東京)、韓国 (ソウル)。

• 保持期間

  過去 7 日間に作成されたタスクのステータスを照会できます。

Kubernetes ジョブとの比較

非同期タスクを実行するには、Function Compute の非同期タスク機能または Kubernetes ジョブを使用できます。Function Compute は、非同期タスクを実行するための即時利用可能なサーバーレス プラットフォームを提供しており、より効率的で、制御可能、かつ可観測性が高いです。以下の表では、この 2 つの方法を比較しています。

タスク管理

非同期タスクのステータス

各タスクの呼び出しについて、Function Compute は状態遷移を記録し、リアルタイムのステータス照会を可能にします。SDK または Function Compute コンソール を使用して、タスクの特定のステータスを表示できます。タスクは、以下のステータスのいずれかになります：

タスク実行の詳細を取得するには、GetAsyncTask API オペレーションを呼び出します。また、ステータスでタスクをフィルターするには、ListAsyncTasks API オペレーションを呼び出します。

タスクの管理

{
  "asyncTask": true
}

イベントトリガー

非同期タスクは、非同期呼び出しをサポートするトリガーを作成することで起動できます。以下のトリガーがこの機能をサポートしています。

• HTTP トリガー

• タイムトリガー

• OSS トリガー

• MNS トピックトリガー

• EventBridge と統合されたトリガーには、以下が含まれます。

  • MNS キュー トリガー

  • RocketMQ トリガー

  • RabbitMQ トリガー

  • Kafka トリガー

  • MQTT トリガー

  • DTS トリガー

  重要

  HTTP トリガーおよび EventBridge と統合されたトリガーの呼び出しメソッドが非同期呼び出しに設定されていることを確認してください。

タスクの重複排除

重複実行を防ぐために、Function Compute では、各タスクにグローバルに一意な ID を割り当てることができます。たとえばタイムアウトなどの理由でタスクの送信が失敗した場合でも、同じタスク ID を使用してリクエストを安全にリトライできます。リトライ動作の詳細については、「リトライポリシー」をご参照ください。

Function Compute は、重複排除のためにグローバルに一意の TaskID を使用します。すべてのタスク送信で TaskID を指定し、タイムアウトやその他の障害が発生した場合の再試行に使用することを推奨します。Function Compute は、重複した TaskID を含む後続の送信を 409 エラーで拒否します。

TaskID の設定

タスクは、Function Computeコンソール、Serverless Devs、または API オペレーションを呼び出すことで送信できます。TaskID を設定するには、呼び出しリクエストに x-fc-async-task-id ヘッダーを指定します。

タスクをトリガーする際に TaskID を設定するサンプルコードについては、「」「サンプルコード（国際サイト）」をご参照ください。

タスクのモニタリング

Function Compute の監視メトリクスを使用すると、非同期タスクのステータスをリアルタイムで取得し、エラー、タイムアウト、その他の例外を速やかに検出できます。

前提条件

関数が作成されました。詳細については、「関数の作成」をご参照ください。

操作手順

1. まず、Function Compute コンソールにログインします。左側のナビゲーションウィンドウで、関数管理 > 関数 を選択します。

2. 上部のナビゲーションバーでリージョンを選択します。関数 ページで、対象の関数をクリックします。

3. 関数の詳細ページで、モニタリング タブをクリックし、非同期呼び出しおよび非同期タスクインスタンスのリソース使用量に関連するメトリクスを確認します。監視メトリクスの詳細については、「監視メトリクス」をご参照ください。

   • 関数のメトリクス タブをクリックして、非同期呼び出しに関連するメトリクス（例：非同期呼び出しの処理事例、非同期呼び出し処理の遅延 (ミリ秒)、非同期呼び出しトリガーイベント、非同期リクエストのバックログ）を確認します。

   • インスタンスのメトリクス タブをクリックして、非同期タスクのインスタンスレベルのリソース使用量を確認します。

     説明

     インスタンスレベルのメトリクスを確認するには、まずログ機能を有効化する必要があります。詳細については、「ログの構成」をご参照ください。

4. メトリクスに対するアラートルールを設定します。

   メモリ使用量や vCPU 使用量などのメトリクスをモニタリングするには、メトリクスチャートの右上隅にあるベルアイコン をクリックします。これにより、「メトリクスベースのアラートルールの作成」パネルにリダイレクトされます。指示に従ってアラート条件およびしきい値を設定し、OK をクリックします。

   以下の図は、アラートルールの設定例を示しています。この例では、ある関数のバックログ中の非同期呼び出し件数が 5 以上になると、DingTalk、メール、電話、Webhook を通じて、指定された連絡先に 24 時間年中無休で中程度の重要度のアラートが送信されます。

   

タスクのオーケストレーション

CloudFlow と統合して、大規模で複雑なタスクワークフローで非同期関数呼び出しを使用できます。Pass、Map、Parallel などのステートを使用して、Function Compute 非同期タスクをオーケストレーションできます。CloudFlow は、事前定義されたステップに従って実行を確実に調整し、各タスクの状態遷移を追跡し、必要に応じてリトライロジックを適用して、ワークフローが正常に完了することを保証します。詳細については、「Function Compute との統合」をご参照ください。

前提条件

• 非同期タスクを作成します。詳細については、「タスク管理」をご参照ください。

• CloudFlow が Function Compute にアクセスできる権限を付与します。 詳細については、「関数ロールを用いた、Function Compute による他クラウドサービスへのアクセス権限の付与」をご参照ください。

操作手順

1. CloudFlow コンソール にログインします。上部のナビゲーションバーでリージョンを選択します。

2. 左側のナビゲーションウィンドウで、ワークフロー をクリックします。ワークフロー ページで、ワークフローの作成 をクリックします。

3. ワークフローの作成 ダイアログボックスで、ワークフローの作成方法およびモードを選択します。

   CloudFlow では、標準（Standard）および高速（Express）の 2 種類のワークフローモードをサポートしています。各モードの詳細については、「標準ワークフローと高速ワークフロー」をご参照ください。ワークフローの作成方法については、「空白キャンバスからのワークフロー作成」をご参照ください。

4. 先ほど作成したワークフローを編集します。

   1. フローを定義します。

      CloudFlow Studio エディターまたは YAML エディターのいずれかを使用できます。本例では YAML エディターを使用します。

      フロー詳細ページの右上隅にある YAML をクリックします。左側のコードエディターにフロー定義言語を入力し、保存 をクリックします。

      以下に例を示します。

      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. 実行ロールを構成します。

      フロー詳細ページの右上隅にある ワークフローの設定 をクリックします。実行ロール を選択し、保存 をクリックします。

      説明

      ワークフローに構成するロールには、AliyunFCInvocationAccess ポリシーがアタッチされていることを確認してください。

5. フロー詳細ページで、右上隅の 実行する をクリックして、ワークフローのテストを行います。