የቴክኒክ መመሪያ

Apache የአየር ፍሰት ለኤምኤል የስራ ፍሰቶች

Apache Airflow የስራ ሂደቶችን እንደ ኮድ ለመጻፍ፣ ለማቀድ እና ለመቆጣጠር ክፍት ምንጭ መድረክ ነው።

2 ሚን አንብብለመጨረሻ ጊዜ የዘመነው

አጠቃላይ እይታ

In machine learning it acts as the conductor that triggers data pipelines, retraining jobs, and batch predictions on a reliable schedule.

ጥልቅ ዳይቭ

የአየር ፍሰት በ2014 በAirbnb የተፈጠረ ሲሆን አሁን የApache ፕሮጀክት ነው። ማእከላዊው አብስትራክት DAG፡ Directed Acyclic Graph of tasks ነው በ Python ውስጥ የተገለጹ፣ ጠርዞቹ የማስፈጸሚያ ቅደም ተከተል እና ጥገኞችን የሚያዘጋጁበት። መርሐግብር አውጪው እነዚህን DAGs ይተነትናል፣ የትኞቹ ተግባራት ዝግጁ እንደሆኑ ይወስናል፣ እና ወደ ፈጻሚዎች እና ሰራተኞች ይልካቸዋል፤ የድር UI የአሂድ ታሪክን፣ ምዝግብ ማስታወሻዎችን እና የተግባር ሁኔታን ያሳያል። ለኤምኤል የአየር ፍሰት ከኮምፒዩተር ሞተር ይልቅ እንደ ኦርኬስትራ በሰፊው ጥቅም ላይ ይውላል፡ እራሱን ሞዴሎችን አያሠለጥንም ነገር ግን እንደ መረጃ ማውጣት፣ ማረጋገጥ፣ በስፓርክ ወይም በኩበርኔትስ ፖድ ላይ የስልጠና ስራን መጀመር እና ውጤቱን ማሰማራት ያሉ እርምጃዎችን ያነሳሳል። ኦፕሬተሮች እና ዳሳሾች ተግባራት ውጫዊ ስርዓቶችን እንዲጠሩ፣ ፋይሎችን እንዲጠብቁ ወይም መያዣዎችን እንዲያሄዱ ያስችላቸዋል። ጥንካሬው አስተማማኝ መርሐግብር ማስያዝ፣ እንደገና መሞከር፣ ወደ ኋላ መሙላት እና ወደ ውስብስብ፣ ጊዜ-ተኮር የቧንቧ መስመሮች ግልጽ ታይነት ነው።

ቴክኒካዊ ግንዛቤ

የአየር ፍሰት DAG የፓይዘን ኮድ ብቻ ነው፣ ስለዚህ ጥገኞች በፕሮግራማዊ መንገድ የሚገለጹት በቢትሺፍት አገባብ ወይም በተግባር ኤፒአይዎች በሰንሰለት ከተያዙ ኦፕሬተሮች ጋር ነው። መርሐግብር አውጪው እያንዳንዱን የDAG የጊዜ ሰሌዳ ክፍተት እና የተግባር ጥገኞችን ያለማቋረጥ ይገመግማል፣የላይ ጥገኞች የተሳካላቸው ተግባራትን ብቻ ይሰለፋል። እንደ ሴሊሪ ወይም ኩበርኔትስ ያሉ አስፈፃሚዎች እነዚህን ተግባራት በተከፋፈሉ ሰራተኞች ላይ ያካሂዳሉ። እያንዳንዱ የተግባር ሂደት በግዛት፣ በምዝግብ ማስታወሻዎች እና በእንደገና ሎጂክ ክትትል ይደረግበታል፣ እና ሜታዳታ ለሙሉ ኦዲትነት በመጠባበቂያ ዳታቤዝ ውስጥ ይከማቻል።

ስልታዊ ተጽእኖ

ወጪ እና በጀት

የስነ-ህንፃ ውሳኔዎች ለዓመታት አፈጻጸምን እና የሥራ ማስኬጃ ወጪዎችን ያንቀሳቅሳሉ.

ግልጽ ውሳኔዎች

የቴክኒክ ትምህርት ቡድኖች አዲሱን ብቻ ሳይሆን ትክክለኛውን ቁልል እንዲመርጡ ይረዳል።

የጥራት ቁጥጥር

የተሻሉ የምህንድስና ምርጫዎች በምርት ውስጥ አስተማማኝነት ክስተቶችን ይቀንሳሉ.

ለኤምኤል የስራ ፍሰቶች የApache የአየር ፍሰት የወደፊት ጊዜ

የአየር ፍሰት 2.x እና 3.x ፈጣን የጊዜ መርሐግብርን አጽንዖት ይሰጣሉ፣ ለተግባር ፍሎ ኤፒአይ ለጠራ የፓይዘን ቧንቧዎች፣ እና DAGs ከቋሚ ሰዓቶች ይልቅ የውሂብ ስብስብ ማሻሻያዎችን የሚቀሰቅሱበት መረጃን የሚያውቅ መርሐግብር ላይ ያተኩራሉ። ለኤምኤል፣ ከባህሪ መደብሮች እና ከክስተት-ተኮር ዳግም ስልጠና ጋር ጥብቅ ትስስር ይጠብቁ። የአየር ፍሰት ከነሱ ጋር ከመፎካከር ይልቅ እንደ ዲቢት፣ ስፓርክ እና ኩቤፍሎስ ያሉ ልዩ መሳሪያዎችን የሚያስተባብር የኦርኬስትራ ንብርብር አድርጎ ያስቀምጣል።

የእውነተኛ-ዓለም አተገባበር

