CloudFlow:グローバル IO、グローバル変数

クイックリファレンス

仕組み

グローバル変数は、実行レベルのキーバリューストアを提供します。任意のステートが終了時にこのストレージにデータを書き込むことができ、後続の任意のステートが入力チェーンを介してデータを受け取ることなく、そのデータを直接読み取ることができます。

コンストラクター

CloudFlow は、ステート内およびステート間でデータフローを管理するために、3 つのコンストラクターを使用します。

コンストラクター	目的	使用するケース
GlobalConstructor	グローバルストレージに値を書き込む	隣接していないステート間でデータを共有する
InputConstructor	ステートへの入力データを再形成する	ステートが実行される前に入力をフィルターまたは再構築する
OutputConstructor	ステートからの出力データを再形成する	次のステートに渡す前に出力をフィルターまたは再構築する

3 つのコンストラクターはすべて、$Context と $Global の両方を参照して情報を抽出できます。

次の図は、コンストラクターがステート内でどのように相互作用するかを示しています。

主な動作：

• $Output は、Task 呼び出しの生の結果です。非同期コールバックタスクの場合、$Output にはコールバックの結果が含まれます。

• GlobalConstructor が実行されると、その出力は既存の $Global の値とマージされます： $Global = Merge($Global, GlobalConstructor($Context, $Global))。

• $Global は、ワークフローの実行全体を通じてアクセス可能です。

GlobalConstructor:
  latestId.$: $Output.data.id       # 42 を $Global.latestId に書き込みます

OutputConstructor:
  combined.$: $Global.previousId    # 10 (GlobalConstructor が実行される前の値) を読み取ります

グローバル変数の書き込み

グローバル変数を書き込むには GlobalConstructor を使用します。これは各ステートの実行の最後に実行され、そのデータ構造は Map[String]Any です。

次の例では、関数の応答のヘッダーとボディを、それぞれ別のグローバル変数として保存します。

Type: StateMachine
Name: MyWorkFlow
SpecVersion: v1
StartAt: InvokeFunction
States:
  - Type: Task
    Name: InvokeFunction
    Action: FC:InvokeFunction
    TaskMode: RequestComplete
    Parameters:
      resourceArn: >-
        acs:fc:cn-hangzhou:123456:functions/myFunction/LATEST
      invocationType: Sync
      body.$: $Input
    GlobalConstructor:
      InvokeFunctionResultHeader.$: $Output.Header   # レスポンスヘッダーを保存
      InvokeFunctionResultBody.$: $Output.Body        # レスポンスボディを保存
    End: true

この定義では：

• InvokeFunctionResultHeader.$: $Output.Header は、関数のレスポンスヘッダーを InvokeFunctionResultHeader グローバル変数に保存します。

• InvokeFunctionResultBody.$: $Output.Body は、関数のレスポンスボディを InvokeFunctionResultBody グローバル変数に保存します。

グローバル変数の読み取り

グローバル変数を読み取るには、$Global キーワードを使用します。構築をサポートする任意の式は、$Global.<key> を通じてグローバルストレージにアクセスできます。

次の例は、最初のステートがグローバル変数を書き込み、2 番目のステートがそれを読み取る、2 つのステートからなるワークフローを示しています。

Type: StateMachine
Name: MyWorkFlow
SpecVersion: v1
StartAt: InvokeFunction1
States:
  - Type: Task
    Name: InvokeFunction1
    Action: FC:InvokeFunction
    TaskMode: RequestComplete
    Parameters:
      invocationType: Sync
      resourceArn: acs:fc:cn-hangzhou:123456:functions/myFunction/LATEST
    GlobalConstructor:
      InvokeFunctionPayload.$: $Output.Body     # 後で使用するためにレスポンスボディを保存
    Next: InvokeFunction
  - Type: Task
    Name: InvokeFunction
    Action: FC:InvokeFunction
    TaskMode: RequestComplete
    Parameters:
      resourceArn: acs:fc:cn-hangzhou:123456:functions/myFunction/LATEST
      invocationType: Sync
      body.$: $Global.InvokeFunctionPayload     # 保存された値を入力として読み取り
    OutputConstructor:
      demo.$: $Global                           # グローバルストレージ全体を出力
    End: true

この定義では：

• InvokeFunction1 は、そのレスポンスボディを InvokeFunctionPayload グローバル変数に保存します。

• InvokeFunction は $Global.InvokeFunctionPayload を読み取り、それを body パラメーターとして関数の呼び出しに渡します。

• OutputConstructor は、$Global の全コンテンツをステート出力の demo フィールドにマッピングします。

グローバル変数の値は、CloudFlow コンソールで実行出力を確認することで検証できます。

制限事項

これらの制限がお客様のニーズを満たさない場合は、チケットを送信して上限緩和をリクエストしてください。

並列実行における競合状態

グローバル変数は、1 つの実行内のすべてのステートで共有されます。並列ロジック (Parallel または Map ステート) が存在する場合、同時書き込みによって互いに上書きされる可能性があります。以下のガイドラインに従ってください。