终止 - AWS Data Pipeline

AWS Data Pipeline 不再向新客户提供。的现有客户 AWS Data Pipeline 可以继续照常使用该服务。了解更多

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

终止

触发取消待处理或未完成的活动、资源或数据节点的操作。 AWS Data Pipeline 如果活动、资源或数据节点不以该lateAfterTimeout值开头,则尝试将其置于CANCELLED状态。

您不能终止包含 onSuccessOnFailonLateAction 资源的操作。

示例

以下是该对象类型的示例。在此示例中,MyActivityonLateAction 字段包含对操作 DefaultAction1 的引用。当您提供针对 onLateAction 的操作时,您还必须提供 lateAfterTimeout 值以指示自管道的计划开始后经过的时间段,在该时间段后,活动将被视为延迟。

{ "name" : "MyActivity", "id" : "DefaultActivity1", "schedule" : { "ref" : "MySchedule" }, "runsOn" : { "ref" : "MyEmrCluster" }, "lateAfterTimeout" : "1 Hours", "type" : "EmrActivity", "onLateAction" : { "ref" : "DefaultAction1" }, "step" : [ "s3://myBucket/myPath/myStep.jar,firstArg,secondArg", "s3://myBucket/myPath/myOtherStep.jar,anotherArg" ] }, { "name" : "TerminateTasks", "id" : "DefaultAction1", "type" : "Terminate" }

语法

可选字段 描述 槽类型
parent 作为槽继承源的当前对象的父项。 参考对象,例如 “父对象”:{"ref”:” myBaseObject Id "}

运行时字段 描述 槽类型
node 将为其执行此操作的节点。 参考对象,例如 “节点”:{"ref”:” myRunnableObject Id "}
@version 用于创建对象的管道版本。 String

系统字段 描述 槽类型
@error 用于描述格式不正确的对象的错误消息。 String
@pipelineId 该对象所属的管道的 ID。 String
@sphere 对象的范围指明对象在生命周期中的位置:组件对象产生实例对象,后者执行尝试对象。 String