CloudFlow:サーバーレスワークフローと非同期関数計算呼び出しの統合

以下の操作を実行します。

• オプション: 非同期呼び出しが有効になっています。詳細については、概要をご参照ください。

  関数のステートフル非同期呼び出しを有効にすると、タスクの実行中に関数インスタンスを停止できます。これにより、フローをより細かい粒度で表示できます。

• 関数計算には、サーバーレスワークフロー にアクセスするための権限が付与されています。これにより、非同期関数の実行が完了した後、サーバーレスワークフロー をコールバックして後続のステップを実行できます。次のスニペットは、権限ポリシーを設定する方法を示しています。

  {
      "Statement": [
          {
              "Effect": "Allow",
              "Action": [
                  "fnf:ReportTaskSucceeded", // タスクの成功を報告
                  "fnf:ReportTaskFailed" // タスクの失敗を報告
              ],
              "Resource": [
                  "*"
              ]
          }
      ],
      "Version": "1"
  }

  承認の詳細については、他のAlibaba Cloudサービスにアクセスするための権限を関数計算に付与するをご参照ください。

デフォルトでは、サーバーレスワークフロー が関数計算タスクを調整してタスクフローを実装する場合、サーバーレスワークフロー は同期パターンを使用します。同期パターンでは、ワークフローが前の関数の実行結果を受信するまで、サーバーレスワークフローは次のステップに進みません。次のスニペットは、同期パターンを使用するフローを示しています。

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

関数呼び出しに同期パターンを使用すると、次の問題が発生する可能性があります。

• 関数計算の関数の呼び出しに関するリソース制限により、スロットリングエラーが発生する可能性があります。デフォルトでは、関数計算のAlibaba Cloudアカウントの単一リージョンで最大 300 の従量課金インスタンスが許可されます。

  サーバーレスワークフロー を使用して関数を呼び出す場合、呼び出しは他のサービスによって開始された関数呼び出しと同じクォータを共有します。これにより、スロットリングエラーが発生する可能性があります。この場合、サーバーレスワークフロー フローで複雑な再試行ポリシーを定義する必要があります。ただし、これによりフローが正常に実行されることは保証されません。

• タスクの実行に長い時間がかかる場合、サーバーレスワークフロー と関数計算の間に永続的な接続を確立する必要があります。不安定なネットワーク状態により、予期しないエラーが発生する可能性があります。

サーバーレスワークフロー では、非同期関数呼び出し機能とさまざまな統合パターンを組み合わせて、前述の問題を解決できます。同時に、この組み合わせは次の要件を満たすことができます。

• シナリオによっては、システムは現在のステップの完了を待たずに後続のステップを実行する必要があります。

• フローの実行中に予期しないエラーが発生した場合、システムは現在のステップをスキップして次のステップに進む必要があります。

サーバーレスワークフローは、シナリオに応じて、リクエストレスポンスパターン（requestResponse）、同期パターン（sync）、または待機コールバックパターン（waitForCallback）を使用して、関数計算の関数を非同期的に呼び出します。

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

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

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

次の例では、サーバーレスワークフロー はタスクノードとして関数計算を使用し、resourceArn を使用してデスティネーションサービスとして関数計算を指定し、serviceParams を使用して関数計算の関数を呼び出すために使用されるパラメータを指定します。serviceParams は次のパラメータをサポートしています。

• InvocationType: 関数の呼び出しタイプ。有効な値は Sync と Async です。 Sync は同期呼び出しを示します。 Async は非同期呼び出しを示します。

• オプション: StatefulAsyncInvocationID: ステートフル非同期呼び出しの ID。このパラメータを使用して、関数計算コンソールでデスティネーションタスクの名前を検索できます。

  説明

  InvocationType を Async に設定し、StatefulAsyncInvocationID の値を指定すると、サーバーレスワークフロー の関数呼び出しパターンはステートフルで非同期呼び出しになります。 StatefulAsyncInvocationID パラメータの値は、すべての関数で一意である必要があります。

フローが指定されたステップに到達すると、サーバーレスワークフローは指定された関数を非同期的に呼び出し、関数を実行します。次に、コールバックまたは前のステップの完了を待たずに、フローは次のステップに進みます。

version: v1
type: flow
steps:
  - type: task
    name: mytask
    resourceArn: acs:fc:{region}:{account}:services/{serviceName}.{qualifier}/functions/{functionName}
    pattern: requestResponse  // 同期パターンでの非同期呼び出し
    serviceParams:
        InvocationType: Async

サーバーレスワークフロー は、非同期関数呼び出し機能とステートフル非同期呼び出し機能を組み合わせて、ジョブタイプのシナリオをサポートします。ステートフル非同期呼び出し機能を有効にし、非同期呼び出しパターンを使用すると、関数の実行ステータスを表示し、関数の呼び出し時および呼び出し後に関数の実行を停止できます。これにより、フローが監視可能になり、操作が容易になります。次のスニペットは、サーバーレスワークフロー のフロー定義言語（FDL）を示しています。

version: v1
type: flow
steps:
  - type: task
    name: mytask
    resourceArn: acs:fc:::services/{serviceName}.{qualifier}/functions/{functionName}
    pattern: sync  // 同期パターンでの非同期呼び出し
    inputMappings:
      - target: id
        source: $context.execution.name
    serviceParams:
        InvocationType: Async
        StatefulAsyncInvocationID: $.id