Работен поток в Informatica: Създаване, Задача, Параметър, Многократна употреба, Мениджър

Съдържание:

Anonim
Какво е Workflow?

Работният процес е група инструкции / команди към услугата за интеграции в Informatica. Услугата за интеграция е обект, който чете информация за работния поток от хранилището, извлича данни от източници и след извършване на трансформацията я зарежда в целта.

Работен поток - Той определя как да се изпълняват задачи като сесийна задача, командна задача, имейл задача и т.н.

За да създадете работен поток

  1. Първо трябва да създадете задачи
  2. И след това добавете тези задачи към работния процес.

Работният процес е като празен контейнер, който има капацитета да съхранява обект, който искате да изпълните. Добавяте задачи към работния поток, които искате да изпълните. В този урок ще направим следните неща в работния процес.

Изпълнението на работния процес може да се извърши по два начина

  • Последователност : Задачите се изпълняват в реда, в който са дефинирани
  • Въз основа на събитие: Задачите се изпълняват въз основа на условията на събитието.

Как да отворите диспечера на работния поток

Стъпка 1 - В Informatica Designer кликнете върху иконата на мениджъра на работния поток

Стъпка 2 - Това ще отвори прозорец на Workflow Manager. След това в диспечера на работния поток.

  1. Ще се свържем с хранилището "guru99", така че щракнете двукратно върху папката, за да се свържете.
  2. Въведете потребителско име и парола, след което изберете „Бутон за свързване“.

Стъпка 3 - В диспечера на работния процес.

  1. Щракнете с десния бутон върху папката
  2. В изскачащото меню изберете отворена опция

Това ще отвори работното пространство на мениджъра на работния поток.

Как да създадете връзки за мениджър на работния поток

За да изпълните всяка задача в диспечера на работния поток, трябва да създадете връзки . Използвайки тези връзки, Integration Service се свързва с различни обекти.

Например, във вашето картографиране, ако имате изходна таблица в базата данни на oracle, тогава ще ви е необходима връзка oracle, така че услугата за интеграция да може да се свърже с базата данни на oracle, за да извлече изходните данни.

Следният тип връзки могат да бъдат създадени в диспечера на работния процес.

  • Релационна връзка
  • Ftp връзка
  • Опашка
  • Приложение

Изборът на връзка, която ще създадете, ще зависи от вида на източника и целевите системи, които искате да свържете. По-често бихте използвали релационни връзки.

За да създадете релационна връзка

Стъпка 1 - В мениджъра на работния поток

  1. Щракнете върху менюто Connection
  2. Изберете Релационна опция

Стъпка 2 - В изскачащия прозорец

  1. Изберете тип Oracle
  2. Щракнете върху новия бутон

Стъпка 3 - В новия прозорец на дефиниция на обект за свързване

  1. Въведете име на връзката (ново име-guru99)
  2. Въведете потребителско име
  3. Въведете паролата
  4. Въведете низ за връзка
  5. Оставете другите настройки по подразбиране и изберете бутона OK

Стъпка 4 - Ще се върнете в предишния прозорец. Щракнете върху бутона за затваряне.

Сега сте настроени с релационната връзка в диспечера на работния поток.

Компоненти на Workflow manager

Има три компонентни инструмента на диспечера на работния поток, който помага при създаването на различни обекти в диспечера на работния поток. Тези инструменти са

  • Разработчик на задачи
  • Дизайнер на Worklet
  • Дизайнер на работния поток

Task Developer - Task Developer е инструмент, с помощта на който можете да създавате обекти за многократна употреба. Обектът за многократна употреба в диспечера на работния поток са обекти, които могат да бъдат използвани повторно в множество работни потоци. Например, ако сте създали командна задача в разработчика на задачи, можете да използвате повторно тази задача в произволен брой работни потоци.

Ролята на дизайнера на работния поток е да изпълнява задачите, които са добавени в него. Можете да добавите произволен брой задачи в работен поток.

