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à.
S3 PrefixNotEmpty
Una condizione preliminare per verificare la presenza degli oggetti Amazon S3 con il prefisso specificato (rappresentato come URI a).
Esempio
Di seguito è riportato un esempio di questo tipo di oggetto utilizzando campi obbligatori, facoltativi e di espressioni.
{ "id" : "InputReady", "type" : "S3PrefixNotEmpty", "role" : "test-role", "s3Prefix" : "#{node.filePath}" }
Sintassi
| Campi obbligatori | Descrizione | Tipo di slot |
|---|---|---|
| role | Specifica il ruolo da utilizzare per eseguire la precondizione. | Stringa |
| s3Prefix | Il prefisso Amazon S3 per verificare l'esistenza di oggetti. | Stringa |
| Campi opzionali | Descrizione | Tipo di slot |
|---|---|---|
| attemptStatus | Lo stato segnalato più di recente dall'attività remota. | Stringa |
| attemptTimeout | Timeout per il completamento del lavoro in remoto. Se questo campo è impostato, un'attività remota che non viene completata entro il tempo impostato di avvio viene tentata di nuovo. | Periodo |
| failureAndRerunModalità | Descrive il comportamento del nodo consumer quando le dipendenze presentano un errore o vengono di nuovo eseguite | Enumerazione |
| lateAfterTimeout | Il tempo trascorso dopo l'inizio della pipeline entro il quale l'oggetto deve essere completato. Viene attivato solo quando il tipo di pianificazione non è impostato su. ondemand |
Periodo |
| maximumRetries | Numero massimo di tentativi in caso di errore | Numero intero |
| onFail | Un'azione da eseguire quando l'oggetto corrente ha esito negativo. | Oggetto di riferimento, ad esempio "onFail«: {" ref»:» myActionId «} |
| onLateAction | Azioni che devono essere attivate se un oggetto non è stato ancora pianificato o non è ancora completo. | Oggetto di riferimento, ad esempio "onLateAction«: {" ref»:» myActionId «} |
| onSuccess | Un'operazione da eseguire quando l'oggetto corrente ha esito positivo. | Oggetto di riferimento, ad esempio "onSuccess«: {" ref»:» myActionId «} |
| parent | Padre dell'oggetto corrente da cui saranno ereditati gli slot. | Oggetto di riferimento, ad esempio «parent»: {"ref»:» myBaseObject Id "} |
| preconditionTimeout | Il periodo dall'inizio dopo il quale la precondizione viene contrassegnata come non riuscita se ancora non è stata soddisfatta. | Periodo |
| reportProgressTimeout | Timeout per il lavoro remoto, chiamate successive areportProgress. Se impostato, le attività in remoto che non presentano avanzamenti nel periodo specificato potrebbero essere considerate bloccate e sono quindi oggetto di un altro tentativo. | Periodo |
| retryDelay | La durata del timeout tra due tentativi. | Periodo |
| Campi Runtime | Descrizione | Tipo di slot |
|---|---|---|
| @activeInstances | Elenco di oggetti di istanze attive attualmente programmate. | Oggetto di riferimento, ad esempio "activeInstances«: {" ref»:» myRunnableObject Id "} |
| @actualEndTime | L'ora in cui è terminata l'esecuzione di questo oggetto. | DateTime |
| @actualStartTime | L'ora in cui è stata avviata l'esecuzione di questo oggetto. | DateTime |
| cancellationReason | Il cancellationReason se questo oggetto è stato annullato. | Stringa |
| @cascadeFailedOn | Descrizione della catena di dipendenza che ha generato l'errore dell'oggetto. | Oggetto di riferimento, ad esempio "cascadeFailedOn«: {" ref»:» myRunnableObject Id "} |
| currentRetryCount | Numero di volte in cui la precondizione è stato provata in questo tentativo. | Stringa |
| emrStepLog | EMRi registri dei passaggi sono disponibili solo in caso di tentativi di EMR attività | Stringa |
| errorId | Il errorId se questo oggetto ha fallito. | Stringa |
| errorMessage | Il errorMessage se questo oggetto ha avuto esito negativo. | Stringa |
| errorStackTrace | Traccia dello stack di errore se l'oggetto non è riuscito. | Stringa |
| hadoopJobLog | I log dei job Hadoop sono disponibili per EMR i tentativi di attività basate su di esse. | Stringa |
| hostname | Il nome host del client che si è aggiudicato il tentativo dell'attività. | Stringa |
| lastRetryTime | L'ultima volta in cui la precondizione è stato provata all'interno di questo tentativo. | Stringa |
| nodo | Il nodo per il quale viene eseguita questa precondizione. | Oggetto di riferimento, ad esempio «node»: {"ref»:» myRunnableObject Id "} |
| reportProgressTime | Il periodo di tempo più recente in cui l'attività remota ha segnalato un progresso. | DateTime |
| @scheduledEndTime | L'orario di termine della pianificazione per un oggetto. | DateTime |
| @scheduledStartTime | L'orario di inizio della pianificazione per l'oggetto. | DateTime |
| @status | Lo stato di questo oggetto. | Stringa |
| @version | Versione della pipeline con cui l'oggetto è stato creato. | Stringa |
| @waitingOn | Descrizione dell'elenco di dipendenze per cui questo oggetto è in attesa. | Oggetto di riferimento, ad esempio "waitingOn«: {" ref»:» myRunnableObject Id "} |
| 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 |
Vedi anche
