abcLoadNRun

Этот модуль отвечает за загрузку и выполнение потоков, уже импортированных в базу данных управления. Вызов этого модуля происходит на сервере таймера SHR, а сведения о расписании находятся в файле {PMDB_HOME}/lib/trendtimer.sched.

Перед выполнением поток необходимо загрузить. Загрузка потоков происходит каждые 12 минут. Выполнение шагов в рамках потока происходит каждые 3 минуты.

Поток из 4 шагов не обязательно будет выполнен через 12 минут после загрузки. Это связано с определенными ограничениями, налагаемыми на результат выполнения каждого шага. Ограничения зависят от типа шага. Далее приведены значение по умолчанию для каждого типа шага.

COLLECT_PROC 10
TRANSFORM_PROC

10

RECONCILE_PROC

10

STAGE_PROC 10
LOAD_PROC 15
AGGREGATE_PROC 10
EXEC_PROC_PROC 10

Это означает, что по умолчанию существует только 15 шагов LOADER, которые могут работать параллельно. При обнаружении более 15 потоков LOADER, запускаемых в каждый данный отрезок времени, остальные потоки в рамках текущего вызова пропускаются. В целях предотвращения нехватки ресурсов пропущенные шаги получают повышение приоритета. В конце следующего трехминутного отрезка при запуске abcloadnrun происходит вызов ранее пропущенных шагов.

Использование
Загрузка потоков для выполнения
  • abcloadNrun -loadBatch -streamId <streamId>
  • abcloadNrun -loadBatch -streamId <streamId> -forceLoad
  • abcloadNrun -loadBatch -allStreams
  • abcloadNrun -loadBatch -allStreams –forceLoad
Выполнение загруженного потока
  • abcloadNrun -runSteps
  • abcloadNrun -runStream -streamId <streamId>
  • abcloadNrun -runStream -streamId <streamId> -stepId <stepId>
streamId Бизнес-имя потока
stepId Бизнес-имя шага потока