מה זה Pub/Sub?

‫Pub/Sub הוא שירות אסינכרוני וניתן להתאמה להעברת הודעות, שמפריד בין השירותים שמפיקים את ההודעות לבין השירותים שמעבדים אותן.

שירות Pub/Sub מאפשר לשירותים לתקשר באופן אסינכרוני, עם זמני אחזור של כ-100 אלפיות השנייה בדרך כלל.

‫Pub/Sub משמש לניתוח נתונים בזמן אמת ולצינורות עיבוד נתונים של שילוב נתונים כדי לטעון ולהפיץ נתונים. הוא יעיל באותה מידה כתוכנת תווך (middleware) מבוססת-הודעות לשילוב שירותים, או כתור להפעלת משימות במקביל.

בעזרת Pub/Sub אפשר ליצור מערכות של יצרני אירועים וצרכני אירועים, שנקראים אפליקציות לשליחת הודעות ואפליקציות רשומות. בעלי התוכן הדיגיטלי מתקשרים עם המנויים באופן אסינכרוני על ידי שידור אירועים, ולא באמצעות קריאות לשירות מרוחק (RPC) באופן סינכרוני.

בעלי תוכן דיגיטלי שולחים אירועים לשירות Pub/Sub, בלי קשר לאופן או למועד שבו האירועים האלה יעובדו. לאחר מכן, Pub/Sub מעביר את האירועים לכל השירותים שמגיבים להם. במערכות שמתקשרות באמצעות RPC, בעלי התוכן הדיגיטלי צריכים לחכות עד שהמנויים יקבלו את הנתונים. עם זאת, השילוב האסינכרוני ב-Pub/Sub מגביר את הגמישות והעמידות של המערכת הכוללת.

כדי להתחיל להשתמש ב-Pub/Sub, תוכלו להיעזר במדריך למתחילים לשימוש במסוף Cloud de Confiance . למבוא מקיף יותר, קראו את המאמר בניית מערכת העברת הודעות ב-Pub/Sub.

תרחישים נפוצים לדוגמה

  • הטמעת אינטראקציות של משתמשים ואירועים בשרת. כדי להשתמש באירועים של אינטראקציות של משתמשים מאפליקציות של משתמשי קצה או באירועי שרת מהמערכת, אפשר להעביר אותם ל-Pub/Sub. לאחר מכן תוכלו להשתמש בכלי לעיבוד זרמי נתונים (stream processing) כדי להעביר את האירועים למסדי נתונים. בעזרת Pub/Sub אפשר לאסוף אירועים מהרבה לקוחות בו-זמנית.
  • הפצת אירועים בזמן אמת. אירועים, גולמיים או מעובדים, יכולים להיות זמינים למספר אפליקציות בצוות ובארגון שלכם לעיבוד בזמן אמת. ‫Pub/Sub תומך ב-"enterprise event bus" ובתבניות עיצוב של אפליקציות מבוססות-אירועים. באמצעות Pub/Sub אפשר לשלב מערכות רבות שמייצאות אירועים ל-Pub/Sub.
  • שכפול נתונים בין מסדי נתונים. לרוב משתמשים ב-Pub/Sub כדי להפיץ אירועי שינוי ממסדי נתונים. אפשר להשתמש באירועים האלה כדי ליצור תצוגה של מצב מסד הנתונים והיסטוריית המצבים.
  • עיבוד מקביל ותהליכי עבודה. כדי לחלק ביעילות הרבה משימות בין כמה עובדים, אפשר להשתמש בהודעות Pub/Sub כדי לתקשר עם העובדים. דוגמאות למשימות כאלה: דחיסת קובצי טקסט, שליחת התראות באימייל, הערכת מודלים של AI ושינוי הפורמט של תמונות.
  • אוטובוס אירועים ארגוני. אתם יכולים ליצור אפיק לשיתוף נתונים בזמן אמת ברמת הארגון, ולהפיץ אירועים עסקיים, עדכונים של מסדי נתונים ואירועי ניתוח נתונים ברחבי הארגון.
  • סטרימינג של נתונים מאפליקציות ומשירותים. לדוגמה, אפליקציית SaaS יכולה לפרסם פיד של אירועים בזמן אמת. לחלופין, חיישן ביתי יכול להעביר נתונים בסטרימינג ל-Pub/Sub לשימוש במוצרים אחרים של Cloud de Confiance by S3NS באמצעות צינור עיבוד נתונים.
  • רענון של מטמונים מבוזרים. לדוגמה, אפליקציה יכולה לפרסם אירועי ביטול כדי לעדכן את המזהים של אובייקטים שהשתנו.
  • איזון עומסים לאמינות. לדוגמה, יכול להיות שמכונות של שירות מסוים פרוסות ב-Compute Engine בכמה אזורים, אבל הן נרשמות לנושא משותף. אם השירות נכשל באחד מהאזורים, האזורים האחרים יכולים לקחת על עצמם את העומס באופן אוטומטי.

השלבים הבאים