አንድ የሚዲያ ኩባንያ የተጠቃሚ-የተሳትፎ ምዝግብ ማስታወሻዎችን የሚስብ፣ የምክር ሞዴልን የሚያሰለጥን እና የአገልግሎት መሸጎጫውን የሚያድስ ዕለታዊ የአየር ፍሰት DAG ይሰራል።

የኢ-ኮሜርስ ቡድን የታችኛው ተፋሰስ ትንበያ ተግባር ከመጀመሩ በፊት የደመና ማከማቻ ውስጥ የሻጭ ውሂብ ፋይል እስኪያርፍ ድረስ ለመጠባበቅ ዳሳሾችን ይጠቀማል።

የፊንቴክ ኩባንያ የአየር ፍሰት በኮንቴይነር የተያዘ ሞዴል አጠራጣሪ ግብይቶችን ለመጠቆም በየሰዓቱ ባች-ውጤት የሚያስገኙ ስራዎችን መርሐግብር ያወጣል።

የውሂብ ቡድን ከአመክንዮ ለውጥ በኋላ የወራትን ታሪካዊ መረጃዎችን በአዲስ ባህሪ-የምህንድስና ቧንቧ ለማቀናበር የአየር ፍሰት የኋላ ሙላዎችን ይጠቀማል።

አደጋዎች እና የጥበቃ መንገዶች

አንድ ቤንችማርክን ማሳደግ ሰፋ ያሉ የስርዓት ድክመቶችን ሊደብቅ ይችላል።

የመሠረተ ልማት እና የጥገና ወጪዎች ብዙ ጊዜ ዝቅተኛ ናቸው.

ስርዓቶች ይበልጥ ውስብስብ ሲሆኑ የደህንነት እና የታዛቢነት ክፍተቶች ሊያድጉ ይችላሉ።

የትግበራ ፍኖተ ካርታ

1

ከመተግበሩ በፊት የቆይታ፣ የጥራት እና የወጪ ግቦችን ይግለጹ።

2

ቤንችማርክ በእውነተኛ ጭነት እና የውሂብ ሁኔታዎች።

3

ለስህተቶች፣ ተንሸራታች እና የተጠቃሚ ተጽእኖ የመሳሪያ ክትትል።

4

ከመጠኑ በፊት የመመለሻ እና የአደጋ ምላሽ መንገዶችን ያዘጋጁ።

ማሰስዎን ይቀጥሉ

Free newsletter

Get the daily AI briefing

Three verified AI stories every weekday morning, written in plain English. Free forever, no ads.

One email each weekday. Unsubscribe in one click. We never sell or share your address.

Test yourself

Take the Apache Airflow for ML Workflows quiz

Instant feedback on every answer, and a shareable certificate with a verifiable ID once you pass a course.

ጥያቄ ጀምር

Support free AI education. AI Understanding is a 501(c)(3) nonprofit — no ads, no paywall, ever. Make a donation

ቀጣይ መመሪያ

Kubernetes ለ ML የስራ ጭነቶች

በተደጋጋሚ የሚጠየቁ ጥያቄዎች

What is Apache Airflow for ML Workflows?

Apache Airflow የስራ ሂደቶችን እንደ ኮድ ለመጻፍ፣ ለማቀድ እና ለመቆጣጠር ክፍት ምንጭ መድረክ ነው። በማሽን መማሪያ ውስጥ የመረጃ ቧንቧዎችን ፣ የስልጠና ስራዎችን እና የቡድን ትንበያዎችን በአስተማማኝ የጊዜ ሰሌዳ ላይ የሚያነቃቃ እንደ መሪ ሆኖ ይሠራል።

በApache Airflow ውስጥ፣ የስራ ሂደትን ለመግለጽ የሚያገለግለው ዋናው ማጠቃለያ ምንድን ነው?

የአየር ፍሰት የስራ ፍሰቶች በፓይዘን ውስጥ እንደ DAGs ይገለፃሉ፣ ተግባራት አንጓዎች ሲሆኑ እና ጠርዞች የማስፈጸሚያ ቅደም ተከተልን ይገልጻሉ።

የአየር ፍሰት በኤምኤል ቧንቧ መስመር ውስጥ ምን ሚና ይጫወታል?

የአየር ፍሰት ኦርኬስትራ ነው፡ እሱ ራሱ ከባድ ስሌት ከማድረግ ይልቅ እንደ ዳታ ማውጣት እና የስልጠና ስራዎችን ያስነሳል እና ያስተባብራል።

የትኛው የአየር ፍሰት ግንባታ ውጫዊ ሁኔታን ለመጠበቅ ጥቅም ላይ ይውላል, ለምሳሌ ወደ ማከማቻ ውስጥ የሚደርሰው ፋይል?

ዳሳሾች እንደ ፋይል ማረፊያ ወይም ክፍልፍል ያለ ሁኔታ እስኪሟላ ድረስ የስራ ሂደትን ባለበት የሚያቆሙ ልዩ ኦፕሬተሮች ናቸው።

የአየር ፍሰት 'backfill' ምን እንዲያደርጉ ይፈቅድልዎታል?

የኋላ መሙላት ከቧንቧ አመክንዮ ለውጥ በኋላ ታሪክን እንደገና ለማቀናበር የሚጠቅም ባለፉት ክፍተቶች ውስጥ DAGን ያስፈጽማል።

DAGsን ያለማቋረጥ የሚገመግመው የትኛው አካል ነው እና የትኞቹ ተግባራት ለመሮጥ ዝግጁ እንደሆኑ ይወስናል?

መርሐግብር አውጪው DAGsን ይመረምራል፣ የጊዜ መርሐግብር ክፍተቶችን እና ጥገኞችን ይፈትሻል፣ እና የወረፋ እርምጃዎቻቸው የተሳካላቸው ተግባራትን ይፈትሻል።