Interruzione - AWS Data Pipeline

AWS Data Pipeline non è più disponibile per i nuovi clienti. Clienti esistenti di AWS Data Pipeline possono continuare a utilizzare il servizio normalmente. Ulteriori informazioni

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Interruzione

Un'azione per attivare l'annullamento di un'attività, una risorsa o un nodo di dati in sospeso o incompiuto. AWS Data Pipeline tenta di impostare lo CANCELLED stato dell'attività, della risorsa o del nodo di dati se non parte dal lateAfterTimeout valore.

Non è possibile terminare azioni che includono risorse onSuccess, OnFail o onLateAction.

Esempio

Di seguito è illustrato un esempio di questo tipo di oggetto. In questo esempio, il campo onLateAction di MyActivity contiene un riferimento all'azione DefaultAction1. Quando si fornisce un'azione per onLateAction, è necessario fornire un valore lateAfterTimeout per indicare il periodo di tempo dall'inizio programmato della pipeline dopo il quale l'attività è considerata in ritardo.

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

Sintassi

Campi opzionali Descrizione Tipo di slot
parent Padre dell'oggetto corrente da cui vengono ereditati gli slot. Oggetto di riferimento, ad esempio «parent»: {"ref»:» myBaseObject Id "}

Campi Runtime Descrizione Tipo di slot
nodo Il nodo per il quale viene eseguita questa azione. Oggetto di riferimento, ad esempio «node»: {"ref»:» myRunnableObject Id "}
@version Versione della pipeline con cui l'oggetto è stato creato. Stringa

Campi di sistema Descrizione Tipo di slot
@error Errore che descrive il formato oggetto errato. Stringa
@pipelineId L'ID della pipeline a cui appartiene questo oggetto. Stringa
@sphere La sfera di un oggetto indica la propria posizione nel ciclo di vita: i Component Objects generano Instance Objects che eseguono Attempt Objects. Stringa