Можете да създадете три вида задачи за многократна употреба в разработчика на задачи.

  • Командна задача
  • Задача на сесията
  • Имейл задача

Командна задача - Командна задача се използва за изпълнение на различни команди на windows / unix по време на изпълнението на работния процес. Можете да създадете командна задача за изпълнение на различни командни задачи. С помощта на тази задача можете да изпълнявате команди за създаване на файлове / папки, за изтриване на файлове / папки, за извършване на ftp на файлове и т.н.

Задача на сесията - За да стартирате картографиране, е необходима сесийна задача в Informatica.

  • Без сесийна задача не можете да изпълните или стартирате картографиране
  • Сесийна задача може да изпълни само едно картографиране. И така, има връзка едно към едно между картографиране и сесия
  • Задачата на сесията е обект, с помощта на който informatica опознава как и къде да изпълни картографиране и по кое време
  • Сесиите не могат да се изпълняват независимо, сесията трябва да бъде добавена към работния поток
  • В кеш обект свойствата могат да бъдат конфигурирани, както и разширена конфигурация за оптимизиране на производителността.

Имейл задача - С помощта на имейл задача можете да изпращате имейли до определени получатели, когато услугата за интеграция изпълнява работен поток. Например, ако искате да наблюдавате колко време отнема една сесия, можете да конфигурирате сесията да изпраща имейл, съдържащ подробности за времето за начало и край на сесията. Или, ако искате услугата за интеграция да ви уведоми, когато даден работен процес завърши / се провали, можете да конфигурирате имейл задачата за същото.

Как да създадете командна задача

Стъпка 1 - За да създадем командна задача, ще използваме Task Developer. В Workflow Manager отворете разработчика на задачи, като щракнете върху раздела „разработчик на задачи“ от менюто.

Стъпка 2 - След като се отвори разработчикът на задачи, следвайте тези стъпки

  1. Изберете меню Задачи
  2. Изберете опция Създаване

Стъпка 3 - В прозореца за създаване на задача

  1. Изберете команда като тип задача, която да създадете
  2. Въведете името на задачата
  3. Изберете бутона за създаване

Това ще създаде папка на командната задача. Сега трябва да конфигурирате задачата да добави команда в нея, което ще видим в следващата стъпка.

Стъпка 4 - За да конфигурирате задачата, щракнете двукратно върху иконата на командната задача и тя ще отвори "прозорец за редактиране на задачата". В новия прозорец на задачата за редактиране

  1. Изберете менюто команди
  2. Щракнете върху иконата за добавяне на нова команда
  3. Въведете име на команда
  4. Щракнете върху иконата на командата, за да добавите текст на командата

Това ще отвори полето за редактор на команди.

Стъпка 5 - В полето за редактор на команди въведете командата "mkdir C: \ guru99" (това е командата на windows за създаване на папка с име "guru99") и изберете OK.

След тази стъпка ще се върнете в прозореца за редактиране на задачи и ще можете да видите командата, която сте добавили в текстовото поле на командата.

Стъпка 6 - Щракнете върху OK в прозореца за редактиране на задача,

Командната задача ще бъде създадена в разработчика на задачата под хранилището "Guru99".

Забележка - използвайте клавишната комбинация ctrl + s, за да запишете промените в хранилището

Как да създам работен поток за изпълнение на командна задача

За да изпълните команди, трябва да включите дизайнера на работния поток. Дизайнерът на работен поток е обект родител или контейнер, в който можете да добавяте множество задачи и когато работният поток се изпълнява, всички добавени задачи ще се изпълняват. За да създадете работен поток

Стъпка 1 - Отворете дизайнера на работния поток, като кликнете върху менюто на дизайнера на работния поток

Стъпка 2 - В дизайнера на работния процес

  1. Изберете меню за работни потоци
  2. Изберете опция за създаване

Стъпка 3 - В прозореца за създаване на работен поток

  1. Въведете име на работния поток
  2. Изберете бутона OK (оставете другите опции по подразбиране)

