Proprietățile sesiunii în Informatica: Tutorial complet

⚡ Rezumat inteligent

Proprietățile sesiunii din Informatica controlează modul și momentul în care Integration Service mută rândurile de la sursă la țintă, acoperind punctele de validare, fișierele jurnal, alocarea memoriei, gestionarea erorilor și conexiunile pe care le mapează.ping utilizări în timpul execuției.

  • 🔘 Noțiuni de bază despre sesiune: O sesiune este o sarcină legată de o singură hartăping, care nu pot fi schimbate odată ce au fost atribuite.
  • ☑️ Tratați rândurile sursă ca: Inserare, Actualizare, Ștergere și Funcțiile bazate pe date decid dacă rândurile sunt adăugate, modificate sau eliminate.
  • ✅ Cheia principala: Execuțiile de actualizare și ștergere necesită o cheie primară în tabelul țintă înainte ca modificările să se aplice.
  • 🧪 Sarcina de testare: Rândurile sunt citite din sursă, dar niciodată scrise, deci o hartăping este verificată în siguranță.
  • 🛠️ Reglarea memoriei: Fila Obiect de configurare expune dimensiunea blocului buffer și lungimea bufferului secvențial pentru lucrări de performanță.
  • 📦 Tip de încărcare: Încărcarea în bloc omite jurnalul bazei de date pentru viteză, în timp ce încărcarea normală face posibilă recuperarea.

Proprietățile sesiunii în Informatica

O sesiune este un set de instrucțiuni care indică companiei Informatica cum și când să mute datele din surse în destinații.

O sesiune este o sarcină, la fel ca celelalte sarcine pe care le creăm în Workflow Manager. Orice sesiune pe care o creați trebuie să aibă un Hartăping asociate cu acesta.

O sesiune poate avea o singură hartăping la un moment dat și odată atribuit, nu poate fi modificat. Pentru a executa o sarcină de sesiune, aceasta trebuie adăugată la o flux de lucru.

O sesiune poate fi un obiect reutilizabil sau nereutilizabil. Când creați o sesiune în Task Developer, aceasta poate fi reutilizată, dar când creați o sesiune în Workflow Designer, aceasta devine nereutilizabilă.

O sesiune reutilizabilă poate fi adăugată la mai multe fluxuri de lucru.

Proprietățile sesiunii

Folosind proprietățile sesiunii, puteți configura diverse caracteristici ale sesiunii, cum ar fi pre și post SQL scripturi, numele și calea fișierului jurnal, proprietățile memoriei etc.

De asemenea, puteți suprascrie hartaping proprietăți din proprietățile sesiunii. În această secțiune, vom discuta următoarele proprietăți importante ale sesiunii.

  • Tratează rândurile sursă ca
  • Interval de comitere
  • Proprietatea fișierului jurnal de sesiune
  • Proprietatea de încărcare de testare
  • Opțiuni de jurnal
  • Gestionarea erorilor
  • Sursă/Target Proprietăţi
  • Conexiuni

Pas 1) Deschideți sesiunea „s_m_emp_emp_target” în Task Developer, pe care am creat-o în tutorialul anterior.

Sesiunea s_m_emp_emp_target este listată în spațiul de lucru Task Developer

Pas 2) Double-faceți clic pe pictograma sesiunii din Task Developer pentru a deschide fereastra Editare sarcină.

Fereastra Editare sarcină s-a deschis pentru sesiune din Dezvoltatorul de sarcini

Pas 3) În fereastra Editare activitate, faceți clic pe fila Proprietăți.

Fila Proprietăți selectată în fereastra Editare activitate a sesiunii

Pas 4) În fila Proprietăți, Informatica afișează proprietățile sesiunii.

Lista completă a proprietăților sesiunii afișată în fila Proprietăți

Tratați rândurile sursă ca proprietate

Această proprietate vă permite să definiți modul în care datele sursă afectează tabelul țintă. De exemplu, puteți defini ca înregistrarea sursă să fie inserată sau ștearsă din țintă.

Această proprietate are patru opțiuni -

  • Insera
  • Actualizează
  • Șterge
  • Date bazate pe date

Toate cele patru opțiuni se află într-un meniu derulant lângă numele proprietății.

