AWS Data Pipeline ist für Neukunden nicht mehr verfügbar. Bestehende Kunden von AWS Data Pipeline können den Service weiterhin wie gewohnt nutzen. Weitere Informationen
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.
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.
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://example-bucket/InputData/#{@scheduledStartTime.format('YYYY-MM-dd-hh:mm')}.csv", "precondition" : { "ref" : "Ready" } }, { "id" : "Ready", "type" : "Exists" }
Syntax
| Optionale Felder | Beschreibung | Slot-Typ |
|---|---|---|
| attemptStatus | Zuletzt gemeldeter Status von der Remote-Aktivität. | String |
| 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. | Intervall |
| 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 |
Intervall |
| 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„: {" ref“:“ myActionId „} |
| onLateAction | Aktionen, die ausgelöst werden sollen, wenn ein Objekt noch nicht geplant oder noch nicht abgeschlossen wurde. | Referenzobjekt, z. B. "onLateAction„: {" ref“:“ myActionId „} |
| onSuccess | Eine Aktion, die ausgeführt wird, wenn das aktuelle Objekt erfolgreich ist. | Referenzobjekt, z. B. "onSuccess„: {" ref“:“ myActionId „} |
| übergeordneter | Übergeordnetes Objekt des aktuellen Objekts, aus dem Slots übernommen werden. | Referenzobjekt, z. B. „parent“: {"ref“:“ myBaseObject Id "} |
| preconditionTimeout | Der Zeitraum ab dem die Vorbedingung als fehlgeschlagen gekennzeichnet ist, wenn sie noch nicht erfüllt ist | Intervall |
| reportProgressTimeout | Timeout für aufeinanderfolgende Anrufe von zu reportProgress Hause aus. 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. | Intervall |
| retryDelay | Die Zeitüberschreitungsdauer zwischen zwei Wiederholungsversuchen. | Intervall |
| Laufzeitfelder | Beschreibung | Slot-Typ |
|---|---|---|
| @activeInstances | Liste der aktuell geplanten aktiven Instance-Objekte. | Referenzobjekt, z. B. "activeInstances„: {" ref“:“ myRunnableObject Id "} |
| @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 | Das cancellationReason , ob dieses Objekt storniert wurde. | String |
| @cascadeFailedOn | Beschreibung der Abhängigkeitskette, bei der das Objekt fehlgeschlagen ist. | Referenzobjekt, z. B. "cascadeFailedOn„: {" ref“:“ myRunnableObject Id "} |
| emrStepLog | EMRSchrittprotokolle sind nur bei EMR Aktivitätsversuchen verfügbar | String |
| errorId | Das errorId , wenn dieses Objekt fehlgeschlagen ist. | String |
| errorMessage | Das ist errorMessage , wenn dieses Objekt fehlgeschlagen ist. | String |
| errorStackTrace | Die Fehler-Stack-Ablaufverfolgung., wenn dieses Objekt fehlgeschlagen ist. | String |
| hadoopJobLog | Hadoop-Jobprotokolle sind bei Versuchen für EMR basierte Aktivitäten verfügbar. | String |
| hostname | Der Hostname des Clients, der den Aufgabenversuch aufnimmt. | String |
| node | Der Knoten, für den diese Vorbedingung ausgeführt wird. | Referenzobjekt, z. B. „node“: {"ref“:“ myRunnableObject Id "} |
| 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. | String |
| @Version | Pipeline-Version, mit der das Objekt erstellt wurde. | String |
| @waitingOn | Beschreibung der Liste der Abhängigkeiten, auf die dieses Objekt wartet. | Referenzobjekt, z. B. "waitingOn„: {" ref“:“ myRunnableObject Id "} |
| Systemfelder | Beschreibung | Slot-Typ |
|---|---|---|
| @error | Fehler mit einer Beschreibung des falsch formatierten Objekts. | String |
| @pipelineId | Id der Pipeline, zu der dieses Objekt gehört. | String |
| @sphere | Die Kugel eines Objekts bezeichnet seinen Platz im Lebenszyklus: Komponentenobjekte ergeben Instance-Objekte, die Versuchsobjekte ausführen. | String |
Weitere Informationen finden Sie unter:
