Этот модуль отвечает за загрузку и выполнение потоков, уже импортированных в базу данных управления. Вызов этого модуля происходит на сервере таймера 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 происходит вызов ранее пропущенных шагов.
Использование | |
Загрузка потоков для выполнения |
|
Выполнение загруженного потока |
|
streamId | Бизнес-имя потока |
stepId | Бизнес-имя шага потока |