AWS Data Pipeline 不再向新客户提供。的现有客户 AWS Data Pipeline 可以继续照常使用该服务。了解更多
本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
终止
触发取消待处理或未完成的活动、资源或数据节点的操作。 AWS Data Pipeline 如果活动、资源或数据节点不以该lateAfterTimeout
值开头,则尝试将其置于CANCELLED状态。
您不能终止包含 onSuccess
、OnFail
或 onLateAction
资源的操作。
示例
以下是该对象类型的示例。在此示例中,MyActivity
的 onLateAction
字段包含对操作 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 |