passing parameters in step functions

0

Hello,

Within step function, I want to pass parameters received from input to a Glue:ListCrawler state to run related crawlers inside a Glue and after running all crawlers, I also need to pass the input parameters to a choice step to run glue jobs. Because the output of Glue:ListCrawler is the CrawlerName, I can not use OutputPath to include input parameters. Can anyone help me how to receive input parameters within choice state, in this regard?

step function run with this Json format: { "Comment": "Run Glue workflow", "tags": { "client": "test", "environment": "qa"}, "glue":{ "client": "test", "environment": "qa", "partitionDate" : "2023-03-2" }}

Step function definition:

{ "Comment": "A utility state machine to run all Glue Crawlers that match tags", "StartAt": "Pass", "States": { "Pass": { "Type": "Pass", "Next": "Get Glue Crawler List based on Client, Environment" }, "Get Glue Crawler List based on Client, Environment": { "Next": "Run Glue Crawlers for all LOB", "OutputPath": "$.CrawlerNames", "Parameters": { "Tags.$": "$.tags" }, "Resource": "arn:aws:states:::aws-sdk:glue:listCrawlers", "Retry": [ { "BackoffRate": 5, "ErrorEquals": [ "States.ALL" ], "IntervalSeconds": 2, "MaxAttempts": 3 } ], "Type": "Task" }, "Run Glue Crawlers for all LOB": { "Iterator": { "StartAt": "Run Glue Crawler for each LOB", "States": { "Run Glue Crawler for each LOB": { "Catch": [ { "ErrorEquals": [ "States.ALL" ], "Next": "Crawler Success" } ], "Next": "Crawler Success", "Parameters": { "Input": { "crawler_name.$": "$" }, "StateMachineArn": "arn:aws:states:ca-central-1:467688788830:stateMachine:run_each_crawler" }, "Resource": "arn:aws:states:::states:startExecution.sync:2", "Retry": [ { "BackoffRate": 5, "ErrorEquals": [ "States.ALL" ], "IntervalSeconds": 2, "MaxAttempts": 1 } ], "Type": "Task" }, "Crawler Success": { "Type": "Succeed" } } }, "ResultPath": null, "Type": "Map", "Next": "Choice", "MaxConcurrency": 4 }, "Choice": { "Type": "Choice", "Choices": [ { "Variable": "$.environment", "StringEquals": "qa", "Next": "start glue-qa-dh" }, { "Variable": "$.environment", "StringEquals": "uat", "Next": "start glue-uat-dh" },

已提問 1 年前檢視次數 1527 次
1 個回答
3

In order to pass the input parameters to the choice step, you can use a "Pass" state between "Run Glue Crawlers for all LOB" and "Choice" states. This "Pass" state will help you to merge the output of "Run Glue Crawlers for all LOB" and the original input parameters. Update your Step Function definition as follows:

{
  "Comment": "A utility state machine to run all Glue Crawlers that match tags",
  "StartAt": "Pass",
  "States": {
    "Pass": {
      "Type": "Pass",
      "Next": "Get Glue Crawler List based on Client, Environment"
    },
    "Get Glue Crawler List based on Client, Environment": {
      "Next": "Run Glue Crawlers for all LOB",
      "OutputPath": "$.CrawlerNames",
      "Parameters": {
        "Tags.$": "$.tags"
      },
      "Resource": "arn:aws:states:::aws-sdk:glue:listCrawlers",
      "Retry": [
        {
          "BackoffRate": 5,
          "ErrorEquals": [
            "States.ALL"
          ],
          "IntervalSeconds": 2,
          "MaxAttempts": 3
        }
      ],
      "Type": "Task"
    },
    "Run Glue Crawlers for all LOB": {
      "Iterator": {
        "StartAt": "Run Glue Crawler for each LOB",
        "States": {
          "Run Glue Crawler for each LOB": {
            "Catch": [
              {
                "ErrorEquals": [
                  "States.ALL"
                ],
                "Next": "Crawler Success"
              }
            ],
            "Next": "Crawler Success",
            "Parameters": {
              "Input": {
                "crawler_name.$": "$"
              },
              "StateMachineArn": "arn:aws:states:ca-central-1:467688788830:stateMachine:run_each_crawler"
            },
            "Resource": "arn:aws:states:::states:startExecution.sync:2",
            "Retry": [
              {
                "BackoffRate": 5,
                "ErrorEquals": [
                  "States.ALL"
                ],
                "IntervalSeconds": 2,
                "MaxAttempts": 1
              }
            ],
            "Type": "Task"
          },
          "Crawler Success": {
            "Type": "Succeed"
          }
        }
      },
      "ResultPath": null,
      "Type": "Map",
      "Next": "MergeResults",
      "MaxConcurrency": 4
    },
    "MergeResults": {
      "Type": "Pass",
      "ResultPath": "$.CrawlerResults",
      "Next": "Choice"
    },
    "Choice": {
      "Type": "Choice",
      "Choices": [
        {
          "Variable": "$.glue.environment",
          "StringEquals": "qa",
          "Next": "start glue-qa-dh"
        },
        {
          "Variable": "$.glue.environment",
          "StringEquals": "uat",
          "Next": "start glue-uat-dh"
        }
      ]
    },
    "start glue-qa-dh": {
      ...
    },
    "start glue-uat-dh": {
      ...
    }
  }
}

This updated definition adds a "MergeResults" Pass state that is used to store the output of the "Run Glue Crawlers for all LOB" state in a new field named "CrawlerResults". Since the "ResultPath" is set to "$.CrawlerResults

profile picture
專家
已回答 1 年前

您尚未登入。 登入 去張貼答案。

一個好的回答可以清楚地回答問題並提供建設性的意見回饋,同時有助於提問者的專業成長。

回答問題指南