CloudFlow:エラー処理

概要

CloudFlow のワークフロー統合中に、予期されたエラーまたは予期しないエラーが発生する可能性があります。この場合、現在の状態の操作を続行するか、次の状態に遷移できます。FnF.ALL キーワードは、すべてのエラーをキャッチする特別なオプションです。再試行ポリシーとキャッチポリシーを使用してエラーを処理できます。詳細については、「再試行」と「キャッチ」をご参照ください。

エラー処理をサポートする状態

以下の状態の定義で [再試行] フィールドと [キャッチ] フィールドを使用して、再試行ポリシーとキャッチポリシーを指定し、状態のエラーを処理できます。

• タスク

• 並列

• マップ

再試行

キャッチ

OutputConstructor パラメーターは、Next パラメーターと一緒に使用されます。状態にエラーが発生した場合、その状態では予期される出力は生成されません。ワークフローが次の状態に遷移しても、ワークフローは続行できません。この場合、OutputConstructor パラメーターを使用して出力を構築し、その出力をワークフローが遷移する次の状態への入力として使用できます。

一般的なエラータイプ

CloudFlow が Function Compute と統合されている場合、以下の一般的なエラータイプが発生します。CloudFlow が他のクラウドサービスと統合されている場合に発生するエラータイプの詳細については、対応するサービス統合ドキュメントをご参照ください。

一般的なエラー処理の例

• 基本的な再試行

• バックオフ再試行

• 複雑な再試行ポリシー

基本的な再試行

この例では、my-error-handle-example という名前のサービス統合呼び出し中にエラーが発生し、MyCustomException1 再試行ポリシーにヒットした場合、システムは再試行ポリシーに基づいて最大 3 回の再試行を試みます。3 回の再試行がすべて失敗した後、現在のエラーは MyCustomException1 キャッチポリシーにヒットします。システムは、OutputConstructor パラメーターを使用してカスタムエラー出力を構築し、カスタムエラー出力を ErrorCatchExit 状態への入力として使用します。次に、ワークフローは ErrorCatchExit 状態に遷移します。

Type: StateMachine
Name: ErrorHandleExample
SpecVersion: v1
Description: 基本的なエラー処理の例
StartAt: my-error-handle-example
States:
  - Type: Task
    Name: my-error-handle-example
    Action: FC:InvokeFunction
    TaskMode: RequestComplete
    Parameters:
      resourceArn: acs:fc:{regionId}:{accountId}:functions/myfunction/LATEST
      invocationType: Sync
      body: |  // 複数行の文字列
        xxx
    Retry: // 再試行ポリシー
      - Errors:
          - MyCustomException1
        Description: 再試行ポリシー 1
        MaxAttempts: 3
        IntervalSeconds: 2
    Catch: // キャッチポリシー
      - Errors:
          - MyCustomException1
        Description: キャッチポリシー 1
        OutputConstructor:
          ErrorCode: MyCustomException1
          ErrorMessage: MyCustomException1
        Next: ErrorCatchExit
    Next: SucceededExit
  - Type: Pass
    Name: ErrorCatchExit
    End: true
  - Type: Pass
    Name: SucceededExit
    End: true

YAML 設定ファイルを保存する前に、resourceArn の有効性を確認する必要があります。resourceArn:acs:fc:{regionId}:{accountId}:functions/myfunction/LATEST の resourceArn を実際の関数 ARN に置き換えてください。関数の ARN を取得する方法の詳細については、「関数の ARN を取得する」をご参照ください。

• regionId: 関数が存在するリージョンの ID（cn-beijing、cn-hangzhou など）。

• accountId: Alibaba Cloud アカウントの ID。

• myfunction: 関数の名前。

• LATEST: 関数のバージョン。ビジネス要件に基づいて、LATEST を特定のバージョンまたはエイリアスに置き換えることができます。

MyCustomException 1: ビジネス要件に基づいてエラーメッセージを変更できます。

バックオフ再試行