Tratați rândurile sursă ca o listă derulantă cu opțiunile Inserare, Actualizare, Ștergere și Bazat pe date

  • Când această proprietate este setată la inserare, datele sursă vor fi marcate pentru a fi inserate. Aceasta înseamnă că datele vor fi doar inserate.
  • Când proprietatea este setată să se actualizeze, datele țintă vor fi actualizate de datele sursă. Pentru actualizarea datelor, trebuie definită o cheie primară în tabelul țintă.
  • Când proprietatea este setată la ștergere, datele sursă care sunt deja prezente în tabelul țintă vor fi șterse din tabelul țintă. Pentru ca această proprietate să se execute și să aplice modificările, cheia primară trebuie definită în tabelul țintă.
  • Cu proprietatea setată la Data based (Bazat pe date), Informatica verifică ce înregistrări sursă sunt marcate. Dacă înregistrările sursă sunt marcate ca inserate într-o hartăping, atunci înregistrările vor fi inserate în țintă. Dacă înregistrările sunt marcate ca actualizare în hartăping, atunci înregistrările vor fi actualizate în țintă. Deci operațiunea efectuată la țintă depinde de modul în care înregistrările sunt gestionate în interiorul hărțiiping.

Opțiunea bazată pe date este alegerea momentului în care hartaping conține o transformare Actualizare strategie, deoarece acea transformare semnalizează fiecare rând individual.

Cum se creează rânduri cu surse de tratamente – Ștergere

Pas 1) În fila Proprietăți a activității sesiunii:

  1. Selectați opțiunea „Ștergere” din „Tratează rândurile sursă ca”
  2. Selectați butonul OK

Ștergeți opțiunile alese în secțiunea Tratați rândurile sursă ca proprietate a sesiunii

Pas 2) Pentru a defini o cheie primară în tabelul țintă, deschideți Informatica Designer.

  1. Operatii Deschise Target proiectant
  2. Double-faceți clic pe tabelul „emp_target”

tabelul emp_target deschis din Target Designer în cadrul Informatica Designer

Aceasta va deschide o fereastră „Editare tabel” pentru tabelul țintă.

Pas 3) În fereastra de editare a tabelului țintă:

  1. Pentru coloana EmpNr, selectați tipul de cheie „cheie primară” din meniul derulant și
  2. Selectați butonul OK.

Coloana EmpNo este setată la cheia primară în fereastra Editare tabel a emp_target

Pas 4) Salvați modificările în Informatica și executați fluxul de lucru pentru această hartăping.

Când executați această hartăping, înregistrările sursă care sunt deja prezente în țintă vor fi șterse.

Interval de comitere – Proprietate

Această proprietate definește intervalul după care Informatica efectuează o operațiune de validare a datelor către tabelul țintă.

De exemplu, dacă inserați 20,000 de înregistrări într-un tabel țintă și definiți intervalul de comitere ca 5,000, atunci după fiecare 5,000 de inserări de înregistrări în țintă, va fi efectuată o operație de comitare.

Intervalul implicit este de 10,000 de rânduri, iar tipul de commit poate fi setat la bazat pe țintă sau pe sursă.

Câmpurile pentru tipul de validare și intervalul de validare afișate în fila Proprietăți sesiunii

Numele fișierului jurnal de sesiune și directorul fișierului jurnal de sesiune

Configurați această proprietate pentru a modifica

  • Numele fișierului jurnal de sesiune implicit și
  • Calea fișierului jurnal

