Условие на конвейере данных

Question

Я сделал несколько действий по скрипту json. Необходимо добавить к нему предварительное условие. как использовать предварительное условие для скрипта json.

В предварительном порядке мне нужно проверить поле mysql db. один раз флаг как «Y», начало выполнения else должно прекратить выполнение.

Answer 1

Вы можете использовать ShellCommandPrecondition для этого, что позволит вам написать собственное предварительное условие.

{ 
    "objects": [ 
    { 
     "schedule": { 
     "ref": "DefaultSchedule" 
     }, 
     "resourceRole": "DataPipelineDefaultResourceRole", 
     "role": "DataPipelineDefaultRole", 
     "name": "DefaultResource1", 
     "id": "ResourceId_dWoZ0", 
     "type": "Ec2Resource", 
     "terminateAfter": "1 Hour" 
    }, 
    { 
     "name": "DefaultPrecondition1", 
     "id": "PreconditionId_yA2rV", 
     "type": "ShellCommandPrecondition", 
     "command": "<Script to check mysql field>" 
    }, 
    { 
     "occurrences": "1", 
     "period": "1 Day", 
     "name": "RunOnce", 
     "id": "DefaultSchedule", 
     "type": "Schedule", 
     "startAt": "FIRST_ACTIVATION_DATE_TIME" 
    }, 
    { 
     "failureAndRerunMode": "CASCADE", 
     "schedule": { 
     "ref": "DefaultSchedule" 
     }, 
     "resourceRole": "DataPipelineDefaultResourceRole", 
     "role": "DataPipelineDefaultRole", 
     "pipelineLogUri": "s3://<mybucket>", 
     "scheduleType": "cron", 
     "name": "Default", 
     "id": "Default" 
    }, 
    { 
     "schedule": { 
     "ref": "DefaultSchedule" 
     }, 
     "name": "DefaultActivity1", 
     "runsOn": { 
     "ref": "ResourceId_dWoZ0" 
     }, 
     "precondition": { 
     "ref": "PreconditionId_yA2rV" 
     }, 
     "id": "ActivityId_gmQ0W", 
     "type": "ShellCommandActivity", 
     "command": "echo 'Hello world'" 
    } 
    ], 
    "parameters": [] 
}