この例では、my-error-handle-example という名前のサービス統合呼び出し中にエラーが発生し、MyCustomException2 または MyCustomException3 再試行ポリシーにヒットした場合、システムは再試行ポリシーに基づいて最大 3 回の再試行を試みます。最初の再試行間隔は 5 秒です。システムは、バックオフ率 2.0 に基づいて、5 秒、10 秒、20 秒、40 秒の間隔で再試行を試みます。3 回の再試行がすべて失敗した後、現在のエラーは MyCustomException2 または MyCustomException3 キャッチポリシーにヒットします。システムは、OutputConstructor パラメーターを使用してカスタムエラー出力を構築し、カスタムエラー出力を ErrorCatchExit 状態への入力として使用します。次に、ワークフローは ErrorCatchExit 状態に遷移します。

Type: StateMachine
Name: ErrorHandleExample
SpecVersion: v1
Description: バックオフエラー処理の例
StartAt: my-error-handle-example
States:
  - Type: Task
    Name: my-error-handle-example
    Action: FC:InvokeFunction
    TaskMode: RequestComplete
    Parameters:
      resourceArn: acs:fc:{regionId}:{accountId}:functions/myfunction/LATEST
      body: xxx
    Retry: // 再試行ポリシー
      - Errors:
          - MyCustomException2
          - MyCustomException3
        Description: 再試行ポリシー 2
        MaxAttempts: 3
        IntervalSeconds: 5
        BackoffRate: 2.0
    Catch: // キャッチポリシー
      - Errors:
          - MyCustomException2
          - MyCustomException3
        Description: キャッチポリシー 2
        Next: ErrorCatchExit
    Next: SucceededExit
  - Type: Pass
    Name: ErrorCatchExit
    End: true
  - Type: Pass
    Name: SucceededExit
    End: true

複雑な再試行ポリシー

この例では、FnF.ALL エラータイプに再試行ポリシーとキャッチポリシーが指定されています。my-error-handle-example という名前のサービス統合呼び出し中に、MyCustomException1、MyCustomException2、MyCustomException3 以外のエラーが発生した場合、システムは再試行ポリシーに基づいて最大 3 回の再試行を試みます。最初の再試行間隔は 5 秒です。バックオフ率 2.0 に基づく最後のバックオフ間隔は 40 秒です。ただし、最大バックオフ間隔は 30 秒に設定されています。システムは、5 秒、10 秒、20 秒、30 秒の間隔で再試行を試みます。3 回の再試行がすべて失敗した後、現在のエラーは FnF.ALL キャッチポリシーにヒットします。OutputConstructor パラメーターを使用してカスタムエラー出力は構築されません。デフォルトでは、ワークフローは ErrorCatchExit 状態に遷移します。

Type: StateMachine
Name: ErrorHandleExample
SpecVersion: v1
Description: エラー処理の例
StartAt: my-error-handle-example
States:
  - Type: Task
    Name: my-error-handle-example
    Action: FC:InvokeFunction
    TaskMode: RequestComplete
    Parameters:
      resourceArn: acs:fc:{regionId}:{accountId}:functions/myfunction/LATEST
      body: xxx
    Retry: // 再試行ポリシー
      - Errors:
          - MyCustomException1
        Description: 再試行ポリシー 1
        MaxAttempts: 3
        IntervalSeconds: 2
      - Errors:
          - MyCustomException2
          - MyCustomException3
        Description: 再試行ポリシー 2
        MaxAttempts: 3
        IntervalSeconds: 5
        BackoffRate: 2.0
      - Errors:
          - FnF.ALL
        Description: 再試行ポリシー 2
        MaxAttempts: 3
        IntervalSeconds: 5
        BackoffRate: 2.0
        MaxBackoffSeconds: 30
    Catch: // キャッチポリシー
      - Errors:
          - MyCustomException1
        Description: キャッチポリシー 1
        OutputConstructor:
          ErrorCode: MyCustomException1
          ErrorMessage: MyCustomException1
        Next: ErrorCatchExit
      - Errors:
          - MyCustomException2
          - MyCustomException3
        Description: キャッチポリシー 2
        Next: ErrorCatchExit
      - Errors:
          - FnF.ALL
        Description: キャッチポリシー 3
        Next: ErrorCatchExit
    Next: SucceededExit
  - Type: Pass
    Name: ErrorCatchExit
    End: true
  - Type: Pass
    Name: SucceededExit
    End: true