`$PMSessionLogDir\` este o variabilă Informatica și este activată Windows Acesta indică următoarea locație implicită „C:\Informatica\9.6.1\server\infa_shared\SessLogs”.

Câmpurile numelui fișierului jurnal de sesiune și directorului fișierului jurnal de sesiune din proprietățile sesiunii

Activați încărcarea de testare

Folosind această proprietate, puteți testa sesiunea și hartapingCând utilizați această funcție și executați sesiunile, înregistrările sunt preluate din surse, dar nu sunt încărcate în țintă. Așadar, această funcție ajută la de testare corectitudinea hărțiipings, fișiere de parametri și funcționarea diverselor transformări în interiorul hărțiiping.

Dacă activați această funcție, există o altă proprietate – Număr de rânduri de testat – care ar trebui configurată pentru numărul de înregistrări pe care doriți să fie preluate din sursă pentru încărcarea de test.

Activați caseta de selectare a încărcării de testare cu câmpul Număr de rânduri de testat lângă ea

Proprietăți memorie

Proprietățile de memorie ne oferă flexibilitatea de a regla fin memoria alocată Informatica pentru optimizări de performanță. Atunci când există blocaje mari și performanța este slabă, puteți încerca să îmbunătățiți performanța utilizând proprietățile de memorie.

Pentru a configura proprietățile memoriei, faceți clic pe fila Config Object din fereastra Edit Task. Aceasta va deschide o altă fereastră unde puteți configura modificările.

Fila Obiect de configurare selectată în fereastra Editare activitate a sesiunii

În această secțiune, puteți configura proprietățile memoriei. De exemplu, dimensiunea implicită a blocului buffer, lungimea bufferului secvențial etc. Modificările aduse acestor proprietăți determină câtă memorie ar trebui alocată serviciilor Informatica pentru funcționarea lor.

Câmpurile pentru dimensiunea implicită a blocului tampon și lungimea tamponului secvențial din fila Obiect de configurare

Opțiuni de jurnalizare

În această secțiune de proprietăți, puteți configura proprietățile jurnalului sesiunii. Puteți seta câte jurnale doriți să salvați pentru o sesiune și dimensiunea maximă a fișierului jurnal al sesiunii.

Grupul de opțiuni de jurnal care afișează setările jurnalului de salvare a sesiunii și dimensiunea maximă a fișierului jurnal

Gestionarea erorilor

În această secțiune, puteți configura proprietățile de eroare pentru sesiune.

Folosind opțiunea Oprire la erori, puteți configura după câte erori trebuie oprită sesiunea.

Utilizarea suprascrierii tracing, poți suprascrie hartaping tracniveluri de ing.

De asemenea, puteți configura comportamentul sesiunii pentru diverse erori întâlnite, de exemplu, eroare de procedură stocată, eroare SQL pre-post etc.

Grupul de gestionare a erorilor din fila Obiect de configurare cu câmpul oprire la erori

Hartăping și Sursă/Target Proprietăţi

În Hartăping din fereastra Editare activitate, puteți configura proprietățile hărțiiping și a surselor, țintelor și transformărilor sale. Numele tabelelor pot fi suprascrise, iar prefixele numelor tabelelor pot fi aplicate aici, iar proprietățile transformării sunt setate în interiorul hărții.ping pot fi revizuite și, de asemenea, anulate. Este un singur loc pentru a le revizui pe toate.

Hartăping fila din fereastra Editare activitate care listează sursele, țintele și transformările

Proprietăți de conexiune în hartăping

Folosind această proprietate, puteți defini conexiuni la baza de date pentru surse și destinații.

Browser de conexiuni relaționale utilizat pentru a seta conexiunile sursă și țintă

Proprietăți sursei

În această secțiune, puteți configura proprietățile legate de sursa hărții.pingPuteți configura scripturi SQL pre și post pentru sursă.

Folosind proprietatea de interogare SQL, puteți suprascrie codul SQL pentru sursă. De asemenea, puteți suprascrie numele tabelului sursă în această secțiune.

Panoul proprietăților sursă care afișează suprascrierile numelui interogării SQL și al tabelului sursă

Target Proprietăţi

În această secțiune, puteți configura detaliile țintei. Puteți defini dacă sarcina țintă trebuie să fie o încărcare în vrac sau o încărcare normală.

Target tipul de sarcină Ce înseamnă pentru alergare
Normal Rândurile sunt scrise prin jurnalul bazei de date, deci încărcarea este mai lentă, dar recuperarea bazei de date după o eroare este posibilă.
masă Bufferele jurnalului de refacere sunt ocolite, deci încărcarea este mai rapidă, dar recuperarea încărcării eșuate nu este disponibilă.

De asemenea, puteți defini proprietatea de a trunchia tabelul țintă înainte de a-l popula, astfel încât tabelul să fie golit mai întâi, iar încărcarea să se execute ulterior. Această proprietate este utilă atunci când creăm o hartă.pings pentru sarcina etapei.

De asemenea, putem defini tabelul țintă pre SQL și post SQL. Pre SQL este porțiunea de cod SQL care va fi executată înainte de inserarea în tabelul țintă, iar codul post SQL va fi executat după finalizarea încărcării tabelului țintă.

Target panoul de proprietăți cu tipul de încărcare țintă, opțiunea de trunchiere și câmpurile SQL pre și post

Succesul sau eșecul sarcinii sesiunii

Când un flux de lucru conține mai multe sesiuni, una sau mai multe dintre ele pot eșua, în timp ce restul reușesc, ceea ce ridică întrebarea despre starea fluxului de lucru. Pentru a gestiona astfel de condiții, Informatica oferă o proprietate specifică eșecului în cadrul fluxului de lucru. Pentru a configura un astfel de comportament –

Pas 1) Deschideți fluxul de lucru „wkf_run_command”, pe care l-am creat anterior.

Fluxul de lucru wkf_run_command s-a deschis în Workflow Manager cu comanda și sarcinile sale de sesiune

Pas 2) Double-faceți clic pe sarcina de comandă. Aceasta va deschide fereastra Editare sarcină.

  1. Selectați fila General
  2. Bifați caseta de selectare de lângă proprietatea „eșuează părintele dacă această sarcină eșuează”.
  3. Selectați butonul OK

Eșuează opțiunea părinte dacă această sarcină eșuează selectată în fila General a sarcinii de comandă

Pas 3) Double-faceți clic pe sarcina sesiunii. Aceasta va deschide fereastra Editare sarcină.

  1. Selectați fila General
  2. Bifați caseta de selectare de lângă proprietatea „eșuează părintele dacă această sarcină eșuează”.
  3. Selectați butonul OK

Eșuează opțiunea părinte dacă această sarcină eșuează selectată în fila General a sarcinii de sesiune

Pas 4) Salvați modificările folosind comanda rapidă Ctrl+S.

Când executați acest flux de lucru după efectuarea modificărilor de mai sus, dacă vreuna dintre sarcini eșuează, starea fluxului de lucru va fi setată la eșuat, astfel încât să puteți identifica faptul că în timpul executării fluxului de lucru unele dintre sarcinile sale au eșuat.

Întrebări frecvente

Da. O sesiune creată în Task Developer este reutilizabilă și poate fi plasată în mai multe fluxuri de lucruUn element creat în Workflow Designer rămâne nereutilizabil și aparține exclusiv acelui flux de lucru.

Serviciul de integrare construiește clauza WHERE a instrucțiunii UPDATE sau DELETE generate din coloanele cheie. Fără o cheie primară în definiția țintă, niciun rând nu se potrivește și nimic nu se schimbă.

Marchează fiecare rând ca inserare, actualizare, ștergere sau respingere în interiorul transformare pipeline, motiv pentru care sesiunea trebuie să ruleze cu opțiunea „Bazat pe date” selectată.

Grupează un calificator sursă cu țintele pe care le alimentează, astfel încât tabelele înrudite se încarcă într-o secvență aleasă, iar rândurile părinte sunt la locul lor înainte de sosirea rândurilor copil.

Citiți jurnalul de sesiune pentru procentele de ocupare ale firelor de execuție ale cititorului, transformării și scriitorului. Firul de execuție cel mai aglomerat este adevăratul blocaj și numai atunci merită atenție setările bufferului.

Da. Nume de conexiuni, directoare sursă și hartăping Parametrii sunt citiți dintr-un fișier de parametri la momentul execuției, astfel încât un obiect rulează neatins pe parcursul dezvoltării, testării și producției.

Modelele de învățare automată din platformele ETL moderne profilează istoricul execuțiilor, prevăd care etapă devine blocajul și recomandă partiționarea sau modificările de memorie, înlocuind încercările manuale de tip „trial and error”.

Da. Copilot-ul redactează SQL care rulează înainte sau după o încărcare, cum ar fi eliminarea indexului, instrucțiunile trunchiate și inserările de audit. Fiecare instrucțiune generată necesită în continuare o revizuire a schemei.

Rezumați această postare cu: