步骤函数中的 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

您可以invoke Glue job from StepFunction synchronously 让它等待作业完成：

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

Answer 2

为什么不使用胶水中的触发器来处理依赖关系？