终止 - AWS Data Pipeline

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

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

终止

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

您不能终止包含 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://amzn-s3-demo-bucket/myPath/myStep.jar,firstArg,secondArg", "s3://amzn-s3-demo-bucket/myPath/myOtherStep.jar,anotherArg" ] }, { "name" : "TerminateTasks", "id" : "DefaultAction1", "type" : "Terminate" }

语法

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

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

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