Workflow este un grup de instrucțiuni / comenzi către serviciul de integrări din Informatica. Serviciul de integrare este o entitate care citește informații despre fluxul de lucru din depozit, preia date din surse și după efectuarea transformării le încarcă în țintă.
Flux de lucru - Definește cum să rulați activități precum sarcina de sesiune, sarcina de comandă, sarcina de e-mail etc.
Pentru a crea un flux de lucru
- Mai întâi trebuie să creați sarcini
- Și apoi adăugați acele sarcini la fluxul de lucru.
Un flux de lucru este ca un container gol, care are capacitatea de a stoca un obiect pe care doriți să îl executați. Adăugați sarcini la fluxul de lucru pe care doriți să îl executați. În acest tutorial, vom face următoarele lucruri în fluxul de lucru.
Executarea fluxului de lucru se poate face în două moduri
- Secvență : Sarcinile se execută în ordinea în care sunt definite
- Bazat pe eveniment: activitățile sunt executate în funcție de condițiile evenimentului.
Cum se deschide Workflow Manager
Pasul 1 - În Informatica Designer, faceți clic pe pictograma Manager flux de lucru
Pasul 2 - Aceasta va deschide o fereastră a Managerului de flux de lucru. Apoi, în Manager flux de lucru.
- Ne vom conecta la depozitul „guru99”, așa că faceți dublu clic pe folder pentru a ne conecta.
- Introduceți numele de utilizator și parola, apoi selectați „Butonul de conectare”.
Pasul 3 - În managerul fluxului de lucru.
- Faceți clic dreapta pe folder
- În meniul pop-up, selectați opțiunea de deschidere
Aceasta va deschide spațiul de lucru al managerului de flux de lucru.
Cum se creează conexiuni pentru Workflow Manager
Pentru a executa orice activitate în managerul de flux de lucru, trebuie să creați conexiuni . Prin utilizarea acestor conexiuni, Integration Service se conectează la diferite obiecte.
De exemplu, în cartografierea dvs. dacă aveți tabel sursă în baza de date oracle, atunci veți avea nevoie de conexiune oracle, astfel încât serviciul de integrare să se poată conecta la baza de date oracle pentru a prelua datele sursă.
Următorul tip de conexiuni poate fi creat în managerul de flux de lucru.
- Conexiune relațională
- Conexiune Ftp
- Coadă
- Cerere
Alegerea conexiunii pe care o veți crea va depinde de tipul sursei și de sistemele țintă pe care doriți să le conectați. Mai des, ați folosi conexiuni relaționale.
Pentru a crea o conexiune relațională
Pasul 1 - În Workflow Manager
- Faceți clic pe meniul Conexiune
- Selectați Opțiunea relațională
Pasul 2 - În fereastra pop-up
- Selectați tipul Oracle
- Faceți clic pe butonul nou
Pasul 3 - În noua fereastră a definiției obiectului de conexiune
- Introduceți numele conexiunii (Nume nou-guru99)
- Introduceti numele de utilizator
- Introdu parola
- Introduceți șirul de conexiune
- Lăsați alte setări ca implicite și selectați butonul OK
Pasul 4 - Veți reveni la fereastra anterioară. Faceți clic pe butonul de închidere.
Acum sunteți setat cu conexiunea relațională în managerul fluxului de lucru.
Componentele managerului de flux de lucru
Există trei instrumente componente ale managerului de flux de lucru care ajută la crearea diferitelor obiecte în managerul de flux de lucru. Aceste instrumente sunt
- Dezvoltator de activități
- Proiectant Worklet
- Proiectant de flux de lucru
Task Developer - Task Developer este un instrument cu ajutorul căruia puteți crea obiecte refolosibile. Obiectul reutilizabil în managerul de flux de lucru sunt obiecte care pot fi refolosite în mai multe fluxuri de lucru. De exemplu, dacă ați creat o sarcină de comandă în dezvoltatorul de sarcini, atunci puteți reutiliza această sarcină în orice număr de fluxuri de lucru.
Rolul proiectantului de flux de lucru este de a executa sarcinile care sunt adăugate în acesta. Puteți adăuga orice număr de sarcini într-un flux de lucru.
Puteți crea trei tipuri de sarcini reutilizabile în dezvoltatorul de activități.
- Sarcină de comandă
- Sarcina sesiunii
- Sarcină prin e-mail
Sarcină de comandă - O sarcină de comandă este utilizată pentru a executa diferite comenzi Windows / Unix în timpul execuției fluxului de lucru. Puteți crea sarcini de comandă pentru a executa diverse sarcini bazate pe comenzi. Cu ajutorul acestei sarcini puteți executa comenzi pentru a crea fișiere / foldere, pentru a șterge fișiere / foldere, pentru a face ftp de fișiere etc.
Activitate sesiune - Este necesară o activitate sesiune în Informatica pentru a rula o mapare.
- Fără o activitate de sesiune, nu puteți executa sau rula o mapare
- O activitate de sesiune poate executa doar o singură mapare. Deci, există o relație unu la unu între o mapare și o sesiune
- O sarcină de sesiune este un obiect cu ajutorul căruia informatica ajunge să știe cum și unde să execute o mapare și la ce moment
- Sesiunile nu pot fi executate independent, o sesiune trebuie adăugată la un flux de lucru
- În sesiune, proprietățile cache ale obiectelor pot fi configurate, precum și configurația avansată de optimizare a performanței.
Sarcină de e-mail - Cu ajutorul sarcinii de e-mail puteți trimite e-mail destinatarilor definiți atunci când Serviciul de integrare execută un flux de lucru. De exemplu, dacă doriți să monitorizați cât durează o sesiune, puteți configura sesiunea pentru a trimite un e-mail conținând detaliile orei de începere și de încheiere a sesiunii. Sau, dacă doriți ca Serviciul de integrare să vă anunțe când un flux de lucru se finalizează / eșuează, puteți configura sarcina de e-mail pentru aceeași.
Cum se creează o sarcină de comandă
Pasul 1 - Pentru a crea o sarcină de comandă vom folosi Task Developer. În Workflow Manager, deschideți dezvoltatorul de activități făcând clic pe fila „dezvoltator de activități” din meniu.
Pasul 2 - Odată ce dezvoltatorul de sarcini este deschis, urmați acești pași
- Selectați meniul Sarcini
- Selectați opțiunea Creați
Pasul 3 - În fereastra de creare a sarcinilor
- Selectați comanda ca tip de sarcină de creat
- Introduceți numele sarcinii
- Selectați butonul de creare
Aceasta va crea folderul de sarcini de comandă. Acum trebuie să configurați sarcina pentru a adăuga comanda în ea, pe care o vom vedea în pasul următor.
Pasul 4 - Pentru a configura sarcina, faceți dublu clic pe pictograma sarcinii de comandă și se va deschide o „editare fereastră sarcină”. În noua fereastră de editare a sarcinilor
- Selectați meniul de comenzi
- Faceți clic pe pictograma Adăugare comandă nouă
- Introduceți numele comenzii
- Faceți clic pe pictograma de comandă pentru a adăuga text de comandă
Aceasta va deschide o casetă de editor de comenzi.
Pasul 5 - În caseta editorului de comenzi, introduceți comanda „mkdir C: \ guru99” (aceasta este comanda Windows pentru a crea un folder numit „guru99”) și selectați OK.
După acest pas, veți reveni la fereastra de editare a sarcinilor și veți putea vedea comanda pe care ați adăugat-o în caseta de text a comenzii.
Pasul 6 - Faceți clic pe OK pe fereastra de editare a activității,
Activitatea de comandă va fi creată în programatorul de activități din depozitul „Guru99”.
Notă - utilizați comanda rapidă ctrl + s pentru a salva modificările din depozit
Cum se creează un flux de lucru pentru a executa sarcina de comandă
Pentru a executa taxele de comandă trebuie să porniți la proiectantul fluxului de lucru. Un proiectant de flux de lucru este un obiect părinte sau container în care puteți adăuga mai multe sarcini și când fluxul de lucru este executat, toate sarcinile adăugate se vor executa. Pentru a crea un flux de lucru
Pasul 1 - Deschideți proiectantul fluxului de lucru făcând clic pe meniul proiectantului fluxului de lucru
Pasul 2 - În proiectarea fluxului de lucru
- Selectați meniul fluxurilor de lucru
- Selectați opțiunea de creare
Pasul 3 - În fereastra de creare a fluxului de lucru
- Introduceți numele fluxului de lucru
- Selectați butonul OK (lăsați alte opțiuni ca implicite)
Aceasta va crea fluxul de lucru.
Convenție de denumire - Numele fluxului de lucru sunt prefixate cu utilizarea „ wkf_” , dacă aveți o sesiune numită „ s_m_employee_detail ”, atunci fluxul de lucru pentru același lucru poate fi numit „ wkf_s_m_employee_detail” .
Când creați un flux de lucru, acesta nu constă în nici o activitate. Deci, pentru a executa orice activitate într-un flux de lucru, trebuie să adăugați sarcină în acesta.
Pasul 4 - Pentru a adăuga sarcina de comandă pe care am creat-o în Task developer la desingerul fluxului de lucru
- În arborele navigatorului, extindeți folderul sarcini
- Trageți și plasați sarcina de comandă în proiectarea fluxului de lucru
Pasul 5 - Selectați „opțiunea de conectare a sarcinii” din caseta de instrumente din meniul de sus. (Opțiunea de legare a activității leagă diverse activități dintr-un flux de lucru cu sarcina de pornire, astfel încât să poată fi definită ordinea de executare a activităților).
Pasul 6 - Odată ce ați selectat pictograma sarcinii de legătură, aceasta vă va permite să trageți legătura între sarcina de pornire și sarcina de comandă. Acum selectați sarcina de pornire și trageți un link către sarcina de comandă.
Acum sunteți gata cu fluxul de lucru având o sarcină de comandă care urmează să fie executată.
Cum se execută fluxul de lucru
Pasul 1 - Pentru a executa fluxul de lucru
- Selectați opțiunea Fluxuri de lucru din meniu
- Selectați opțiunea de pornire a fluxului de lucru
Aceasta va deschide fereastra de monitorizare a fluxului de lucru și va executa fluxul de lucru
Odată ce fluxul de lucru este executat, acesta va executa sarcina de comandă pentru a crea un folder (folder guru99) în directorul definit.
Sarcina sesiunii
O sarcină de sesiune în Informatica este necesară pentru a rula o mapare.
Fără o activitate de sesiune, nu puteți executa sau rula o mapare, iar o activitate de sesiune poate executa doar o singură mapare. Deci, există o relație unu la unu între o mapare și o sesiune. O sarcină de sesiune este un obiect cu ajutorul căruia Informatica știe cum și unde să execute o mapare și la ce oră. Sesiunile nu pot fi executate independent, o sesiune trebuie adăugată la un flux de lucru. În sesiune, proprietățile cache ale obiectelor pot fi configurate, precum și configurația avansată de optimizare a performanței.
Cum se creează o activitate de sesiune.
În acest exercițiu veți crea o activitate de sesiune pentru maparea „m_emp_emp_target” pe care ați creat-o în articolul precedent.
Pasul 1 - Deschideți Manager de flux de lucru și deschideți dezvoltatorul de activități
Pasul 2 - Odată ce se deschide dezvoltatorul de activități, în managerul fluxului de lucru accesați meniul principal
- Faceți clic pe meniul task
- Selectați opțiunea de creare
Aceasta va deschide o nouă fereastră „Creați o activitate”
Pasul 3 - În fereastra de creare a sarcinilor
- Selectați activitatea de sesiune ca tip de activitate.
- Introduceți numele sarcinii.
- Faceți clic pe butonul Creați
Pasul 4 - Va apărea o fereastră pentru selectarea mapării. Selectați maparea pe care doriți să o asociați cu această sesiune, pentru acest exemplu selectați maparea „m_emp_emp_target” și faceți clic pe butonul OK.
Pasul 5 - După aceea, faceți clic pe butonul „Terminat”
Obiectul sesiunii va apărea în dezvoltatorul activității
Pasul 6 - În acest pas veți crea un flux de lucru pentru sarcina sesiunii. Faceți clic pe pictograma de proiectare a fluxului de lucru.
Pasul 7 - În instrumentul de proiectare a fluxului de lucru
- Faceți clic pe meniul fluxului de lucru
- Selectați opțiunea de creare
Pasul 8 - În fereastra de creare a fluxului de lucru
- Introduceți numele fluxului de lucru
- Selectați OK. (lăsați alte proprietăți ca implicite, nu este nevoie să modificați nici o proprietate)
În managerul de flux de lucru va apărea o sarcină de pornire, este un punct de plecare al execuției fluxului de lucru.
Pasul 9 - În managerul fluxului de lucru
- Extindeți folderul sesiuni sub arborele de navigare.
- Trageți și fixați sesiunea pe care ați creat-o în spațiul de lucru al managerului de flux de lucru.
Pasul 10 - Faceți clic pe opțiunea de legare a sarcinii din caseta de instrumente.
Pasul 11 - Conectați sarcina de pornire și sarcina de sesiune utilizând linkul.
Pasul 12 - Faceți dublu clic pe obiectul de sesiune în wokflow manager. Se va deschide o fereastră de activitate pentru a modifica proprietățile activității.
Pasul 13 - În fereastra de editare a sarcinilor
- Selectați fila mapare
- Selectați proprietatea conexiunii
- Atribuiți conexiunea la sursă și țintă, conexiunea pe care am creat-o în pași inițiali.
- Selectați butonul OK
Acum configurația dvs. pentru fluxul de lucru este completă și puteți executa fluxul de lucru.
Cum se adaugă mai multe sarcini la o sarcină de pornire
Sarcina de pornire este un punct de plecare pentru execuția fluxului de lucru. Există două moduri de a lega mai multe sarcini la o sarcină de pornire.
- Paralel
- Serial
În paralel, legarea sarcinilor este legată direct de sarcina de pornire și toate sarcinile încep să se execute în paralel în același timp.
Cum se adaugă sarcini în paralel
Pasul 1 - În managerul fluxului de lucru, deschideți fluxul de lucru „wkf_run_command”
Pasul 2 - În fluxul de lucru, adăugați sarcina de sesiune „s_m_emp_emp_target”. (selectând sesiunea și apoi glisați și fixați)
Pasul 3 - Selectați opțiunea de legătură din caseta de instrumente
Pasul 4 - conectați sarcina sesiunii la sarcina de pornire (făcând clic pe Start taks, ținând apăsat clicul și conectându-vă la sarcina sesiunii)
După conectarea sarcinii sesiunii, fluxul de lucru va arăta astfel.
Pasul 5 - Porniți fluxul de lucru și monitorizați în monitorul fluxului de lucru.
Cum se adaugă sarcini în modul serial
Dar înainte de a adăuga sarcini în modul serial, trebuie să ștergem sarcina pe care am adăugat-o pentru a demonstra executarea paralelă a sarcinii. Pentru asta
Pasul 1 - Deschideți fluxul de lucru „w.kf_run_command”
- Selectați linkul către sarcina sesiunii.
- Selectați opțiunea de editare din meniu
- Selectați opțiunea de ștergere
Pasul 2 - Caseta de dialog de confirmare va apărea într-o fereastră, selectați opțiunea da
Legătura dintre sarcina de pornire și sarcina de sesiune va fi eliminată.
Pasul 3 - Acum mergeți din nou în meniul de sus și selectați opțiunea de activitate a legăturii din caseta de instrumente
Pasul 4 - conectați sarcina de sesiune la sarcina de comandă
După conectare, fluxul de lucru va arăta astfel
Pasul 5 - Pentru a face aspectul vizual al fluxului de lucru mai clar
- Faceți clic dreapta pe wokspace din fluxul de lucru
- Selectați meniul de aranjare
- Selectați opțiunea Orizontală
Dacă porniți fluxul de lucru, sarcina de comandă se va executa mai întâi și după executarea acestuia, va începe sarcina de sesiune.
Variabilă a fluxului de lucru
Variabilele fluxului de lucru permit sarcinilor diferite dintr-un flux de lucru să facă schimb de informații între ele și permite, de asemenea, sarcinilor să acceseze anumite proprietăți ale altor sarcini dintr-un flux de lucru. De exemplu, pentru a obține data curentă, puteți utiliza variabila încorporată „sysdate”.
Cel mai frecvent scenariu este atunci când aveți mai multe sarcini într-un flux de lucru și într-o sarcină accesați variabila altei sarcini. De exemplu, dacă aveți două sarcini într-un flux de lucru și cerința este să executați a doua sarcină numai atunci când prima sarcină este executată cu succes. Puteți implementa un astfel de scenariu utilizând variabila predefinită în fluxul de lucru.
Implementarea scenariului
Am avut un flux de lucru „wkf_run_command” cu sarcini adăugate în modul serial. Acum vom adăuga o condiție la legătura dintre sarcina de sesiune și sarcina de comandă, astfel încât, numai după succesul sarcinii de comandă, sarcina de sesiune să fie executată.
Pasul 1 - Deschideți fluxul de lucru „wkf_run_command”
Pasul 2 - Faceți dublu clic pe legătura dintre sesiune și sarcina de comandă
Va apărea o fereastră Expression
Pasul 3 - Faceți dublu clic pe variabila de stare din meniul „cmd_create_folder”. O variabilă „$ cmd_create_folder.status” va apărea în fereastra editorului din partea dreaptă.
Pasul 4 - Acum vom seta condiția variabilă „$ cmd_create_folder.status” la starea reușită. ceea ce înseamnă că atunci când sarcinile anterioare sunt executate și execuția a avut succes, atunci executați doar sarcina următoarei sesiuni.
- Schimbați variabila la valoarea "$ cmd_create_folder.status = SUCCEEDED".
- Faceți clic pe butonul OK
Fluxul de lucru va arăta astfel
Când executați acest flux de lucru, sarcina de comandă se execută mai întâi și numai atunci când reușește, atunci numai sarcina de sesiune va fi executată.
Parametru flux de lucru
Parametrii fluxului de lucru sunt acele valori care rămân constante pe tot parcursul alergării. odată ce valoarea lor este atribuită, aceasta rămâne aceeași. Parametrii pot fi utilizați în proprietățile fluxului de lucru, iar valorile lor pot fi definite în fișiere de parametri. De exemplu, în loc să utilizați o valoare de conexiune codificată, puteți utiliza un parametru / variabilă în numele conexiunii și valoarea poate fi definită în fișierul de parametri.
Fișierele de parametri sunt fișierele în care definim valorile variabilelor sau parametrilor de mapare / flux de lucru. Fișierele au extensia „.par”. Ca standard general, se creează un fișier de parametri pentru un flux de lucru.
Avantajele fișierului Parameter
- Ajută la migrarea codului dintr-un mediu în altul
- Permite depanarea și testarea ușoară
- Valorile pot fi modificate cu ușurință fără schimbarea codului
Structura fișierului de parametri
Structura fișierului de parametri
- [folder_name.WF:Workflow_name]
- $ Numele_parametru = Valoarea_parametru
Folder_name este numele folderului depozit, numele fluxului de lucru este numele fluxului de lucru pentru care creați fișierul de parametri.
Vom crea un fișier de parametri pentru conexiunea la baza de date „guru99” pe care l-am atribuit în primele noastre sesiuni pentru surse și ținte.
Cum se creează un fișier de parametri
Pasul 1 - Creați un nou fișier gol (fișier notepad)
Pasul 2 - În fișier introduceți textul așa cum se arată în figură
Pasul 3 - Salvați fișierul sub un folder guru99 la locația „C: \ guru99” ca „wkf_run_command.par”
În fișierul în care am creat un parametru „$ DBConnection_SRC”, vom atribui același lucru unei conexiuni din fluxul nostru de lucru.
Pasul 4- Deschideți fluxul de lucru „wkf_run_command”
- Selectați meniul fluxurilor de lucru
- Selectați opțiunea de editare
Pasul 5 - Aceasta va deschide fereastra de editare a fluxului de lucru, în această fereastră
- Accesați meniul din fila Proprietăți
- Introduceți numele fișierului parametru ca „c: \ guru99 \ wkf_run_command.par”
- Selectați butonul OK
Acum am terminat cu definirea conținutului fișierului de parametri și îl îndreptăm către un flux de lucru.
Următorul pas este să utilizați parametrul în sesiune.
Pasul 6 - În fluxul de lucru faceți dublu clic pe sesiunea „s_m_emp_emp_target”, apoi
- Selectați meniul filei mapări
- Selectați proprietatea conexiunii în panoul din stânga
- Faceți clic pe conexiunea țintă, care este codificată acum ca „guru99”
Pasul 7 - În fereastra respectivă va apărea o fereastră de browser de conexiune
- Selectați opțiunea de a utiliza variabila de conexiune
- Introduceți numele variabilei de conexiune ca „$ DBConnection_SRC”
- Selectați butonul Ok
Pasul 8 - În fereastra de editare a sarcinii va apărea variabila de conexiune pentru țintă, selectați butonul OK din fereastra de editare a activității.
Acum am terminat cu crearea parametrului pentru o conexiune și atribuirea valorii acestuia la fișierul de parametri.
Când executăm fluxul de lucru, fluxul de lucru alege fișierul cu parametri caută valoarea parametrilor / variabilelor sale în fișierul cu parametri și ia aceste valori.