Това ще създаде работния поток.

Конвенция за имената - Имената на работния поток са с префикс с използване на „ wkf_“ , ако имате сесия с име „ s_m_employee_detail “, тогава работният поток за същия може да бъде наречен като „ wkf_s_m_employee_detail“ .

Когато създавате работен поток, той не се състои от никакви задачи. Така че, за да изпълните всяка задача в работен поток, трябва да добавите задача в нея.

Стъпка 4 - За да добавите командна задача, която сме създали в Task developer към работния процес

  1. В дървото на навигатора разгънете папката със задачи
  2. Плъзнете и пуснете командната задача в дизайнера на работния поток

Стъпка 5 - Изберете "опция за свързване на задача" от кутията с инструменти от горното меню. (Опцията за свързване на задача свързва различни задачи в работен поток със стартовата задача, така че редът на изпълнение на задачите може да бъде дефиниран).

Стъпка 6 - След като изберете иконата на задачата за връзка, тя ще ви позволи да плъзнете връзката между стартовата задача и командната задача. Сега изберете стартовата задача и плъзнете връзка към командната задача.

Сега сте готови с работния процес, който има командна задача, която да бъде изпълнена.

Как да изпълните работния процес

Стъпка 1 - За изпълнение на работния процес

  1. Изберете опция за работни потоци от менюто
  2. Изберете опция за стартиране на работния поток

Това ще отвори прозореца на монитора на работния поток и ще изпълни работния процес

След като работният процес бъде изпълнен, той ще изпълни командната задача за създаване на папка (папка guru99) в определената директория.

Задача на сесията

За да стартирате картографиране, е необходима сесийна задача в Informatica.

Без сесийна задача не можете да изпълните или стартирате картографиране и сесийна задача може да изпълни само едно картографиране. И така, има връзка едно към едно между картографиране и сесия. Сесийна задача е обект, с помощта на който Informatica се запознава как и къде да изпълни картографиране и по кое време. Сесиите не могат да се изпълняват независимо, сесията трябва да бъде добавена към работния поток. В кеш обект свойствата могат да бъдат конфигурирани, както и разширена конфигурация за оптимизиране на производителността.

Как да създадете сесийна задача.

В това упражнение ще създадете сесийна задача за картографирането "m_emp_emp_target", което сте създали в предишната статия.

Стъпка 1 - Отворете мениджъра на работния поток и отворете разработчика на задачи

Стъпка 2 - Сега, след като разработчикът на задачи се отвори, в диспечера на работния поток отидете в главното меню

  1. Щракнете върху менюто на задачите
  2. Изберете опция за създаване

Това ще отвори нов прозорец "Създаване на задача"

Стъпка 3 - В прозореца за създаване на задача

  1. Изберете сесийна задача като тип задача.
  2. Въведете име на задачата.
  3. Щракнете върху бутона за създаване

Стъпка 4 - Ще се появи прозорец за избор на картографиране. Изберете картографирането, което искате да свържете с тази сесия, за този пример изберете картографиране "m_emp_emp_target" и щракнете върху бутона OK.

Стъпка 5 - След това кликнете върху бутона "Готово"

Обектът на сесията ще се появи в разработчика на задачата

Стъпка 6 - В тази стъпка ще създадете работен поток за сесийна задача. Кликнете върху иконата на дизайнера на работния процес.

Стъпка 7 - В инструмента за проектиране на работен процес

  1. Щракнете върху менюто на работния поток
  2. Изберете опция за създаване

Стъпка 8 - В прозореца за създаване на работен поток

  1. Въведете име на работния поток
  2. Изберете OK. (оставете други свойства по подразбиране, няма нужда да променяте свойствата)

В диспечера на работния поток ще се появи начална задача, това е начална точка на изпълнение на работния процес.

Стъпка 9 - В мениджъра на работния поток

  1. Разгънете папката сесии под дървото за навигация.
  2. Плъзнете и пуснете създадената от вас сесия в работното пространство на мениджъра на работния поток.

Стъпка 10 - Щракнете върху опцията за задача за свързване в полето с инструменти.

Стъпка 11 - Свържете стартовата задача и задачата на сесията, като използвате връзката.

Стъпка 12 - Щракнете двукратно върху обекта на сесията в wokflow manager. Той ще отвори прозорец на задачата, за да модифицира свойствата на задачата.

Стъпка 13 - В прозореца за редактиране на задачата

  1. Изберете раздела за картографиране
  2. Изберете свойство на връзката
  3. Задайте връзката на източник и цел, връзката, която създадохме в ранните стъпки.
  4. Изберете бутона OK

Сега вашата конфигурация на работния процес е завършена и можете да изпълните работния процес.

Как да добавите множество задачи към начална задача

Стартовата задача е отправна точка за изпълнение на работния процес. Има два начина за свързване на множество задачи със начална задача.

  1. Паралелно
  2. Сериен

При паралелно свързване задачите са свързани директно със стартовата задача и всички задачи започват да се изпълняват паралелно едновременно.

Как да добавяте задачи паралелно

Стъпка 1 - В диспечера на работния поток отворете работния поток "wkf_run_command"

Стъпка 2 - В работния процес добавете сесийна задача "s_m_emp_emp_target". (като изберете сесия и след това плъзнете и пуснете)

Стъпка 3 - Изберете опцията за задача за свързване от кутията с инструменти

Стъпка 4 - свържете задачата на сесията със стартовата задача (като щракнете върху стартови такси, задържите щракването и се свържете със сесийна задача)

След свързването на сесийна задача работният процес ще изглежда така.

Стъпка 5 - Стартирайте работния поток и монитора в монитора на работния поток.

Как да добавяте задачи в сериен режим

Но преди да добавим задачи в сериен режим, трябва да изтрием задачата, която сме добавили, за да демонстрираме паралелно изпълнение на задачата. За това

Стъпка 1 - Отворете работния процес "w.kf_run_command"

  1. Изберете връзката към сесийна задача.
  2. Изберете опция за редактиране в менюто
  3. Изберете опция за изтриване

Стъпка 2 - диалоговият прозорец за потвърждение ще се появи в прозорец, изберете опция да

Връзката между стартовата задача и задачата на сесията ще бъде премахната.

Стъпка 3 - Сега отново отидете в горното меню и изберете опцията за свързване на задача от кутията с инструменти

Стъпка 4 - свържете задачата на сесията с командната задача

След свързването работният процес ще изглежда така

Стъпка 5 - За да направите визуалния външен вид на работния процес по-ясен

  1. Щракнете с десния бутон върху wokspace на работния процес
  2. Изберете меню за подреждане
  3. Изберете Хоризонтална опция

Ако стартирате работния поток, командната задача ще се изпълни първо и след нейното изпълнение ще стартира сесийна задача.

Променлива на работния поток

Променливите на работния поток позволяват на различни задачи в работния поток да обменят информация помежду си, а също така позволява на задачите да имат достъп до определени свойства на други задачи в работния процес. Например, за да получите текущата дата, можете да използвате вградената променлива "sysdate".

Най-често срещаният сценарий е, когато имате няколко задачи в работен поток и в една задача имате достъп до променливата на друга задача. Например, ако имате две задачи в работен поток и изискването е да изпълните втората задача само когато първата задача е изпълнена успешно. Можете да приложите такъв сценарий, като използвате предварително дефинирана променлива в работния поток.

Прилагане на сценария

Имахме работен поток "wkf_run_command" с добавени задачи в сериен режим. Сега ще добавим условие към връзката между сесийна задача и командна задача, така че само след успеха на командната задача сесийна задача да бъде изпълнена.

Стъпка 1 - Отворете работния процес "wkf_run_command"

Стъпка 2 - Щракнете двукратно върху връзката между сесията и командната задача

Ще се появи прозорец за израз

