Step Functions で Workflow Studio を使用して状態の入力と出力を設定する

ステートへの入力に次の JSON データが含まれているとします。

{
  "comment": "Example for InputPath",
  "dataset1": {
    "val1": 1,
    "val2": 2,
    "val3": 3
  },
  "dataset2": {
    "val1": "a",
    "val2": "b",
    "val3": "c"
  }
}

InputPath フィルターを適用するには、[InputPath で入力をフィルタリング] を選択し、適切なリファレンスパスを入力します。$.dataset2.val1 に入ると、次の JSON が状態への入力として渡されます。

{"a"}

リファレンスパスでは、値の選択もできます。リファレンスが { "a": [1, 2, 3, 4] } で、リファレンスパス$.a[0:2] を InputPath フィルターとして適用した場合、結果は次のようになります。

[ 1, 2 ]

次の JSON データがパラレルステートへの入力であるとします。

{
  "comment": "Example for Parameters",
  "product": {
    "details": {
      "color": "blue",
      "size": "small",
      "material": "cotton"
    },
    "availability": "in stock",
    "sku": "2317",
    "cost": "$23"
  }
}

この例では、ResultSelector を使って、Amazon EMR CreateCluster 状態の Amazon EMR CreateCluster API コールからのレスポンスを操作します。以下は、Amazon EMR CreateCluster API コールからの結果です。

{
  "resourceType": "elasticmapreduce",
  "resource": "createCluster.sync",
  "output": {
    "SdkHttpMetadata": {
      "HttpHeaders": {
        "Content-Length": "1112",
        "Content-Type": "application/x-amz-JSON-1.1",
        "Date": "Mon, 25 Nov 2019 19:41:29 GMT",
        "x-amzn-RequestId": "1234-5678-9012"
      },
      "HttpStatusCode": 200
    },
    "SdkResponseMetadata": {
      "RequestId": "1234-5678-9012"
    },
    "ClusterId": "AKIAIOSFODNN7EXAMPLE"
  }
}

この情報パートを選択し、静的値を持つ追加のキーバリューのペアを渡すには、状態の [出力] タブの下、[ResultSelector] フィールドで次のように指定します。

{
 "result": "found",
 "ClusterId.$": "$.output.ClusterId", 
 "ResourceType.$": "$.resourceType"
 }

ResultSelector を使用すると、次の結果になります。

{
 "result": "found",
 "ClusterId": "AKIAIOSFODNN7EXAMPLE",
 "ResourceType": "elasticmapreduce"
}

次のものがタスクステートへの入力であるとします。

{
  "details": "Default example",
  "who": "AWS Step Functions"
}

タスクステートの結果は次のとおりです。

Hello, AWS Step Functions

ResultPath を適用し、$.taskresult のように、結果を追加する場所を示すリファレンスパスを入力して、状態の入力にこの結果を追加します。

この ResultPath を使って、状態の出力として渡される JSON を次に示します。

{
  "details": "Default example",
  "who": "AWS Step Functions",
  "taskresult": "Hello, AWS Step Functions!"
}

Lambda Invoke API コールが Lambda 関数の結果に加えてメタデータを返すとしましょう。

{
  "ExecutedVersion": "$LATEST",
  "Payload": {
     "foo": "bar",
     "colors": [
          "red",
          "blue",
          "green"    
     ],
     "car": {
          "year": 2008,
          "make": "Toyota",
          "model": "Matrix"
     }
   },
"SdkHttpMetadata": {
  "AllHttpHeaders": {
    "X-Amz-Executed-Version": ["$LATEST"]
...

OutputPath を使用して、追加のメタデータをフィルターで除外します。デフォルトでは、Workflow Studio で作成された Lambda Invoke 状態の [OutputPath] フィルターの値は $.Payload です。このデフォルト値では、追加のメタデータが削除され、Lambda 関数を直接実行するのに等しい出力が返されます。

Lambda 呼び出しタスクの結果の例と [出力] フィルターの $.Payload の値は、次の JSON データを出力として渡します。

{
 "foo": "bar",
 "colors": [
      "red",
      "blue",
      "green"    
 ],
 "car": {
      "year": 2008,
      "make": "Toyota",
      "model": "Matrix"
 }
}