翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

を使用した Apache Oozie ワークフローへの接続 AWS Schema Conversion Tool

AWS SCT コマンドラインインターフェイス (CLI) を使用して、Apache Oozie ワークフローを に変換できます AWS Step Functions。Apache Hadoop ワークロードを Amazon に移行したらEMR、 のネイティブサービスを使用してジョブ AWS クラウド をオーケストレーションできます。詳細については、「Apache Hadoop への接続」を参照してください。

AWS SCT は Oozie ワークフローを に変換 AWS Step Functions し AWS Lambda 、 を使用して、 がサポート AWS Step Functions していない機能をエミュレートします。また、 は Oozie ジョブのプロパティを AWS SCT に変換します AWS Systems Manager。

Apache Oozie ワークフローを変換するには、 AWS SCT バージョン 1.0.671 以降を使用していることを確認してください。また、 AWS SCTのコマンドラインインターフェイスにも慣れておいてください。詳細については、「CLI のリファレンス AWS Schema Conversion Tool」を参照してください。

Apache Oozie をソースとして使用する場合の前提条件

を使用して AWS SCT Apache Oozie に接続するには、次の前提条件が必要ですCLI。

ソース Apache Oozie ワークフローを使用するには、ソースファイルの特定の構造 AWS SCT が必要です。各アプリケーションフォルダには job.properties ファイルが含まれている必要があります。このファイルには、ジョブプロパティのキーと値のペアが含まれています。また、各アプリケーションフォルダにこの workflow.xml ファイルが含まれている必要があります。このファイルには、ワークフローのアクションノードと制御フローノードが記述されています。

ソースとしての Apache Oozie への接続

以下の手順を使用して、Apache Oozie ソースファイルに接続します。

拡張パックで AWS Lambda 関数を使用するためのアクセス許可

がサポート AWS Step Functions していないソース関数の場合、 は拡張パック AWS SCT を作成します。この拡張パックには、ソース AWS Lambda 関数をエミュレートする 関数が含まれています。

この拡張パックを使用するには、次のアクセス許可を持つ AWS Identity and Access Management （IAM) ロールを作成します。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "lambda",
            "Effect": "Allow",
            "Action": [
                "lambda:InvokeFunction"
            ],
            "Resource": [
                "arn:aws:lambda:*:498160209112:function:LoadParameterInitialState:*",
                "arn:aws:lambda:*:498160209112:function:EvaluateJSPELExpressions:*"
            ]
        },
        {
            "Sid": "emr",
            "Effect": "Allow",
            "Action": [
                "elasticmapreduce:DescribeStep",
                "elasticmapreduce:AddJobFlowSteps"
            ],
            "Resource": [
                "arn:aws:elasticmapreduce:*:498160209112:cluster/*"
            ]
        },
        {
            "Sid": "s3",
            "Effect": "Allow",
            "Action": [
                "s3:GetObject"
            ],
            "Resource": [
                "arn:aws:s3:::*/*"
            ]
        }
    ]
}

拡張パックを適用するには、次のアクセス許可を持つ IAMロール AWS SCT が必要です。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "iam:GetRole",
                "iam:ListRolePolicies",
                "iam:CreateRole",
                "iam:TagRole",
                "iam:PutRolePolicy",
                "iam:DeleteRolePolicy",
                "iam:DeleteRole",
                "iam:PassRole"
            ],
            "Resource": [
                "arn:aws:iam::ACCOUNT_NUMBER:role/sct/*"
            ]
        },
        {
            "Effect": "Allow",
            "Action": [
                "iam:GetRole",
                "iam:ListRolePolicies"
            ],
            "Resource": [
                "arn:aws:iam::ACCOUNT_NUMBER:role/lambda_LoadParameterInitialStateRole",
                "arn:aws:iam::ACCOUNT_NUMBER:role/lambda_EvaluateJSPELExpressionsRole",
                "arn:aws:iam::ACCOUNT_NUMBER:role/stepFunctions_MigratedOozieWorkflowRole"
            ]
        },
        {
            "Effect": "Allow",
            "Action": [
                "lambda:GetFunction",
                "lambda:CreateFunction",
                "lambda:UpdateFunctionCode",
                "lambda:DeleteFunction"
            ],
            "Resource": [
                "arn:aws:lambda:*:ACCOUNT_NUMBER:function:LoadParameterInitialState",
                "arn:aws:lambda:*:ACCOUNT_NUMBER:function:EvaluateJSPELExpressions"
            ]
        }
    ]
}

ターゲット AWS Step Functions として に接続する

次の手順を使用して、ターゲット AWS Step Functions として に接続します。