Стъпка 3 - Щракнете двукратно върху променливата на състоянието под менюто "cmd_create_folder". В прозореца на редактора от дясната страна ще се появи променлива "$ cmd_create_folder.status".

Стъпка 4 - Сега ще зададем състоянието на променливата "$ cmd_create_folder.status" на успешен статус. което означава, че когато предишните задачи са изпълнени и изпълнението е било успешно, тогава изпълнете само следващата сесийна задача.

  1. Променете променливата на стойност "$ cmd_create_folder.status = УСПЕШНО".
  2. Щракнете върху бутона OK

Работният процес ще изглежда така

Когато изпълнявате този работен поток, командната задача се изпълнява първо и само когато успее, тогава ще се изпълни само сесийна задача.

Параметър на работния поток

Параметрите на работния поток са тези стойности, които остават постоянни през цялото изпълнение. след като стойността им е присвоена, тя остава същата. Параметрите могат да се използват в свойствата на работния поток и техните стойности могат да бъдат дефинирани във файлове с параметри. Например, вместо да използвате твърдо кодирана стойност на връзката, можете да използвате параметър / променлива в името на връзката и стойността може да бъде дефинирана във файла на параметъра.

Файловете с параметри са файловете, в които дефинираме стойностите на променливи или параметри на картографиране / работен поток. Там файловете имат разширението ".par". Като общ стандарт се създава файл с параметри за работен поток.

Предимства на файла с параметри

  • Помага при миграция на код от една среда в друга
  • Позволява лесно отстраняване на грешки и тестване
  • Стойностите могат да бъдат модифицирани с лекота, без промяна в кода

Структура на файла с параметри

Структурата на файла с параметри

  • [име на папка.WF: Име на работен поток]
  • $ Parameter_name = Стойност на параметъра

Името на папката е името на папката на хранилището, името на работния поток е името на работния поток, за който създавате файла на параметъра.

Ще създадем файл с параметри за връзката с базата данни "guru99", който зададохме в ранните ни сесии за източници и цели.

Как да създам файл с параметри

Стъпка 1 - Създайте нов празен файл (файл на бележника)

Стъпка 2 - Във файла въведете текст, както е показано на фигурата

Стъпка 3 - Запазете файла в папка guru99 на местоположението "C: \ guru99" като "wkf_run_command.par"

Във файла, който сме създали параметър "$ DBConnection_SRC", ние ще присвоим същото на връзка в нашия работен процес.

Стъпка 4- Отворете работния процес "wkf_run_command"

  1. Изберете меню за работни потоци
  2. Изберете опция за редактиране

Стъпка 5 - Това ще отвори прозорец за редактиране на работния процес, в този прозорец

  1. Отидете в раздела за свойства
  2. Въведете името на файла на параметъра като "c: \ guru99 \ wkf_run_command.par"
  3. Изберете бутона OK

Сега приключихме с дефинирането на съдържанието на файла с параметри и го насочихме към работен поток.

Следващата стъпка е да използвате параметъра в сесия.

Стъпка 6 - След това в работния процес щракнете двукратно върху сесията "s_m_emp_emp_target"

  1. Изберете менюто на раздела за картографиране
  2. Изберете свойството за връзка в левия панел
  3. Кликнете върху целевата връзка, която сега е кодирана твърдо като "guru99"

Стъпка 7 - В този прозорец ще се появи прозорец на браузъра за връзка

  1. Изберете опцията да използвате променлива на връзката
  2. Въведете име на променлива на връзката като "$ DBConnection_SRC"
  3. Изберете бутон Ok

Стъпка 8 - В прозореца за редактиране на задача за промяна ще се появи променлива за целта, изберете бутона OK в прозореца за редактиране на задачата.

Сега приключихме със създаването на параметър за връзка и присвояване на неговата стойност на файла с параметри.

Когато изпълняваме работния поток, работният процес избира файла с параметри, търси стойността на параметрите / променливите във файла с параметри и приема тези стойности.