AWS Data Pipeline não está mais disponível para novos clientes. Os clientes existentes do AWS Data Pipeline podem continuar usando o serviço normalmente. Saiba mais
As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.
ShellCommandPrecondition
Um comando shell do Unix/Linux que pode ser executado como uma precondição.
Exemplo
Veja a seguir um exemplo deste tipo de objeto.
{ "id" : "VerifyDataReadiness", "type" : "ShellCommandPrecondition", "command" : "perl check-data-ready.pl" }
Sintaxe
| Grupo obrigatório (um dos seguintes é obrigatório) | Descrição | Tipo de slot |
|---|---|---|
| command | O comando a ser executado. Este valor e quaisquer parâmetros associados precisam funcionar no ambiente do qual você está executando o Task Runner. | String |
| scriptUri | Um caminho de URI do Amazon S3 para um arquivo do qual você fará download e executará como um comando shell. Apenas um campo de comando ou scriptUri deve estar presente. scriptUri não pode usar parâmetros, portanto, em vez disso, use o comando. | String |
| Campos opcionais | Descrição | Tipo de slot |
|---|---|---|
| attemptStatus | Status mais recente da atividade remota. | String |
| attemptTimeout | Tempo limite para conclusão do trabalho remoto. Se configurada, uma atividade remota não concluída dentro do prazo definido poderá ser executada novamente. | Período |
| failureAndRerunModo | Descreve o comportamento do nó do consumidor quando as dependências apresentam falhas ou são executadas novamente. | Enumeração |
| lateAfterTimeout | O tempo decorrido após o início do pipeline no qual o objeto deve ser concluído. Ele é acionado somente quando o tipo de programação não está definido como ondemand. |
Período |
| maximumRetries | Quantidade máxima de novas tentativas com falha. | Inteiro |
| onFail | Uma ação a ser executada quando há falha no objeto atual. | Objeto de referência, por exemplo, “onFail”: {"ref”:” myActionId “} |
| onLateAction | Ações que devem ser acionadas se um objeto ainda não foi agendado ou não foi concluído. | Objeto de referência, por exemplo, "onLateAction“: {" ref”:” myActionId “} |
| onSuccess | Uma ação a ser executada quando o objeto atual é executado com êxito. | Objeto de referência, por exemplo, “onSuccess”: {"ref”:” myActionId “} |
| parent | Pai do objeto atual a partir do qual os slots serão herdados. | Objeto de referência, por exemplo, “parent”: {"ref”:” myBaseObject Id "} |
| preconditionTimeout | O período inicial após o qual a precondição é marcada como "com falha" se ainda não tiver sido atendida. | Período |
| reportProgressTimeout | Tempo limite para as chamadas sucessivas de trabalho remoto para reportProgress. Se definidas, as atividades remotas sem progresso para o período especificado podem ser consideradas como interrompidas e executadas novamente. | Período |
| retryDelay | A duração do tempo limite entre duas novas tentativas. | Período |
| scriptArgument | Argumento a ser passado para o script de shell | String |
| stderr | O caminho do Amazon S3 que recebe mensagens de erro do sistema redirecionadas do comando. Se você usar o campo runsOn, ele precisará ser um caminho do Amazon S3 devido à natureza transitória do recurso que está executando sua atividade. No entanto, se você especificar o campo workerGroup, poderá usar um caminho de arquivo local. |
String |
| stdout | O caminho do Amazon S3 que recebe saídas redirecionadas do comando. Se você usar o campo runsOn, ele precisará ser um caminho do Amazon S3 devido à natureza transitória do recurso que está executando sua atividade. No entanto, se você especificar o campo workerGroup, poderá usar um caminho de arquivo local. |
String |
| Campos de tempo de execução | Descrição | Tipo de slot |
|---|---|---|
| @activeInstances | Lista dos objetos da instância ativa agendados no momento. | Objeto de referência, por exemplo, “ActiveInstances”: {"ref”:” myRunnableObject Id "} |
| @actualEndTime | Hora em que a execução deste objeto foi concluída. | DateTime |
| @actualStartTime | Hora em que a execução deste objeto foi iniciada. | DateTime |
| cancellationReason | O motivo do cancelamento, se esse objeto foi cancelado. | String |
| @cascadeFailedOn | Descrição da cadeia de dependência na qual o objeto apresentou falha. | Objeto de referência, por exemplo, "cascadeFailedOn“: {" ref”:” myRunnableObject Id "} |
| emrStepLog | Registros da etapa do EMR disponíveis somente nas tentativas de atividade do EMR. | String |
| errorId | O ID do erro se esse objeto apresentou falha. | String |
| errorMessage | A mensagem de erro se esse objeto apresentou falha. | String |
| errorStackTrace | O rastreamento de pilha com erro se esse objeto apresentou falha. | String |
| hadoopJobLog | Registos de trabalho do Hadoop disponíveis nas tentativas de atividades baseadas em EMR. | String |
| hostname | O nome do host do cliente que capturou a tentativa da tarefa. | String |
| nó | O nó para o qual esta precondição está sendo realizada. | Objeto de referência, por exemplo, “node”: {"ref”:” myRunnableObject Id "} |
| reportProgressTime | A última vez que a atividade remota relatou progresso. | DateTime |
| @scheduledEndTime | Horário de término da programação para o objeto. | DateTime |
| @scheduledStartTime | Horário de início da programação para o objeto. | DateTime |
| @status | O status deste objeto. | String |
| @version | A versão do pipeline com que o objeto foi criado. | String |
| @waitingOn | Descrição da lista de dependências em que este objeto está aguardando. | Objeto de referência, por exemplo, “waitingOn”: {"ref”:” myRunnableObject Id "} |
| Campos do sistema | Descrição | Tipo de slot |
|---|---|---|
| @error | Erro ao descrever o objeto malformado. | String |
| @pipelineId | ID do pipeline ao qual este objeto pertence. | String |
| @sphere | A esfera de um objeto denota seu lugar no ciclo de vida: os objetos componentes dão origem aos objetos de instância que executam os objetos de tentativa. | String |
Consulte também
