AWS Data Pipeline ist für Neukunden nicht mehr verfügbar. Bestandskunden von AWS Data Pipeline können den Service weiterhin wie gewohnt nutzen. [Weitere Informationen](https://aws.amazon.com/blogs/big-data/migrate-workloads-from-aws-data-pipeline/)
Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
# Vorbedingungen
Im Folgenden sind die AWS Data Pipeline Vorbedingungsobjekte aufgeführt:
**Topics**
+ [Dynamo DBData ist vorhanden](dp-dynamodbdataexists.md)
+ [Dynamo ist vorhanden DBTable](dp-dynamodbtableexists.md)
+ [Vorhanden](dp-object-exists.md)
+ [S3 KeyExists](dp-object-S3KeyExists.md)
+ [S3 PrefixNotEmpty](dp-object-s3prefixnotempty.md)
+ [ShellCommandPrecondition](dp-object-shellcommandprecondition.md)
# Dynamo DBData ist vorhanden
Eine Vorbedingung, um zu überprüfen, ob Daten in einer DynamoDB-Tabelle vorhanden sind.
## Syntax
****
| Pflichtfelder | Description | Slot-Typ |
| --- | --- | --- |
| role | Legt die Rolle für die Ausführung der Vorbedingung fest. | Zeichenfolge |
| tableName | Die zu prüfende DynamoDB-Tabelle. | Zeichenfolge |
****
| Optionale Felder | Description | Slot-Typ |
| --- | --- | --- |
| attemptStatus | Zuletzt gemeldeter Status von der Remote-Aktivität. | Zeichenfolge |
| attemptTimeout | Timeout für die Remote-Arbeit abgeschlossen. Wenn diese Option aktiviert ist, kann eine Remote-Aktivität, die nicht innerhalb der festgelegten Startzeit abgeschlossen wird, wiederholt werden. | Zeitraum |
| failureAndRerunModus | Beschreibt das Verhalten des Konsumentenknotens, wenn Abhängigkeiten fehlschlagen oder erneut ausgeführt werden | Aufzählung |
| lateAfterTimeout | Die nach dem Start der Pipeline verstrichene Zeit, innerhalb der das Objekt abgeschlossen werden muss. Sie wird nur ausgelöst, wenn der Zeitplantyp nicht auf eingestellt ist. ondemand | Zeitraum |
| maximumRetries | Maximale Anzahl von Versuchen bei Ausfällen | Ganzzahl |
| onFail | Eine Aktion, die ausgeführt werden soll, wenn das aktuelle Objekt fehlschlägt. | Referenzobjekt, z. B. „onFail“: \$1"ref“:“ myActionId „\$1 |
| onLateAction | Aktionen, die ausgelöst werden sollen, wenn ein Objekt noch nicht geplant oder noch nicht abgeschlossen wurde. | Referenzobjekt, z. B. "onLateAction„: \$1" ref“:“ myActionId „\$1 |
| onSuccess | Eine Aktion, die ausgeführt wird, wenn das aktuelle Objekt erfolgreich ist. | Referenzobjekt, z. B. „onSuccess“: \$1"ref“:“ myActionId „\$1 |
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, z. B. „parent“: \$1"ref“:“ myBaseObject Id "\$1 |
| preconditionTimeout | Der Zeitraum ab dem die Vorbedingung als fehlgeschlagen gekennzeichnet ist, wenn sie noch nicht erfüllt ist | Zeitraum |
| reportProgressTimeout | Timeout für aufeinanderfolgende Aufrufe von Remote-Arbeit in reportProgress. Wenn diese Option aktiviert ist, werden Remote-Aktivitäten, die den Fortschritt für den angegebenen Zeitraum nicht melden, als fehlgeschlagen angesehen und es wird erneut versucht. | Zeitraum |
| retryDelay | Die Zeitüberschreitungsdauer zwischen zwei Wiederholungsversuchen. | Zeitraum |
****
| Laufzeitfelder | Description | Slot-Typ |
| --- | --- | --- |
| @activeInstances | Liste der aktuell geplanten aktiven Instance-Objekte. | Referenzobjekt, z. B. „activeInstances“: \$1"ref“:“ myRunnableObject Id "\$1 |
| @actualEndTime | Zeitpunkt, zu dem die Ausführung dieses Objekts abgeschlossen wurde. | DateTime |
| @actualStartTime | Zeitpunkt, zu dem die Ausführung dieses Objekts gestartet wurde. | DateTime |
| cancellationReason | Die cancellationReason, wenn dieses Objekt storniert wurde. | Zeichenfolge |
| @cascadeFailedOn | Beschreibung der Zuständigkeitskette, bei der das Objekt fehlgeschlagen ist. | Referenzobjekt, z. B. "cascadeFailedOn„: \$1" ref“:“ myRunnableObject Id "\$1 |
| currentRetryCount | Anzahl, wie oft die Vorbedingung in diesem Versuch probiert wurde. | Zeichenfolge |
| emrStepLog | EMR-Schrittprotokolle nur bei EMR-Aktivitätsversuchen verfügbar | Zeichenfolge |
| errorId | Die errorId, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorMessage | Die errorMessage, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorStackTrace | Die Fehler-Stack-Ablaufverfolgung., wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| hadoopJobLog | Hadoop-Jobprotokolle für Versuche für EMR-basierte Aktivitäten verfügbar. | Zeichenfolge |
| hostname | Der Hostname des Clients, der den Aufgabenversuch aufnimmt. | Zeichenfolge |
| lastRetryTime | Das letzte Mal, dass die Vorbedingung in diesem Versuch probiert wurde. | Zeichenfolge |
| node | Der Knoten, für den diese Vorbedingung ausgeführt wird | Referenzobjekt, z. B. „node“: \$1"ref“:“ myRunnableObject Id "\$1 |
| reportProgressTime | Der letzte Zeitpunkt, an dem die Remote-Aktivität einen Fortschritt gemeldet hat. | DateTime |
| @scheduledEndTime | Endzeit für Objekt einplanen. | DateTime |
| @scheduledStartTime | Startzeit für Objekt einplanen. | DateTime |
| @Status | Der Status des Objekts. | Zeichenfolge |
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde. | Zeichenfolge |
| @waitingOn | Beschreibung der Liste der Abhängigkeiten, auf die dieses Objekt wartet. | Referenzobjekt, z. B. „WaitingOn“: \$1"ref“:“ myRunnableObject Id "\$1 |
****
| Systemfelder | Description | Slot-Typ |
| --- | --- | --- |
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts. | Zeichenfolge |
| @pipelineId | ID der Pipeline, zu der dieses Objekt gehört | Zeichenfolge |
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen. | Zeichenfolge |
# Dynamo ist vorhanden DBTable
Eine Vorbedingung, um zu überprüfen, ob die DynamoDB-Tabelle existiert.
## Syntax
****
| Pflichtfelder | Description | Slot-Typ |
| --- | --- | --- |
| role | Legt die Rolle für die Ausführung der Vorbedingung fest. | Zeichenfolge |
| tableName | Die zu prüfende DynamoDB-Tabelle. | Zeichenfolge |
****
| Optionale Felder | Description | Slot-Typ |
| --- | --- | --- |
| attemptStatus | Zuletzt gemeldeter Status von der Remote-Aktivität. | Zeichenfolge |
| attemptTimeout | Timeout für die Remote-Arbeit abgeschlossen. Wenn diese Option aktiviert ist, kann eine Remote-Aktivität, die nicht innerhalb der festgelegten Startzeit abgeschlossen wird, wiederholt werden. | Zeitraum |
| failureAndRerunModus | Beschreibt das Verhalten des Konsumentenknotens, wenn Abhängigkeiten fehlschlagen oder erneut ausgeführt werden | Aufzählung |
| lateAfterTimeout | Die nach dem Start der Pipeline verstrichene Zeit, innerhalb der das Objekt abgeschlossen werden muss. Sie wird nur ausgelöst, wenn der Zeitplantyp nicht auf eingestellt ist. ondemand | Zeitraum |
| maximumRetries | Maximale Anzahl von Versuchen bei Ausfällen | Ganzzahl |
| onFail | Eine Aktion, die ausgeführt werden soll, wenn das aktuelle Objekt fehlschlägt. | Referenzobjekt, z. B. „onFail“: \$1"ref“:“ myActionId „\$1 |
| onLateAction | Aktionen, die ausgelöst werden sollen, wenn ein Objekt noch nicht geplant oder noch nicht abgeschlossen wurde. | Referenzobjekt, z. B. "onLateAction„: \$1" ref“:“ myActionId „\$1 |
| onSuccess | Eine Aktion, die ausgeführt wird, wenn das aktuelle Objekt erfolgreich ist. | Referenzobjekt, z. B. „onSuccess“: \$1"ref“:“ myActionId „\$1 |
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, z. B. „parent“: \$1"ref“:“ myBaseObject Id "\$1 |
| preconditionTimeout | Der Zeitraum ab dem die Vorbedingung als fehlgeschlagen gekennzeichnet ist, wenn sie noch nicht erfüllt ist | Zeitraum |
| reportProgressTimeout | Timeout für aufeinanderfolgende Aufrufe von Remote-Arbeit in reportProgress. Wenn diese Option aktiviert ist, werden Remote-Aktivitäten, die den Fortschritt für den angegebenen Zeitraum nicht melden, als fehlgeschlagen angesehen und es wird erneut versucht. | Zeitraum |
| retryDelay | Die Zeitüberschreitungsdauer zwischen zwei Wiederholungsversuchen. | Zeitraum |
****
| Laufzeitfelder | Description | Slot-Typ |
| --- | --- | --- |
| @activeInstances | Liste der aktuell geplanten aktiven Instance-Objekte. | Referenzobjekt, z. B. „activeInstances“: \$1"ref“:“ myRunnableObject Id "\$1 |
| @actualEndTime | Zeitpunkt, zu dem die Ausführung dieses Objekts abgeschlossen wurde. | DateTime |
| @actualStartTime | Zeitpunkt, zu dem die Ausführung dieses Objekts gestartet wurde. | DateTime |
| cancellationReason | Die cancellationReason, wenn dieses Objekt storniert wurde. | Zeichenfolge |
| @cascadeFailedOn | Beschreibung der Zuständigkeitskette, bei der das Objekt fehlgeschlagen ist. | Referenzobjekt, z. B. "cascadeFailedOn„: \$1" ref“:“ myRunnableObject Id "\$1 |
| currentRetryCount | Anzahl, wie oft die Vorbedingung in diesem Versuch probiert wurde. | Zeichenfolge |
| emrStepLog | EMR-Schrittprotokolle nur bei EMR-Aktivitätsversuchen verfügbar | Zeichenfolge |
| errorId | Die errorId, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorMessage | Die errorMessage, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorStackTrace | Die Fehler-Stack-Ablaufverfolgung., wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| hadoopJobLog | Hadoop-Jobprotokolle für Versuche für EMR-basierte Aktivitäten verfügbar. | Zeichenfolge |
| hostname | Der Hostname des Clients, der den Aufgabenversuch aufnimmt. | Zeichenfolge |
| lastRetryTime | Das letzte Mal, dass die Vorbedingung in diesem Versuch probiert wurde. | Zeichenfolge |
| node | Der Knoten, für den diese Vorbedingung ausgeführt wird | Referenzobjekt, z. B. „node“: \$1"ref“:“ myRunnableObject Id "\$1 |
| reportProgressTime | Der letzte Zeitpunkt, an dem die Remote-Aktivität einen Fortschritt gemeldet hat. | DateTime |
| @scheduledEndTime | Endzeit für Objekt einplanen | DateTime |
| @scheduledStartTime | Startzeit für Objekt einplanen | DateTime |
| @Status | Der Status des Objekts. | Zeichenfolge |
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde. | Zeichenfolge |
| @waitingOn | Beschreibung der Liste der Abhängigkeiten, auf die dieses Objekt wartet. | Referenzobjekt, z. B. „WaitingOn“: \$1"ref“:“ myRunnableObject Id "\$1 |
****
| Systemfelder | Description | Slot-Typ |
| --- | --- | --- |
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts | Zeichenfolge |
| @pipelineId | Id der Pipeline, zu der dieses Objekt gehört | Zeichenfolge |
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen | Zeichenfolge |
# Vorhanden
Prüft, ob eine Datenknotenobjekt vorhanden ist.
**Anmerkung**
Wir empfehlen, stattdessen die vom System verwalteten Vorbedingungen zu verwenden. Weitere Informationen finden Sie unter [Vorbedingungen](dp-concepts-preconditions.md).
## Beispiel
Es folgt ein Beispiel für diesen Objekttyp. Das `InputData`-Objekt verweist auf dieses Objekt, `Ready`, und auf ein anderes Objekt, das Sie in derselben Pipeline-Definitionsdatei definieren. `CopyPeriod` ist ein `Schedule`-Objekt.
```
{
"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"
}
```
## Syntax
****
| Optionale Felder | Description | Slot-Typ |
| --- | --- | --- |
| attemptStatus | Zuletzt gemeldeter Status von der Remote-Aktivität. | Zeichenfolge |
| attemptTimeout | Timeout für die Remote-Arbeit abgeschlossen. Wenn diese Option aktiviert ist, kann eine Remote-Aktivität, die nicht innerhalb der festgelegten Startzeit abgeschlossen wird, wiederholt werden. | Zeitraum |
| failureAndRerunModus | Beschreibt das Verhalten des Konsumentenknotens, wenn Abhängigkeiten fehlschlagen oder erneut ausgeführt werden. | Aufzählung |
| lateAfterTimeout | Die nach dem Start der Pipeline verstrichene Zeit, innerhalb der das Objekt abgeschlossen werden muss. Sie wird nur ausgelöst, wenn der Zeitplantyp nicht auf eingestellt ist. ondemand | Zeitraum |
| maximumRetries | Maximale Anzahl von Versuchen bei Ausfällen | Ganzzahl |
| onFail | Eine Aktion, die ausgeführt werden soll, wenn das aktuelle Objekt fehlschlägt. | Referenzobjekt, z. B. „onFail“: \$1"ref“:“ myActionId „\$1 |
| onLateAction | Aktionen, die ausgelöst werden sollen, wenn ein Objekt noch nicht geplant oder noch nicht abgeschlossen wurde. | Referenzobjekt, z. B. "onLateAction„: \$1" ref“:“ myActionId „\$1 |
| onSuccess | Eine Aktion, die ausgeführt wird, wenn das aktuelle Objekt erfolgreich ist. | Referenzobjekt, z. B. „onSuccess“: \$1"ref“:“ myActionId „\$1 |
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, z. B. „parent“: \$1"ref“:“ myBaseObject Id "\$1 |
| preconditionTimeout | Der Zeitraum ab dem die Vorbedingung als fehlgeschlagen gekennzeichnet ist, wenn sie noch nicht erfüllt ist | Zeitraum |
| reportProgressTimeout | Timeout für aufeinanderfolgende Aufrufe von Remote-Arbeit in reportProgress. Wenn diese Option aktiviert ist, werden Remote-Aktivitäten, die den Fortschritt für den angegebenen Zeitraum nicht melden, als fehlgeschlagen angesehen und es wird erneut versucht. | Zeitraum |
| retryDelay | Die Zeitüberschreitungsdauer zwischen zwei Wiederholungsversuchen. | Zeitraum |
****
| Laufzeitfelder | Description | Slot-Typ |
| --- | --- | --- |
| @activeInstances | Liste der aktuell geplanten aktiven Instance-Objekte. | Referenzobjekt, z. B. „activeInstances“: \$1"ref“:“ myRunnableObject Id "\$1 |
| @actualEndTime | Zeitpunkt, zu dem die Ausführung dieses Objekts abgeschlossen wurde. | DateTime |
| @actualStartTime | Zeitpunkt, zu dem die Ausführung dieses Objekts gestartet wurde. | DateTime |
| cancellationReason | Die cancellationReason, wenn dieses Objekt storniert wurde. | Zeichenfolge |
| @cascadeFailedOn | Beschreibung der Abhängigkeitskette, bei der das Objekt fehlgeschlagen ist. | Referenzobjekt, z. B. "cascadeFailedOn„: \$1" ref“:“ myRunnableObject Id "\$1 |
| emrStepLog | EMR-Schrittprotokolle nur bei EMR-Aktivitätsversuchen verfügbar | Zeichenfolge |
| errorId | Die errorId, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorMessage | Die errorMessage, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorStackTrace | Die Fehler-Stack-Ablaufverfolgung., wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| hadoopJobLog | Hadoop-Jobprotokolle für Versuche für EMR-basierte Aktivitäten verfügbar. | Zeichenfolge |
| hostname | Der Hostname des Clients, der den Aufgabenversuch aufnimmt. | Zeichenfolge |
| node | Der Knoten, für den diese Vorbedingung ausgeführt wird. | Referenzobjekt, z. B. „node“: \$1"ref“:“ myRunnableObject Id "\$1 |
| reportProgressTime | Der letzte Zeitpunkt, an dem die Remote-Aktivität einen Fortschritt gemeldet hat. | DateTime |
| @scheduledEndTime | Endzeit für Objekt einplanen. | DateTime |
| @scheduledStartTime | Startzeit für Objekt einplanen. | DateTime |
| @Status | Der Status des Objekts. | Zeichenfolge |
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde. | Zeichenfolge |
| @waitingOn | Beschreibung der Liste der Abhängigkeiten, auf die dieses Objekt wartet. | Referenzobjekt, z. B. „WaitingOn“: \$1"ref“:“ myRunnableObject Id "\$1 |
****
| Systemfelder | Description | Slot-Typ |
| --- | --- | --- |
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts. | Zeichenfolge |
| @pipelineId | Id der Pipeline, zu der dieses Objekt gehört. | Zeichenfolge |
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen. | Zeichenfolge |
## Weitere Informationen finden Sie unter:
+ [ShellCommandPrecondition](dp-object-shellcommandprecondition.md)
# S3 KeyExists
Prüft, ob ein Schlüssel in einem Amazon S3-Datenknoten vorhanden ist.
## Beispiel
Es folgt ein Beispiel für diesen Objekttyp. Die Vorbedingung wird ausgelöst, wenn der Schlüssel, `s3://amzn-s3-demo-bucket/mykey`, auf den der `s3Key`-Parameter verweist, vorhanden ist.
```
{
"id" : "InputReady",
"type" : "S3KeyExists",
"role" : "test-role",
"s3Key" : "s3://amzn-s3-demo-bucket/mykey"
}
```
Sie können `S3KeyExists` auch als Voraussetzung für die zweite Pipeline verwenden, die darauf wartet, dass die erste Pipeline abgeschlossen wird. Gehen Sie hierzu wie folgt vor:
1. Schreiben Sie am Ende der Fertigstellung der ersten Pipeline eine Datei in Amazon S3.
1. Erstellen Sie eine `S3KeyExists`-Vorbedingung für die zweite Pipeline.
## Syntax
****
| Pflichtfelder | Description | Slot-Typ |
| --- | --- | --- |
| role | Legt die Rolle für die Ausführung der Vorbedingung fest. | Zeichenfolge |
| s3Key | Der Amazon S3 S3-Schlüssel. | Zeichenfolge |
****
| Optionale Felder | Description | Slot-Typ |
| --- | --- | --- |
| attemptStatus | Zuletzt gemeldeter Status von der Remote-Aktivität. | Zeichenfolge |
| attemptTimeout | Timeout vor dem Versuch, die Remote-Arbeit noch einmal auszuführen. Wenn diese Option aktiviert ist, wird erneut versucht, eine Remote-Aktivität durchzuführen, die nach dem Start nicht innerhalb der festgelegten Zeit abgeschlossen wird. | Zeitraum |
| failureAndRerunModus | Beschreibt das Verhalten des Konsumentenknotens, wenn Abhängigkeiten fehlschlagen oder erneut ausgeführt werden. | Aufzählung |
| lateAfterTimeout | Die nach dem Start der Pipeline verstrichene Zeit, innerhalb der das Objekt abgeschlossen werden muss. Sie wird nur ausgelöst, wenn der Zeitplantyp nicht auf eingestellt ist. ondemand | Zeitraum |
| maximumRetries | Maximale Anzahl der Versuche, die bei einem Fehler initiiert werden. | Ganzzahl |
| onFail | Eine Aktion, die ausgeführt werden soll, wenn das aktuelle Objekt fehlschlägt. | Referenzobjekt, z. B. „onFail“: \$1"ref“:“ myActionId „\$1 |
| onLateAction | Aktionen, die ausgelöst werden sollen, wenn ein Objekt noch nicht geplant oder noch nicht abgeschlossen wurde. | Referenzobjekt, z. B. "onLateAction„: \$1" ref“:“ myActionId „\$1 |
| onSuccess | Eine Aktion, die ausgeführt wird, wenn das aktuelle Objekt erfolgreich ist. | Referenzobjekt, z. B. „onSuccess“: \$1"ref“:“ myActionId „\$1 |
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, z. B. „parent“: \$1"ref“:“ myBaseObject Id "\$1 |
| preconditionTimeout | Der Zeitraum ab dem die Vorbedingung als fehlgeschlagen gekennzeichnet ist, wenn sie noch nicht erfüllt ist. | Zeitraum |
| reportProgressTimeout | Timeout für aufeinanderfolgende Aufrufe von Remote-Arbeit in reportProgress. Wenn diese Option aktiviert ist, werden Remote-Aktivitäten, die den Fortschritt für den angegebenen Zeitraum nicht melden, als fehlgeschlagen angesehen und es wird erneut versucht. | Zeitraum |
| retryDelay | Die Zeitüberschreitungsdauer zwischen zwei aufeinander folgenden Versuchen. | Zeitraum |
****
| Laufzeitfelder | Description | Slot-Typ |
| --- | --- | --- |
| @activeInstances | Liste der aktuell geplanten aktiven Instance-Objekte. | Referenzobjekt, z. B. „activeInstances“: \$1"ref“:“ myRunnableObject Id "\$1 |
| @actualEndTime | Zeitpunkt, zu dem die Ausführung dieses Objekts abgeschlossen wurde. | DateTime |
| @actualStartTime | Zeitpunkt, zu dem die Ausführung dieses Objekts gestartet wurde. | DateTime |
| cancellationReason | Die cancellationReason, wenn dieses Objekt storniert wurde. | Zeichenfolge |
| @cascadeFailedOn | Beschreibung der Abhängigkeitskette, bei der das Objekt fehlgeschlagen ist. | Referenzobjekt, z. B. "cascadeFailedOn„: \$1" ref“:“ myRunnableObject Id "\$1 |
| currentRetryCount | Anzahl, wie oft die Vorbedingung in diesem Versuch probiert wurde. | Zeichenfolge |
| emrStepLog | EMR-Schrittprotokolle nur bei EMR-Aktivitätsversuchen verfügbar | Zeichenfolge |
| errorId | Die errorId, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorMessage | Die errorMessage, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorStackTrace | Die Fehler-Stack-Ablaufverfolgung., wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| hadoopJobLog | Hadoop-Jobprotokolle für Versuche für EMR-basierte Aktivitäten verfügbar. | Zeichenfolge |
| hostname | Der Hostname des Clients, der den Aufgabenversuch aufnimmt. | Zeichenfolge |
| lastRetryTime | Das letzte Mal, dass die Vorbedingung in diesem Versuch probiert wurde. | Zeichenfolge |
| node | Der Knoten, für den diese Vorbedingung ausgeführt wird | Referenzobjekt, z. B. „node“: \$1"ref“:“ myRunnableObject Id "\$1 |
| reportProgressTime | Der letzte Zeitpunkt, an dem die Remote-Aktivität einen Fortschritt gemeldet hat. | DateTime |
| @scheduledEndTime | Endzeit für Objekt einplanen | DateTime |
| @scheduledStartTime | Startzeit für Objekt einplanen | DateTime |
| @Status | Der Status des Objekts. | Zeichenfolge |
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde. | Zeichenfolge |
| @waitingOn | Beschreibung der Liste der Abhängigkeiten, auf die dieses Objekt wartet. | Referenzobjekt, z. B. „WaitingOn“: \$1"ref“:“ myRunnableObject Id "\$1 |
****
| Systemfelder | Description | Slot-Typ |
| --- | --- | --- |
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts | Zeichenfolge |
| @pipelineId | Id der Pipeline, zu der dieses Objekt gehört | Zeichenfolge |
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen | Zeichenfolge |
## Weitere Informationen finden Sie unter:
+ [ShellCommandPrecondition](dp-object-shellcommandprecondition.md)
# S3 PrefixNotEmpty
Eine Voraussetzung, um zu überprüfen, ob die Amazon S3 S3-Objekte mit dem angegebenen Präfix (dargestellt als URI) vorhanden sind.
## Beispiel
Es folgt ein Beispiel für die Verwendung dieses Objekttyps mit erforderlichen, optionalen und Ausdrucksfeldern.
```
{
"id" : "InputReady",
"type" : "S3PrefixNotEmpty",
"role" : "test-role",
"s3Prefix" : "#{node.filePath}"
}
```
## Syntax
****
| Pflichtfelder | Description | Slot-Typ |
| --- | --- | --- |
| role | Legt die Rolle für die Ausführung der Vorbedingung fest. | Zeichenfolge |
| s3Prefix | Das Amazon S3 S3-Präfix zur Überprüfung der Existenz von Objekten. | Zeichenfolge |
****
| Optionale Felder | Description | Slot-Typ |
| --- | --- | --- |
| attemptStatus | Zuletzt gemeldeter Status von der Remote-Aktivität. | Zeichenfolge |
| attemptTimeout | Timeout für die Remote-Arbeit abgeschlossen. Wenn diese Option aktiviert ist, kann eine Remote-Aktivität, die nicht innerhalb der festgelegten Startzeit abgeschlossen wird, wiederholt werden. | Zeitraum |
| failureAndRerunModus | Beschreibt das Verhalten des Konsumentenknotens, wenn Abhängigkeiten fehlschlagen oder erneut ausgeführt werden | Aufzählung |
| lateAfterTimeout | Die nach dem Start der Pipeline verstrichene Zeit, innerhalb der das Objekt abgeschlossen werden muss. Sie wird nur ausgelöst, wenn der Zeitplantyp nicht auf eingestellt ist. ondemand | Zeitraum |
| maximumRetries | Maximale Anzahl von Versuchen bei Ausfällen | Ganzzahl |
| onFail | Eine Aktion, die ausgeführt werden soll, wenn das aktuelle Objekt fehlschlägt. | Referenzobjekt, z. B. „onFail“: \$1"ref“:“ myActionId „\$1 |
| onLateAction | Aktionen, die ausgelöst werden sollen, wenn ein Objekt noch nicht geplant oder noch nicht abgeschlossen wurde. | Referenzobjekt, z. B. "onLateAction„: \$1" ref“:“ myActionId „\$1 |
| onSuccess | Eine Aktion, die ausgeführt wird, wenn das aktuelle Objekt erfolgreich ist. | Referenzobjekt, z. B. „onSuccess“: \$1"ref“:“ myActionId „\$1 |
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, z. B. „parent“: \$1"ref“:“ myBaseObject Id "\$1 |
| preconditionTimeout | Der Zeitraum ab dem die Vorbedingung als fehlgeschlagen gekennzeichnet ist, wenn sie noch nicht erfüllt ist | Zeitraum |
| reportProgressTimeout | Timeout für aufeinanderfolgende Aufrufe von Remote-Arbeit in reportProgress. Wenn diese Option aktiviert ist, werden Remote-Aktivitäten, die den Fortschritt für den angegebenen Zeitraum nicht melden, als fehlgeschlagen angesehen und es wird erneut versucht. | Zeitraum |
| retryDelay | Die Zeitüberschreitungsdauer zwischen zwei Wiederholungsversuchen. | Zeitraum |
****
| Laufzeitfelder | Description | Slot-Typ |
| --- | --- | --- |
| @activeInstances | Liste der aktuell geplanten aktiven Instance-Objekte. | Referenzobjekt, z. B. „activeInstances“: \$1"ref“:“ myRunnableObject Id "\$1 |
| @actualEndTime | Zeitpunkt, zu dem die Ausführung dieses Objekts abgeschlossen wurde. | DateTime |
| @actualStartTime | Zeitpunkt, zu dem die Ausführung dieses Objekts gestartet wurde. | DateTime |
| cancellationReason | Die cancellationReason, wenn dieses Objekt storniert wurde. | Zeichenfolge |
| @cascadeFailedOn | Beschreibung der Abhängigkeitskette, bei der das Objekt fehlgeschlagen ist. | Referenzobjekt, z. B. "cascadeFailedOn„: \$1" ref“:“ myRunnableObject Id "\$1 |
| currentRetryCount | Anzahl, wie oft die Vorbedingung in diesem Versuch probiert wurde. | Zeichenfolge |
| emrStepLog | EMR-Schrittprotokolle nur bei EMR-Aktivitätsversuchen verfügbar | Zeichenfolge |
| errorId | Die errorId, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorMessage | Die errorMessage, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorStackTrace | Die Fehler-Stack-Ablaufverfolgung., wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| hadoopJobLog | Hadoop-Jobprotokolle für Versuche für EMR-basierte Aktivitäten verfügbar. | Zeichenfolge |
| hostname | Der Hostname des Clients, der den Aufgabenversuch aufnimmt. | Zeichenfolge |
| lastRetryTime | Das letzte Mal, dass die Vorbedingung in diesem Versuch probiert wurde. | Zeichenfolge |
| node | Der Knoten, für den diese Vorbedingung ausgeführt wird. | Referenzobjekt, z. B. „node“: \$1"ref“:“ myRunnableObject Id "\$1 |
| reportProgressTime | Der letzte Zeitpunkt, an dem die Remote-Aktivität einen Fortschritt gemeldet hat. | DateTime |
| @scheduledEndTime | Endzeit für Objekt einplanen. | DateTime |
| @scheduledStartTime | Startzeit für Objekt einplanen. | DateTime |
| @Status | Der Status des Objekts. | Zeichenfolge |
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde. | Zeichenfolge |
| @waitingOn | Beschreibung der Liste der Abhängigkeiten, auf die dieses Objekt wartet. | Referenzobjekt, z. B. „WaitingOn“: \$1"ref“:“ myRunnableObject Id "\$1 |
****
| Systemfelder | Description | Slot-Typ |
| --- | --- | --- |
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts | Zeichenfolge |
| @pipelineId | Id der Pipeline, zu der dieses Objekt gehört | Zeichenfolge |
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen | Zeichenfolge |
## Weitere Informationen finden Sie unter:
+ [ShellCommandPrecondition](dp-object-shellcommandprecondition.md)
# ShellCommandPrecondition
Ein Unix/Linux Shell-Befehl, der als Vorbedingung ausgeführt werden kann.
## Beispiel
Es folgt ein Beispiel für diesen Objekttyp.
```
{
"id" : "VerifyDataReadiness",
"type" : "ShellCommandPrecondition",
"command" : "perl check-data-ready.pl"
}
```
## Syntax
****
| Erforderliche Gruppe (mindestens eine der folgenden ist erforderlich) | Description | Slot-Typ |
| --- | --- | --- |
| command | Den auszuführenden Befehl. Dieser Wert und alle zugehörigen Parameter müssen in der Umgebung funktionieren, in der Sie den Task-Runner ausführen. | Zeichenfolge |
| scriptUri | Ein Amazon S3-URI-Pfad für eine Datei, die heruntergeladen und als Shell-Befehl ausgeführt werden soll. Nur das Feld scriptUri oder das Befehlsfeld sollten vorhanden sein. scriptUri kann keine Parameter verwenden. Verwenden Sie stattdessen das Befehlsfeld. | Zeichenfolge |
****
| Optionale Felder | Description | Slot-Typ |
| --- | --- | --- |
| attemptStatus | Zuletzt gemeldeter Status von der Remote-Aktivität. | Zeichenfolge |
| attemptTimeout | Timeout für die Remote-Arbeit abgeschlossen. Wenn diese Option aktiviert ist, kann eine Remote-Aktivität, die nicht innerhalb der festgelegten Startzeit abgeschlossen wird, wiederholt werden. | Zeitraum |
| failureAndRerunModus | Beschreibt das Verhalten des Konsumentenknotens, wenn Abhängigkeiten fehlschlagen oder erneut ausgeführt werden | Aufzählung |
| lateAfterTimeout | Die nach dem Start der Pipeline verstrichene Zeit, innerhalb der das Objekt abgeschlossen werden muss. Sie wird nur ausgelöst, wenn der Zeitplantyp nicht auf eingestellt ist. ondemand | Zeitraum |
| maximumRetries | Maximale Anzahl von Versuchen bei Ausfällen | Ganzzahl |
| onFail | Eine Aktion, die ausgeführt werden soll, wenn das aktuelle Objekt fehlschlägt. | Referenzobjekt, z. B. „onFail“: \$1"ref“:“ myActionId „\$1 |
| onLateAction | Aktionen, die ausgelöst werden sollen, wenn ein Objekt noch nicht geplant oder noch nicht abgeschlossen wurde. | Referenzobjekt, z. B. "onLateAction„: \$1" ref“:“ myActionId „\$1 |
| onSuccess | Eine Aktion, die ausgeführt wird, wenn das aktuelle Objekt erfolgreich ist. | Referenzobjekt, z. B. „onSuccess“: \$1"ref“:“ myActionId „\$1 |
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, z. B. „parent“: \$1"ref“:“ myBaseObject Id "\$1 |
| preconditionTimeout | Der Zeitraum ab dem die Vorbedingung als fehlgeschlagen gekennzeichnet ist, wenn sie noch nicht erfüllt ist | Zeitraum |
| reportProgressTimeout | Timeout für aufeinanderfolgende Aufrufe von Remote-Arbeit in reportProgress. Wenn diese Option aktiviert ist, werden Remote-Aktivitäten, die den Fortschritt für den angegebenen Zeitraum nicht melden, als fehlgeschlagen angesehen und es wird erneut versucht. | Zeitraum |
| retryDelay | Die Zeitüberschreitungsdauer zwischen zwei Wiederholungsversuchen. | Zeitraum |
| scriptArgument | Argument, das an ein Shell-Skript übergeben werden soll | Zeichenfolge |
| stderr | Der Amazon S3 S3-Pfad, der umgeleitete Systemfehlermeldungen vom Befehl empfängt. Wenn Sie das runsOn Feld verwenden, muss es sich um einen Amazon S3 S3-Pfad handeln, da die Ressource, auf der Ihre Aktivität ausgeführt wird, vorübergehend ist. Wenn Sie jedoch das Feld workerGroup angeben, ist ein lokaler Dateipfad zulässig. | Zeichenfolge |
| stdout | Der Amazon S3 S3-Pfad, der die umgeleitete Ausgabe des Befehls empfängt. Wenn Sie das runsOn Feld verwenden, muss es sich um einen Amazon S3 S3-Pfad handeln, da die Ressource, auf der Ihre Aktivität ausgeführt wird, vorübergehend ist. Wenn Sie jedoch das Feld workerGroup angeben, ist ein lokaler Dateipfad zulässig. | Zeichenfolge |
****
| Laufzeitfelder | Description | Slot-Typ |
| --- | --- | --- |
| @activeInstances | Liste der aktuell geplanten aktiven Instance-Objekte. | Referenzobjekt, z. B. „activeInstances“: \$1"ref“:“ Id "\$1 myRunnableObject |
| @actualEndTime | Zeitpunkt, zu dem die Ausführung dieses Objekts abgeschlossen wurde. | DateTime |
| @actualStartTime | Zeitpunkt, zu dem die Ausführung dieses Objekts gestartet wurde. | DateTime |
| cancellationReason | Die cancellationReason, wenn dieses Objekt storniert wurde. | Zeichenfolge |
| @cascadeFailedOn | Beschreibung der Abhängigkeitskette, bei der das Objekt fehlgeschlagen ist. | Referenzobjekt, z. B. "cascadeFailedOn„: \$1" ref“:“ myRunnableObject Id "\$1 |
| emrStepLog | EMR-Schrittprotokolle nur bei EMR-Aktivitätsversuchen verfügbar | Zeichenfolge |
| errorId | Die errorId, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorMessage | Die errorMessage, wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| errorStackTrace | Die Fehler-Stack-Ablaufverfolgung., wenn dieses Objekt fehlgeschlagen ist. | Zeichenfolge |
| hadoopJobLog | Hadoop-Jobprotokolle für Versuche für EMR-basierte Aktivitäten verfügbar. | Zeichenfolge |
| hostname | Der Hostname des Clients, der den Aufgabenversuch aufnimmt. | Zeichenfolge |
| node | Der Knoten, für den diese Vorbedingung ausgeführt wird | Referenzobjekt, z. B. „node“: \$1"ref“:“ myRunnableObject Id "\$1 |
| reportProgressTime | Der letzte Zeitpunkt, an dem die Remote-Aktivität einen Fortschritt gemeldet hat. | DateTime |
| @scheduledEndTime | Endzeit für Objekt einplanen | DateTime |
| @scheduledStartTime | Startzeit für Objekt einplanen | DateTime |
| @Status | Der Status des Objekts. | Zeichenfolge |
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde. | Zeichenfolge |
| @waitingOn | Beschreibung der Liste der Abhängigkeiten, auf die dieses Objekt wartet. | Referenzobjekt, z. B. „WaitingOn“: \$1"ref“:“ myRunnableObject Id "\$1 |
****
| Systemfelder | Description | Slot-Typ |
| --- | --- | --- |
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts | Zeichenfolge |
| @pipelineId | Id der Pipeline, zu der dieses Objekt gehört | Zeichenfolge |
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen | Zeichenfolge |
## Weitere Informationen finden Sie unter:
+ [ShellCommandActivity](dp-object-shellcommandactivity.md)
+ [Vorhanden](dp-object-exists.md)