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 |