Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Connessione ai flussi di lavoro di Apache Oozie con AWS Schema Conversion Tool

È possibile utilizzare l'interfaccia a riga di AWS SCT comando (CLI) per convertire i flussi di lavoro di Apache Oozie in. AWS Step Functions Dopo aver migrato i carichi di lavoro Apache Hadoop su AmazonEMR, puoi utilizzare un servizio nativo per orchestrare i Cloud AWS tuoi lavori. Per ulteriori informazioni, consulta Connessione ad Apache Hadoop.

AWS SCT converte i flussi di lavoro di Oozie e li utilizza per AWS Step Functions emulare funzionalità che non supporta. AWS Lambda AWS Step Functions Inoltre, AWS SCT converte le proprietà del lavoro di Oozie in. AWS Systems Manager

Per convertire i flussi di lavoro di Apache Oozie, assicurati di utilizzare AWS SCT la versione 1.0.671 o successiva. Inoltre, acquisisci familiarità con l'interfaccia a riga di comando di. AWS SCT Per ulteriori informazioni, consulta CLIRiferimento per AWS Schema Conversion Tool.

Prerequisiti per l'utilizzo di Apache Oozie come sorgente

I seguenti prerequisiti sono necessari per connettersi ad Apache Oozie con. AWS SCT CLI

Per lavorare con i flussi di lavoro di Apache Oozie di origine, è AWS SCT necessaria la struttura specifica dei file sorgente. Ciascuna cartella dell'applicazione deve includere il file. job.properties Questo file include coppie chiave-valore delle proprietà del lavoro. Inoltre, ogni cartella dell'applicazione deve includere il workflow.xml file. Questo file descrive i nodi di azione e i nodi di flusso di controllo del flusso di lavoro.

Connessione ad Apache Oozie come sorgente

Usa la seguente procedura per connetterti ai tuoi file sorgente di Apache Oozie.

Autorizzazioni per l'utilizzo AWS Lambda delle funzioni nel pacchetto di estensione

Per le funzioni di origine che AWS Step Functions non sono supportate, AWS SCT crea un pacchetto di estensione. Questo pacchetto di estensione include AWS Lambda funzioni che emulano le funzioni di origine.

Per utilizzare questo pacchetto di estensione, create un ruolo AWS Identity and Access Management (IAM) con le seguenti autorizzazioni.

{
    "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:::*/*"
            ]
        }
    ]
}

Per applicare il pacchetto di estensione, è AWS SCT necessario un IAM ruolo con le seguenti autorizzazioni.

{
    "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"
            ]
        }
    ]
}

Connessione a AWS Step Functions come destinazione

Utilizza la seguente procedura per connetterti AWS Step Functions come destinazione.