סקירה כללית על Cloud Data Fusion

‫Cloud Data Fusion מאפשר לכם ליצור ולתזמן Data pipelines בשירות שילוב נתונים מבוסס-ענן ומנוהל במלואו, שמבוסס על פרויקט הקוד הפתוח CDAP. באמצעות ממשק האינטרנט של Cloud Data Fusion, אתם יכולים להתחבר למקורות נתונים, לשנות את הנתונים ולהעביר אותם למערכות יעד בלי לנהל את התשתית.

תחילת העבודה עם Cloud Data Fusion

אפשר להתחיל להשתמש ב-Cloud Data Fusion תוך דקות.

התנסות ב-Cloud Data Fusion

בקטעים הבאים מוסברים הרכיבים העיקריים של Cloud Data Fusion.

פרויקט של דייר (tenant)

קבוצת השירותים שנדרשים כדי ליצור ולתזמר צינורות עיבוד נתונים ב-Cloud Data Fusion, ולאחסן מטא-נתונים של צינורות עיבוד נתונים, מוקצים בפרויקט דייר (tenant) בתוך יחידת דיירים. לכל פרויקט של לקוח נוצר פרויקט נפרד של דייר, שבו מוקצים מופעים של Cloud Data Fusion. פרויקט הדייר (tenant) יורש את כל הגדרות הרשת וחומת האש מהפרויקט של הלקוח.

‫Cloud Data Fusion: מסוף

מסוף Cloud Data Fusion, שנקרא גם מישור הבקרה, הוא אוסף של פעולות API וממשק אינטרנט שמתייחסים למופע Cloud Data Fusion עצמו, כמו יצירה, מחיקה, הפעלה מחדש ועדכון שלו.

‫Cloud Data Fusion: Studio

‫Cloud Data Fusion Studio, שנקרא גם מישור הנתונים, הוא קבוצה של פעולות של ממשק API בארכיטקטורת REST וממשק אינטרנט שקשורות ליצירה, להפעלה ולניהול של צינורות עיבוד נתונים ופריטי מידע שקשורים אליהם.

מושגים

בקטע הזה נציג כמה מהמושגים העיקריים של Cloud Data Fusion.

קונספט תיאור
מכונת Cloud Data Fusion‏
  • מכונה של Cloud Data Fusion היא פריסה ייחודית של Cloud Data Fusion. כדי להתחיל להשתמש ב-Cloud Data Fusion, יוצרים מכונה של Cloud Data Fusion דרך מסוף Google Cloud .
  • אפשר ליצור כמה מכונות בפרויקט אחד במסוף Google Cloud , ולציין את האזור ב- Google Cloud שבו רוצים ליצור את המכונות של Cloud Data Fusion.
  • בהתאם לדרישות ולמגבלות העלויות, אפשר ליצור מופע של Developer,‏ Basic או Enterprise.
  • כל מכונה של Cloud Data Fusion מכילה פריסה ייחודית ועצמאית של Cloud Data Fusion, שכוללת קבוצת שירותים שמטפלים בניהול מחזור החיים של צינור עיבוד הנתונים, בתזמור, בתיאום ובניהול המטא-נתונים. השירותים האלה פועלים באמצעות משאבים לטווח ארוך בפרויקט של דייר.
מרחב שמות מרחב שמות הוא קיבוץ לוגי של אפליקציות, נתונים והמטא-נתונים המשויכים להם במופע של Cloud Data Fusion. אפשר לחשוב על מרחבי שמות כחלוקה של המכונה. במופע יחיד, מרחב שמות אחד מאחסן את הנתונים והמטא-נתונים של ישות באופן עצמאי ממרחב שמות אחר.
פייפליין
  • צינור עיבוד נתונים הוא דרך לתכנן באופן חזותי את תהליכי הנתונים והבקרה כדי לחלץ, לשנות, למזג, לצבור ולטעון נתונים ממקורות נתונים שונים בענן ובמקום פיזי.
  • יצירת פייפליינים מאפשרת לכם ליצור תהליכי עבודה מורכבים לעיבוד נתונים, שיכולים לעזור לכם לפתור בעיות שקשורות להטמעת נתונים, לשילוב ולהעברה של נתונים. אתם יכולים להשתמש ב-Cloud Data Fusion כדי ליצור צינורות נתונים באצווה וגם צינורות נתונים בזמן אמת, בהתאם לצרכים שלכם.
  • באמצעות צינורות עיבוד נתונים אפשר לבטא את תהליכי העבודה של עיבוד הנתונים באמצעות הזרימה הלוגית של הנתונים, ו-Cloud Data Fusion מטפל בכל הפונקציונליות שנדרשת כדי להריץ פיזית בסביבת הפעלה.
צומת הפייפליין
  • בדף Studio בממשק האינטרנט של Cloud Data Fusion, צינורות עיבוד הנתונים מיוצגים כסדרה של צמתים שמסודרים בגרף אציקלי מכוון (DAG), ויוצרים תהליך חד-כיווני.
  • הצמתים מייצגים את הפעולות השונות שאפשר לבצע באמצעות צינורות עיבוד הנתונים, כמו קריאה ממקורות, ביצוע טרנספורמציות של נתונים וכתיבת פלט לכיורים. אתם יכולים לפתח צינורות עיבוד נתונים בממשק האינטרנט של Cloud Data Fusion על ידי חיבור של מקורות, טרנספורמציות, sink וצמתים אחרים.
