AWS Data Pipeline n'est plus disponible pour les nouveaux clients. Les clients existants de AWS Data Pipeline peut continuer à utiliser le service normalement. En savoir plus
Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
ShellCommandPrecondition
Commande shell Unix/Linux qui peut être exécutée en tant que condition préalable.
Exemple
Voici un exemple de ce type d'objet.
{ "id" : "VerifyDataReadiness", "type" : "ShellCommandPrecondition", "command" : "perl check-data-ready.pl" }
Syntaxe
Groupe obligatoire (l'un des groupes suivants est obligatoire) | Description | Type d'option |
---|---|---|
command | Commande à exécuter. Cette valeur et les paramètres associés doivent fonctionner dans l'environnement à partir duquel vous lancez l'exécuteur de tâches. | Chaîne |
scriptUri | Un URI chemin Amazon S3 pour un fichier à télécharger et à exécuter en tant que commande shell. Un scriptUri seul champ de commande doit être présent. scriptUri Impossible d'utiliser les paramètres, utilisez plutôt la commande. | Chaîne |
Champs facultatifs | Description | Type d'option |
---|---|---|
attemptStatus | État de l'activité à distance le plus récemment rapporté. | Chaîne |
attemptTimeout | Délai d'achèvement de la tâche à distance. Si une valeur est définie, une activité à distance qui n'est pas exécutée dans le cadre de la période de départ définie peut être retentée. | Période |
failureAndRerunMode | Décrit le comportement du nœud de consommateurs lorsque les dépendances échouent ou sont à nouveau exécutées. | Énumération |
lateAfterTimeout | Temps écoulé après le début du pipeline pendant lequel l'objet doit être terminé. Il est déclenché uniquement lorsque le type de planification n'est pas défini surondemand . |
Période |
maximumRetries | Nombre maximal de nouvelles tentatives en cas d'échec | Entier |
onFail | Action à exécuter en cas d'échec de l'objet actuel. | Objet de référence, par exemple "onFail« : {" ref » : » myActionId «} |
onLateAction | Actions à déclencher si un objet n'a pas encore été planifié ou n'est toujours pas terminé. | Objet de référence, par exemple "onLateAction« : {" ref » : » myActionId «} |
onSuccess | Action à exécuter en cas de réussite de l'objet actuel. | Objet de référence, par exemple "onSuccess« : {" ref » : » myActionId «} |
parent | Parent de l'objet actuel à partir duquel les emplacements sont hérités. | Objet de référence, par exemple « parent » : {"ref » : » myBaseObject Id "} |
preconditionTimeout | Période depuis le démarrage après laquelle la condition préalable est marquée comme ayant échoué si elle n'est toujours pas satisfaite | Période |
reportProgressTimeout | Délai d'attente pour le télétravail, appels successifs à. reportProgress Si une valeur est définie, les activités à distance qui ne font pas état d'avancement pour la période spécifiée doivent être considérées comme bloquées et, par conséquent, retentées. | Période |
retryDelay | Délai entre deux nouvelles tentatives. | Période |
scriptArgument | Argument à transmettre au script shell. | Chaîne |
stderr | Le chemin Amazon S3 qui reçoit les messages d'erreur système redirigés depuis la commande. Si vous utilisez ce runsOn champ, il doit s'agir d'un chemin Amazon S3 en raison de la nature transitoire de la ressource exécutant votre activité. Toutefois, si vous spécifiez le champ workerGroup , un chemin de fichier local est autorisé. |
Chaîne |
stdout | Le chemin Amazon S3 qui reçoit la sortie redirigée de la commande. Si vous utilisez ce runsOn champ, il doit s'agir d'un chemin Amazon S3 en raison de la nature transitoire de la ressource exécutant votre activité. Toutefois, si vous spécifiez le champ workerGroup , un chemin de fichier local est autorisé. |
Chaîne |
Champs liés à l'exécution | Description | Type d'option |
---|---|---|
@activeInstances | Liste des objets d'instances actives actuellement planifiés. | Objet de référence, par exemple "activeInstances« : {" ref » : » myRunnableObject Id "} |
@actualEndTime | Heure à laquelle l'exécution de l'objet s'est terminée. | DateTime |
@actualStartTime | Heure à laquelle l'exécution de l'objet a démarré. | DateTime |
cancellationReason | cancellationReason Si cet objet a été annulé. | Chaîne |
@cascadeFailedOn | Description de la chaîne de dépendances sur laquelle l'objet a échoué. | Objet de référence, par exemple "cascadeFailedOn« : {" ref » : » myRunnableObject Id "} |
emrStepLog | EMRjournaux d'étapes disponibles uniquement pour les tentatives EMR d'activité | Chaîne |
errorId | Le errorId si cet objet a échoué. | Chaîne |
errorMessage | Le errorMessage si cet objet a échoué. | Chaîne |
errorStackTrace | Suivi de la pile d'erreurs si l'objet a échoué. | Chaîne |
hadoopJobLog | Des journaux de tâches Hadoop sont disponibles sur les tentatives d'activités EMR basées. | Chaîne |
hostname | Nom d'hôte du client qui a sélectionné la tentative de tâche. | Chaîne |
nœud | Nœud pour lequel la condition préalable est en cours d'exécution | Objet de référence, par exemple « node » : {"ref » : » myRunnableObject Id "} |
reportProgressTime | Heure la plus récente pour laquelle l'activité distante a signalé une progression. | DateTime |
@scheduledEndTime | Heure de fin planifiée pour l'objet. | DateTime |
@scheduledStartTime | Heure de début planifiée pour l'objet. | DateTime |
@État | État de l'objet. | Chaîne |
@Version | Version du pipeline avec laquelle l'objet été créé. | Chaîne |
@waitingOn | Description de la liste des dépendances sur laquelle l'objet est en attente. | Objet de référence, par exemple "waitingOn« : {" ref » : » myRunnableObject Id "} |
Champs système | Description | Type d'option |
---|---|---|
@error | Erreur décrivant l'objet mal formé. | Chaîne |
@pipelineId | Id du pipeline auquel l'objet appartient. | Chaîne |
@sphere | La sphère d'un objet désigne sa place dans le cycle de vie : les objets « composant » entraînent les objets « instance » qui exécutent les objets « tentative » | Chaîne |