AWS Data Pipeline non è più disponibile per i nuovi clienti. I clienti esistenti di AWS Data Pipeline possono continuare a utilizzare il servizio normalmente. [Ulteriori informazioni](https://aws.amazon.com/blogs/big-data/migrate-workloads-from-aws-data-pipeline/)
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à.
# Precondizioni
I seguenti sono gli oggetti AWS Data Pipeline precondizionati:
**Topics**
+ [La dinamo esiste DBData](dp-dynamodbdataexists.md)
+ [La dinamo DBTable esiste](dp-dynamodbtableexists.md)
+ [Exists](dp-object-exists.md)
+ [S3 KeyExists](dp-object-S3KeyExists.md)
+ [S3 PrefixNotEmpty](dp-object-s3prefixnotempty.md)
+ [ShellCommandPrecondition](dp-object-shellcommandprecondition.md)
# La dinamo esiste DBData
Un prerequisito per verificare l'esistenza di dati in una tabella DynamoDB.
## Sintassi
****
| Campi obbligatori | Description | Tipo di slot |
| --- | --- | --- |
| role | Specifica il ruolo da utilizzare per eseguire la precondizione. | Stringa |
| tableName | Tabella DynamoDB da verificare. | Stringa |
****
| Campi opzionali | Description | 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»: \$1"ref»:» myActionId «\$1 |
| onLateAction | Azioni che devono essere attivate se un oggetto non è stato ancora pianificato o non è ancora completo. | Oggetto di riferimento, ad esempio "onLateAction«: \$1" ref»:» myActionId «\$1 |
| onSuccess | Un'operazione da eseguire quando l'oggetto corrente ha esito positivo. | Oggetto di riferimento, ad esempio «onSuccess»: \$1"ref»:» myActionId «\$1 |
| parent | Padre dell'oggetto corrente da cui saranno ereditati gli slot. | Oggetto di riferimento, ad esempio «parent»: \$1"ref»:» myBaseObject Id "\$1 |
| preconditionTimeout | Il periodo dall'inizio dopo il quale la precondizione viene contrassegnata come non riuscita se ancora non è stata soddisfatta. | Periodo |
| reportProgressTimeout | Timeout per chiamate successive di attività in remoto a reportProgress. 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 | Description | Tipo di slot |
| --- | --- | --- |
| @activeInstances | Elenco di oggetti di istanze attive attualmente programmate. | Oggetto di riferimento, ad esempio «activeInstances»: \$1"ref»:» myRunnableObject Id "\$1 |
| @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 | 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«: \$1" ref»:» myRunnableObject Id "\$1 |
| currentRetryCount | Numero di volte in cui la precondizione è stato provata in questo tentativo. | Stringa |
| emrStepLog | Log della fase EMR disponibili solo sui tentativi delle attività EMR | Stringa |
| errorId | ErrorId se l'oggetto non è riuscito. | Stringa |
| errorMessage | ErrorMessage se l'oggetto non è riuscito. | Stringa |
| errorStackTrace | Traccia dello stack di errore se l'oggetto non è riuscito. | Stringa |
| hadoopJobLog | Log delle attività Hadoop disponibili per le attività basate su EMR. | 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»: \$1"ref»:» myRunnableObject Id "\$1 |
| 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»: \$1"ref»:» myRunnableObject Id "\$1 |
****
| Campi di sistema | Description | 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 |
# La dinamo DBTable esiste
Una precondizione per verificare l'esistenza della tabella DynamoDB.
## Sintassi
****
| Campi obbligatori | Description | Tipo di slot |
| --- | --- | --- |
| role | Specifica il ruolo da utilizzare per eseguire la precondizione. | Stringa |
| tableName | Tabella DynamoDB da verificare. | Stringa |
****
| Campi opzionali | Description | 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 |
| failureAndRerunModo | 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»: \$1"ref»:» myActionId «\$1 |
| onLateAction | Azioni che devono essere attivate se un oggetto non è stato ancora pianificato o non è ancora completo. | Oggetto di riferimento, ad esempio "onLateAction«: \$1" ref»:» myActionId «\$1 |
| onSuccess | Un'operazione da eseguire quando l'oggetto corrente ha esito positivo. | Oggetto di riferimento, ad esempio «onSuccess»: \$1"ref»:» myActionId «\$1 |
| parent | Padre dell'oggetto corrente da cui saranno ereditati gli slot. | Oggetto di riferimento, ad esempio «parent»: \$1"ref»:» myBaseObject Id "\$1 |
| preconditionTimeout | Il periodo dall'inizio dopo il quale la precondizione viene contrassegnata come non riuscita se ancora non è stata soddisfatta. | Periodo |
| reportProgressTimeout | Timeout per chiamate successive di attività in remoto a reportProgress. 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 | Description | Tipo di slot |
| --- | --- | --- |
| @activeInstances | Elenco di oggetti di istanze attive attualmente programmate. | Oggetto di riferimento, ad esempio «activeInstances»: \$1"ref»:» myRunnableObject Id "\$1 |
| @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 | 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«: \$1" ref»:» myRunnableObject Id "\$1 |
| currentRetryCount | Numero di volte in cui la precondizione è stato provata in questo tentativo. | Stringa |
| emrStepLog | Log della fase EMR disponibili solo sui tentativi delle attività EMR | Stringa |
| errorId | ErrorId se l'oggetto non è riuscito. | Stringa |
| errorMessage | ErrorMessage se l'oggetto non è riuscito. | Stringa |
| errorStackTrace | Traccia dello stack di errore se l'oggetto non è riuscito. | Stringa |
| hadoopJobLog | Log delle attività Hadoop disponibili per le attività basate su EMR. | 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»: \$1"ref»:» myRunnableObject Id "\$1 |
| 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»: \$1"ref»:» myRunnableObject Id "\$1 |
****
| Campi di sistema | Description | 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 |
# Exists
Verifica se esiste un oggetto nodo di dati.
**Nota**
È consigliabile utilizzare precondizioni gestite dal sistema. Per ulteriori informazioni, consulta [Precondizioni](dp-concepts-preconditions.md).
## Esempio
Di seguito è illustrato un esempio di questo tipo di oggetto. L'oggetto `InputData` fa riferimento a questo oggetto, `Ready`, più a un altro oggetto definito nello stesso file di definizione della pipeline. `CopyPeriod` è un oggetto `Schedule`.
```
{
"id" : "InputData",
"type" : "S3DataNode",
"schedule" : { "ref" : "CopyPeriod" },
"filePath" : "s3://amzn-s3-demo-bucket/InputData/#{@scheduledStartTime.format('YYYY-MM-dd-hh:mm')}.csv",
"precondition" : { "ref" : "Ready" }
},
{
"id" : "Ready",
"type" : "Exists"
}
```
## Sintassi
****
| Campi opzionali | Description | 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»: \$1"ref»:» myActionId «\$1 |
| onLateAction | Azioni che devono essere attivate se un oggetto non è stato ancora pianificato o non è ancora completo. | Oggetto di riferimento, ad esempio "onLateAction«: \$1" ref»:» myActionId «\$1 |
| onSuccess | Un'operazione da eseguire quando l'oggetto corrente ha esito positivo. | Oggetto di riferimento, ad esempio «onSuccess»: \$1"ref»:» myActionId «\$1 |
| parent | Padre dell'oggetto corrente da cui saranno ereditati gli slot. | Oggetto di riferimento, ad esempio «parent»: \$1"ref»:» myBaseObject Id "\$1 |
| preconditionTimeout | Il periodo dall'inizio dopo il quale la precondizione viene contrassegnata come non riuscita se ancora non è stata soddisfatta. | Periodo |
| reportProgressTimeout | Timeout per chiamate successive di attività in remoto a reportProgress. 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 | Description | Tipo di slot |
| --- | --- | --- |
| @activeInstances | Elenco di oggetti di istanze attive attualmente programmate. | Oggetto di riferimento, ad esempio «activeInstances»: \$1"ref»:» myRunnableObject Id "\$1 |
| @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 | 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«: \$1" ref»:» myRunnableObject Id "\$1 |
| emrStepLog | Log della fase EMR disponibili solo sui tentativi delle attività EMR | Stringa |
| errorId | ErrorId se l'oggetto non è riuscito. | Stringa |
| errorMessage | ErrorMessage se l'oggetto non è riuscito. | Stringa |
| errorStackTrace | Traccia dello stack di errore se l'oggetto non è riuscito. | Stringa |
| hadoopJobLog | Log delle attività Hadoop disponibili per le attività basate su EMR. | Stringa |
| hostname | Il nome host del client che si è aggiudicato il tentativo dell'attività. | Stringa |
| nodo | Il nodo per il quale viene eseguita questa precondizione. | Oggetto di riferimento, ad esempio «node»: \$1"ref»:» myRunnableObject Id "\$1 |
| 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»: \$1"ref»:» myRunnableObject Id "\$1 |
****
| Campi di sistema | Description | 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
+ [ShellCommandPrecondition](dp-object-shellcommandprecondition.md)
# S3 KeyExists
Verifica se esiste una chiave in un nodo di dati Amazon S3.
## Esempio
Di seguito è illustrato un esempio di questo tipo di oggetto. La precondizione sarà attivata quando esiste la chiave `s3://amzn-s3-demo-bucket/mykey`, a cui si fa riferimento tramite il parametro `s3Key`.
```
{
"id" : "InputReady",
"type" : "S3KeyExists",
"role" : "test-role",
"s3Key" : "s3://amzn-s3-demo-bucket/mykey"
}
```
È inoltre possibile utilizzare `S3KeyExists` come precondizione nella seconda pipeline che attende il termine della prima pipeline. A tale scopo:
1. Scrivi un file su Amazon S3 al termine del completamento della prima pipeline.
1. Crea una precondizione `S3KeyExists` nella seconda pipeline.
## Sintassi
****
| Campi obbligatori | Description | Tipo di slot |
| --- | --- | --- |
| role | Specifica il ruolo da utilizzare per eseguire la precondizione. | Stringa |
| s3Key | La chiave Amazon S3. | Stringa |
****
| Campi opzionali | Description | Tipo di slot |
| --- | --- | --- |
| attemptStatus | Lo stato segnalato più di recente dall'attività remota. | Stringa |
| attemptTimeout | Timeout prima di tentare nuovamente di completare il lavoro in remoto. Se impostato, un'attività remota che non viene completata entro il tempo impostato dopo l'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 che vengono avviati in caso di errore. | Numero intero |
| onFail | Un'azione da eseguire quando l'oggetto corrente ha esito negativo. | Oggetto di riferimento, ad esempio «onFail»: \$1"ref»:» myActionId «\$1 |
| onLateAction | Azioni che devono essere attivate se un oggetto non è stato ancora pianificato o non è ancora completo. | Oggetto di riferimento, ad esempio "onLateAction«: \$1" ref»:» myActionId «\$1 |
| onSuccess | Un'operazione da eseguire quando l'oggetto corrente ha esito positivo. | Oggetto di riferimento, ad esempio «onSuccess»: \$1"ref»:» myActionId «\$1 |
| parent | Padre dell'oggetto corrente da cui saranno ereditati gli slot. | Oggetto di riferimento, ad esempio «parent»: \$1"ref»:» myBaseObject Id "\$1 |
| preconditionTimeout | Il periodo dall'inizio dopo il quale la precondizione viene contrassegnata come non riuscita se ancora non è stata soddisfatta. | Periodo |
| reportProgressTimeout | Timeout per chiamate successive di attività in remoto a reportProgress. 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 consecutivi. | Periodo |
****
| Campi Runtime | Description | Tipo di slot |
| --- | --- | --- |
| @activeInstances | Elenco di oggetti di istanze attive attualmente programmate. | Oggetto di riferimento, ad esempio «activeInstances»: \$1"ref»:» myRunnableObject Id "\$1 |
| @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 | 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«: \$1" ref»:» myRunnableObject Id "\$1 |
| currentRetryCount | Numero di volte in cui la precondizione è stato provata in questo tentativo. | Stringa |
| emrStepLog | Log della fase EMR disponibili solo sui tentativi delle attività EMR | Stringa |
| errorId | ErrorId se l'oggetto non è riuscito. | Stringa |
| errorMessage | ErrorMessage se l'oggetto non è riuscito. | Stringa |
| errorStackTrace | Traccia dello stack di errore se l'oggetto non è riuscito. | Stringa |
| hadoopJobLog | Log delle attività Hadoop disponibili per le attività basate su EMR. | 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»: \$1"ref»:» myRunnableObject Id "\$1 |
| 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»: \$1"ref»:» myRunnableObject Id "\$1 |
****
| Campi di sistema | Description | 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
+ [ShellCommandPrecondition](dp-object-shellcommandprecondition.md)
# S3 PrefixNotEmpty
Una precondizione per verificare la presenza degli oggetti Amazon S3 con il prefisso specificato (rappresentato come URI).
## 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 | Description | 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 | Description | 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»: \$1"ref»:» myActionId «\$1 |
| onLateAction | Azioni che devono essere attivate se un oggetto non è stato ancora pianificato o non è ancora completo. | Oggetto di riferimento, ad esempio "onLateAction«: \$1" ref»:» myActionId «\$1 |
| onSuccess | Un'operazione da eseguire quando l'oggetto corrente ha esito positivo. | Oggetto di riferimento, ad esempio «onSuccess»: \$1"ref»:» myActionId «\$1 |
| parent | Padre dell'oggetto corrente da cui saranno ereditati gli slot. | Oggetto di riferimento, ad esempio «parent»: \$1"ref»:» myBaseObject Id "\$1 |
| preconditionTimeout | Il periodo dall'inizio dopo il quale la precondizione viene contrassegnata come non riuscita se ancora non è stata soddisfatta. | Periodo |
| reportProgressTimeout | Timeout per chiamate successive di attività in remoto a reportProgress. 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 | Description | Tipo di slot |
| --- | --- | --- |
| @activeInstances | Elenco di oggetti di istanze attive attualmente programmate. | Oggetto di riferimento, ad esempio «activeInstances»: \$1"ref»:» myRunnableObject Id "\$1 |
| @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 | 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«: \$1" ref»:» myRunnableObject Id "\$1 |
| currentRetryCount | Numero di volte in cui la precondizione è stato provata in questo tentativo. | Stringa |
| emrStepLog | Log della fase EMR disponibili solo sui tentativi delle attività EMR | Stringa |
| errorId | ErrorId se l'oggetto non è riuscito. | Stringa |
| errorMessage | ErrorMessage se l'oggetto non è riuscito. | Stringa |
| errorStackTrace | Traccia dello stack di errore se l'oggetto non è riuscito. | Stringa |
| hadoopJobLog | Log delle attività Hadoop disponibili per le attività basate su EMR. | 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»: \$1"ref»:» myRunnableObject Id "\$1 |
| 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»: \$1"ref»:» myRunnableObject Id "\$1 |
****
| Campi di sistema | Description | 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
+ [ShellCommandPrecondition](dp-object-shellcommandprecondition.md)
# ShellCommandPrecondition
Un comando di Unix/Linux shell che può essere eseguito come condizione preliminare.
## Esempio
Di seguito è illustrato un esempio di questo tipo di oggetto.
```
{
"id" : "VerifyDataReadiness",
"type" : "ShellCommandPrecondition",
"command" : "perl check-data-ready.pl"
}
```
## Sintassi
****
| Gruppo richiesto (uno dei seguenti è obbligatorio) | Description | Tipo di slot |
| --- | --- | --- |
| command | Il comando da eseguire. Questo valore ed eventuali parametri associati devono funzionare nell'ambiente da cui si sta eseguendo il Task Runner. | Stringa |
| scriptUri | Un percorso URI di Amazon S3 per un file da scaricare ed eseguire come comando shell. Deve essere presente solo uno scriptUri o un campo di comando. Se lo scriptUri non è in grado di utilizzare i parametri, utilizzare il comando. | Stringa |
****
| Campi opzionali | Description | 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 |
| failureAndRerunModo | 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»: \$1"ref»:» myActionId «\$1 |
| onLateAction | Azioni che devono essere attivate se un oggetto non è stato ancora pianificato o non è ancora completo. | Oggetto di riferimento, ad esempio "onLateAction«: \$1" ref»:» myActionId «\$1 |
| onSuccess | Un'operazione da eseguire quando l'oggetto corrente ha esito positivo. | Oggetto di riferimento, ad esempio «onSuccess»: \$1"ref»:» myActionId «\$1 |
| parent | Padre dell'oggetto corrente da cui saranno ereditati gli slot. | Oggetto di riferimento, ad esempio «parent»: \$1"ref»:» myBaseObject Id "\$1 |
| preconditionTimeout | Il periodo dall'inizio dopo il quale la precondizione viene contrassegnata come non riuscita se ancora non è stata soddisfatta. | Periodo |
| reportProgressTimeout | Timeout per chiamate successive di attività in remoto a reportProgress. 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 |
| scriptArgument | Argomento da passare allo script della shell | Stringa |
| stderr | Il percorso Amazon S3 che riceve i messaggi di errore di sistema reindirizzati dal comando. Se utilizzi il runsOn campo, deve trattarsi di un percorso Amazon S3 a causa della natura transitoria della risorsa che esegue la tua attività. Tuttavia, se specifichi il campo workerGroup, viene autorizzato un percorso file locale. | Stringa |
| stdout | Il percorso Amazon S3 che riceve l'output reindirizzato dal comando. Se utilizzi il runsOn campo, deve trattarsi di un percorso Amazon S3 a causa della natura transitoria della risorsa che esegue la tua attività. Tuttavia, se specifichi il campo workerGroup, viene autorizzato un percorso file locale. | Stringa |
****
| Campi Runtime | Description | Tipo di slot |
| --- | --- | --- |
| @activeInstances | Elenco di oggetti di istanze attive attualmente programmate. | Oggetto di riferimento, ad esempio «activeInstances»: \$1"ref»:» Id "\$1 myRunnableObject |
| @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 | 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«: \$1" ref»:» myRunnableObject Id "\$1 |
| emrStepLog | Log della fase EMR disponibili solo sui tentativi delle attività EMR | Stringa |
| errorId | ErrorId se l'oggetto non è riuscito. | Stringa |
| errorMessage | ErrorMessage se l'oggetto non è riuscito. | Stringa |
| errorStackTrace | Traccia dello stack di errore se l'oggetto non è riuscito. | Stringa |
| hadoopJobLog | Log delle attività Hadoop disponibili per le attività basate su EMR. | Stringa |
| hostname | Il nome host del client che si è aggiudicato il tentativo dell'attività. | Stringa |
| nodo | Il nodo per il quale viene eseguita questa precondizione | Oggetto di riferimento, ad esempio «node»: \$1"ref»:» myRunnableObject Id "\$1 |
| 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»: \$1"ref»:» myRunnableObject Id "\$1 |
****
| Campi di sistema | Description | 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
+ [ShellCommandActivity](dp-object-shellcommandactivity.md)
+ [Exists](dp-object-exists.md)