פלאגין
  • פלאגין הוא מודול שניתן להתאמה אישית, שמאפשר להרחיב את היכולות של Cloud Data Fusion.
  • ‫Cloud Data Fusion מספקת תוספים למקורות, לטרנספורמציות, לצבירות, ליעדים, לאוספי שגיאות, לפרסום התראות, לפעולות ולפעולות אחרי הרצה.
  • לפעמים פלאגין נקרא צומת, בדרך כלל בהקשר של ממשק האינטרנט של Cloud Data Fusion.
  • במאמר יישומי פלאגין של Cloud Data Fusion מוסבר איך למצוא את יישומי הפלאגין הפופולריים של Cloud Data Fusion ולהשתמש בהם.
מרכז המכשירים שלי בממשק האינטרנט של Cloud Data Fusion, לוחצים על Hub כדי לעיין בפלאגינים, בצינורות עיבוד נתונים לדוגמה ובשילובים אחרים. כשיוצאת גרסה חדשה של פלאגין, היא מופיעה ב-Hub בכל מכונה תואמת. זה נכון גם אם המכונה נוצרה לפני שהפלאגין פורסם.
תצוגה מקדימה של צינור עיבוד הנתונים
  • ב-Cloud Data Fusion Studio אפשר לבדוק את הדיוק של עיצוב צינור עיבוד הנתונים באמצעות תצוגה מקדימה על קבוצת משנה של נתונים.
  • צינור (pipeline) בתצוגה מקדימה פועל בפרויקט הדייר.
הרצה של צינור עיבוד נתונים
  • ‫Cloud Data Fusion יוצר סביבות הפעלה זמניות כדי להפעיל צינורות עיבוד נתונים.
  • ‫Cloud Data Fusion תומך ב-Managed Service for Apache Spark כסביבת הפעלה
  • ‫Cloud Data Fusion מקצה אשכול זמני של Managed Service for Apache Spark בפרויקט של הלקוח בתחילת ההרצה של צינור הנתונים, מריץ את צינור הנתונים באמצעות Spark באשכול, ואז מוחק את האשכול אחרי שההרצה של צינור הנתונים מסתיימת.
  • לחלופין, אם אתם מנהלים את אשכולות Managed Service for Apache Spark בסביבות מבוקרות, באמצעות טכנולוגיות כמו Terraform, אתם יכולים גם להגדיר את Cloud Data Fusion כך שלא יקצה אשכולות. בסביבות האלה, אתם יכולים להריץ צינורות עיבוד נתונים באשכולות קיימים של Managed Service for Apache Spark.
פרופיל המחשוב
  • פרופיל מחשוב מציין איך ואיפה מופעל צינור עיבוד נתונים. פרופיל כולל את כל המידע שנדרש כדי להגדיר ולמחוק את סביבת ההפעלה הפיזית של צינור עיבוד נתונים.
  • לדוגמה, פרופיל מחשוב כולל את הפרטים הבאים:
    • Execution provisioner
    • משאבים (זיכרון ומעבד)
    • מספר הצמתים המינימלי והמקסימלי
    • ערכים אחרים
  • פרופיל מזוהה לפי שם, וחובה להקצות לו ספק הקצאות ואת ההגדרה שקשורה אליו. פרופיל יכול להיות ברמת המכונה של Cloud Data Fusion או ברמת מרחב השמות.
  • פרופיל ברירת המחדל של Cloud Data Fusion הוא Autoscaling.
פייפליין לשימוש חוזר
  • צינורות נתונים לשימוש חוזר ב-Cloud Data Fusion מאפשרים ליצור פייפליין אחד שיכול להחיל דפוס שילוב נתונים על מגוון תרחישי שימוש ומערכי נתונים.
  • צינורות עיבוד נתונים לשימוש חוזר מאפשרים ניהול טוב יותר, כי רוב ההגדרות של צינור עיבוד הנתונים נקבעות בזמן ההפעלה, במקום להגדיר אותן בתוך הקוד בזמן התכנון.
טריגר
  • ב-Cloud Data Fusion אפשר ליצור טריגר בפייפליין (שנקרא פייפליין במורד הזרם), כדי להריץ אותו בסיום של פייפליין אחד או יותר (שנקראים פייפליינים במעלה הזרם). אתם בוחרים מתי צינור הנתונים במורד הזרם יפעל – למשל, אם הפעלת צינור הנתונים במעלה הזרם תצליח, תיכשל או תיפסק, או כל שילוב אחר של האפשרויות האלה.
  • טריגרים שימושיים במקרים הבאים:
    • ניקוי הנתונים פעם אחת, ואז הפיכתם לזמינים לשימוש בכמה צינורות בהמשך.
    • שיתוף מידע, כמו ארגומנטים של זמן ריצה והגדרות פלאגינים, בין צינורות עיבוד נתונים. זה נקרא הגדרת המטען הייעודי (payload).
    • הגדרת קבוצה של צינורות עיבוד נתונים דינמיים שיכולים לפעול באמצעות הנתונים של השעה, היום, השבוע או החודש, במקום להשתמש בצינור עיבוד נתונים סטטי שצריך לעדכן בכל הפעלה.

משאבים של Cloud Data Fusion

עיון במשאבי Cloud Data Fusion:

המאמרים הבאים