步骤函数中的aws胶水作业依赖性

Question

我创建了 2 个胶水作业（gluejob1、gluejob2）。

我想创建一个依赖项，因为gluejob2 应该只在gluejob1 完成后运行。

为了编排这个，我创建了一个具有以下定义的阶跃函数：

 {
  "gluejob1": {
    "Type": "Task",
    "Resource": "gluejob1.Arn",
    "Comment": "Glue job1.",
    "Next": "gluejob2"
  },

  "gluejob2": {
    "Type": "Task",
    "Resource": "gluejob2.Arn",
    "Comment": "TGlue job2.",
    "Next": "Gluejob2 Finished Loading"
  },
  "Gluejob2 Finished Loading": {
    "Type": "Pass",
    "Result": "",
    "End": true
  }
}

当我执行这个 step 函数时，状态函数在它触发 Gluejob1并继续触发gluejob2的那一刻称它为成功。

我想知道是否有可能只有在gluejob1 完成后才运行gluejob2。

Answer 1

您可以从 StepFunction 同步调用 Glue 作业，以便它等待作业完成：

{
  "StartAt": "gluejob1",
  "States": {
    "gluejob1": {
      "Type": "Task",
      "Resource": "arn:aws:states:::glue:startJobRun.sync",
      "Parameters": {
        "JobName.$": "ETLJobName1"
      },
      "Next": "gluejob2"
    },
    "gluejob2": {
      "Type": "Task",
      "Resource": "arn:aws:states:::glue:startJobRun.sync",
      "Parameters": {
        "JobName.$": "ETLJobName2"
      },
      "Next": "Gluejob2 Finished Loading"
    },
    "Gluejob2 Finished Loading": {
      "Type": "Pass",
      "Result": "",
      "End": true
    }
}