使用Step Functions编排Sqoop

0

【以下的问题经过翻译处理】 我们可以使用 Step Function 来编排Sqoop作业吗?目标是创建一个暂时的集群,先使用Sqoop加载数据,然后在Hive中进行转换,但看起来Command Runner没有这样的选项。

如果不行,有什么替代方案吗?

profile picture
专家
已提问 5 个月前8 查看次数
1 回答
0

【以下的回答经过翻译处理】 您可以在脚本运行模式下运行任何脚本。

基本上,从 Step Function 调用 Script Runner需要的语法,例如:


       "StartAt":"Step 1",
       "States":{ 
          "Step_1":{ 
             "Type":"Task",
             "Resource":"arn:aws:states:::elasticmapreduce:addStep.sync",
             "Parameters":{ 
                "ClusterId.$":"$.ClusterId",
                "Step":{ 
                   "Name":"1 - Step 1",
                   "ActionOnFailure":"CONTINUE",
                   "HadoopJarStep":{ 
                      "Jar":"s3://elasticmapreduce/libs/script-runner/script-runner.jar",
                      "Args":[ 
                         "s3://xxx/scripts/step1.sh"
                      ]
                   }
                }
             },
             "End":true
          }
       }
    }

将所有代码放入step1.sh脚本中,该脚本将在主节点上执行您想要执行的任何任务,包括Sqoop。

profile picture
专家
已回答 5 个月前

您未登录。 登录 发布回答。

一个好的回答可以清楚地解答问题和提供建设性反馈,并能促进提问者的职业发展。

回答问题的准则