תצוגה מקדימה – BigQuery Connector

השימוש בתכונה הזו כפוף לתנאי השימוש במוצרים בגרסת טרום-GA, שמפורטים בחלק "תנאי שירות הכלליים" בתנאים הספציפיים של השירות. השימוש בתכונות בגרסת טרום-GA הוא "כפי שהן" (As is), ויכול להיות שהתמיכה בהן תהיה מוגבלת. מידע נוסף זמין בקטע תיאור שלבי ההשקה.

Solace

מחבר Solace מספק קישוריות ל-Solace.

לפני שמתחילים

לפני שמשתמשים במחבר Solace, צריך לבצע את המשימות הבאות:

• בפרויקט שלכם ב-Google Cloud:
  • מוודאים שהגדרתם חיבור לרשת. מידע על תבניות רשת זמין במאמר קישוריות לרשת.
  • נותנים למשתמש שמגדיר את המחבר את תפקיד ה-IAM‏ roles/connectors.admin.
  • מקצים לחשבון השירות שרוצים להשתמש בו עבור המחבר את תפקידי ה-IAM הבאים:
    • roles/secretmanager.viewer
    • roles/secretmanager.secretAccessor

    חשבון שירות הוא סוג מיוחד של חשבון Google שמייצג משתמש לא אנושי, שצריך לאמת ולאשר כדי לתת לו גישה לנתונים ב-Google APIs. אם אין לכם חשבון שירות, אתם צריכים ליצור חשבון שירות. המחבר וחשבון השירות צריכים להיות שייכים לאותו פרויקט. מידע נוסף זמין במאמר בנושא יצירת חשבון שירות.

  • מפעילים את השירותים הבאים:
    • ‫secretmanager.googleapis.com (Secret Manager API)
    • ‫connectors.googleapis.com (Connectors API)

    במאמר הפעלת שירותים מוסבר איך להפעיל שירותים.

  אם השירותים או ההרשאות האלה לא הופעלו בפרויקט שלכם בעבר, תתבקשו להפעיל אותם כשאתם מגדירים את המחבר.

הערה: מחבר Solace תומך בפרוטוקול JMS ‏ (Java Message Service). אין תמיכה בפרוטוקולים אחרים, כמו MQTT ו-AMQP.

הגדרת המחבר

החיבור הוא ספציפי למקור נתונים. אם יש לכם הרבה מקורות נתונים, תצטרכו ליצור חיבור נפרד לכל אחד מהם. כדי ליצור קישור:

1. במסוף Cloud, עוברים לדף Integration Connectors > Connections ובוחרים או יוצרים פרויקט בענן.

   כניסה לדף Connections

2. לוחצים על + יצירת חיבור חדש כדי לפתוח את הדף יצירת חיבור.
3. בקטע מיקום, בוחרים את המיקום של החיבור.
   1. אזור: בוחרים מיקום מהרשימה הנפתחת.

      רשימה של כל האזורים הנתמכים מופיעה במאמר מיקומים.

   2. לוחצים על הבא.
4. בקטע פרטי החיבור, ממלאים את הפרטים הבאים:
   1. מחבר: בוחרים באפשרות Solace מהרשימה הנפתחת של המחברים הזמינים.
   2. גרסת כלי החיבור: בוחרים את גרסת כלי החיבור מהרשימה הנפתחת של הגרסאות הזמינות.
   3. בשדה Connection Name (שם החיבור), מזינים שם למופע החיבור.

      השמות של החיבורים צריכים לעמוד בקריטריונים הבאים:

      • שמות החיבורים יכולים לכלול אותיות, מספרים או מקפים.
      • האותיות צריכות להיות קטנות.
      • שמות החיבורים צריכים להתחיל באות ולהסתיים באות או במספר.
      • שמות החיבורים לא יכולים לכלול יותר מ-49 תווים.
      • במחברים שתומכים בהרשמה לאירועים, שמות החיבורים לא יכולים להתחיל בקידומת goog.
   4. אופציונלי: מזינים תיאור למופע החיבור.
   5. חשבון שירות: בוחרים חשבון שירות שיש לו את התפקידים הנדרשים.
   6. כדי להשתמש בחיבור למינויים לאירועים, בוחרים באפשרות הפעלת מינוי לאירועים. בחירה באפשרות הזו מפעילה את המינוי לאירוע עם פעולות.
      הערה: האפשרות Enable only event subscription לא נתמכת בחיבור הזה.
   7. ‫Message VPN: רשת ה-VPN של הודעות בנתב ההודעות Solace Pub/Sub+ שאליו רוצים להתחבר. החיבור ספציפי ל-Message VPN. אם יש לכם הרבה רשתות VPN להעברת הודעות, אתם צריכים ליצור חיבור נפרד לכל רשת VPN להעברת הודעות.
   8. שם תור ברירת המחדל: השם של תור ברירת המחדל, יכול להיות שיוחלף כשמבצעים פעולה.
   9. שם ברירת המחדל של הנושא: שם הנושא שאליו רוצים להתחבר.
   10. (אופציונלי) כדי להשתמש ב-SSL, בוחרים באפשרות הפעלת SSL ומציינים את פרטי ההגדרה של SSL.
   1. בוחרים סוג של מאגר אישורים. אפשר לציין גלוי לכולם, פרטי או חיבור לא מאובטח.
   2. בוחרים את האישורים בהתאם לבחירה שלכם במאגר האישורים. לדוגמה, אם בוחרים באפשרות פרטי, צריך לציין מאגר אישורים מותאם אישית.
   3. אם אתם משתמשים ב-mTLS, בוחרים את האישורים של מאגר המפתחות בקטע Key Store.
   4. אופציונלי: בוחרים את גרסת ה-TLS.
   5. מזינים את סט האלגוריתמים להצפנה הנתמך. מזינים כמה חבילות הצפנה, כערכים מופרדים בפסיקים. מידע נוסף זמין במאמר בנושא חבילות הצפנה נתמכות.
   הערה:
   • כל האישורים צריכים להיות אישורי X.509 ובפורמט PEM (דואר עם פרטיות משודרגת).
   • אי אפשר לבחור אישור ישירות כשמגדירים SSL. אתם צריכים לאחסן את כל האישורים והמפתחות הפרטיים שלכם כסוד ב-Secret Manager, ואז לבחור את הסוד הנדרש במהלך הגדרת ה-SSL.
   11. (אופציונלי) מגדירים את ההגדרות של צומת החיבור.
   • מספר מינימלי של צמתים: מזינים את המספר המינימלי של צמתי חיבור.
   • מספר הצמתים המקסימלי: מזינים את מספר צמתי החיבור המקסימלי.

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

   הערה: אפשר להתאים אישית את הערכים של צומת החיבור רק אם אתם לקוחות עם תשלום לפי שימוש.
   12. אופציונלי: לוחצים על + הוספת תווית כדי להוסיף תווית לקישור בצורה של צמד מפתח/ערך.
   13. לוחצים על הבא.
5. בקטע יעדים, מזינים את הפרטים של המארח המרוחק (מערכת העורף) שאליו רוצים להתחבר.
   1. סוג היעד: בוחרים סוג יעד.
      • כדי לציין את שם המארח או את כתובת ה-IP של היעד, בוחרים באפשרות כתובת המארח ומזינים את הכתובת בשדה מארח 1.
      • כדי ליצור חיבור פרטי, בוחרים באפשרות Endpoint attachment (צירוף נקודת קצה). ברשימה Endpoint Attachment, בוחרים את קובץ ה-Endpoint Attachment שנוצר עבור מערכת ה-Backend.
      הערה: מידע על יצירת צירוף של נקודת קצה זמין במאמר קישוריות לרשת פרטית. אחרי שיוצרים את ההצמדה של נקודת הקצה, היא מופיעה ברשימה Endpoint Attachment.

      אם רוצים ליצור חיבור ציבורי למערכות העורפיות עם אבטחה נוספת, אפשר להגדיר כתובות IP סטטיות יוצאות לחיבורים, ואז להגדיר את כללי חומת האש כך שרק כתובות ה-IP הסטטיות הספציפיות יופיעו ברשימת ההיתרים.

      הערה: המחבר הזה תומך רק ביעד אחד.
   2. לוחצים על הבא.
6. בקטע אימות, מזינים את פרטי האימות.
   1. בוחרים סוג אימות ומזינים את הפרטים הרלוונטיים.

      החיבור ל-Solace תומך בסוגי האימות הבאים:

      • אנונימי
      • שם משתמש וסיסמה

   כדי להבין איך להגדיר את סוגי האימות האלה, אפשר לעיין במאמר בנושא הגדרת אימות.

   2. לוחצים על הבא.
7. בקטע פרטי המינוי לאירוע, מגדירים את הפרטים שקשורים לאירוע.
   • מזינים את ההגדרה של תור ההודעות המתות. אם מגדירים תיבת דואר להודעות שלא נמסרו, החיבור כותב את האירועים שלא עברו עיבוד אל נושא Pub/Sub שצוין. ממלאים את הפרטים הבאים:
     1. מזהה פרויקט של הודעות שלא ניתן למסור: מזהה הפרויקט ב-Google Cloud שבו הגדרתם את נושא ה-Pub/Sub של הודעות שלא ניתן למסור.
     2. נושא להודעות ללא מוצא: נושא Pub/Sub שבו רוצים לכתוב את הפרטים של האירוע שלא עבר עיבוד.
8. בדיקה: בודקים את פרטי החיבור והאימות.
9. לוחצים על יצירה.

הגדרת אימות

מזינים את הפרטים בהתאם לאימות שבו רוצים להשתמש.

• אנונימי

  אם רוצים להשתמש בכניסה אנונימית, בוחרים באפשרות לא זמין.

• שם משתמש וסיסמה
  • שם משתמש: שם המשתמש ב-Solace שבו ישתמשו לחיבור.
  • ‫Password: סוד ב-Secret Manager שמכיל את הסיסמה שמשויכת לשם המשתמש ב-Solace.

ישויות, פעולות ופעולות

כל Integration Connectors מספקים שכבת הפשטה לאובייקטים של האפליקציה המחוברת. אפשר לגשת לאובייקטים של אפליקציה רק דרך ההפשטה הזו. ההפשטה מוצגת לכם כישויות, פעולות ופעולות.

הערה: אפשר לראות את הישויות, הפעולות והפעולות של מחבר במשימת המחברים.

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

  עם זאת, יכול להיות שמחבר לא תומך בישויות או שאין לו ישויות, ובמקרה כזה הרשימה Entities תהיה ריקה.

• פעולה: פעולה היא הפעילות שאפשר לבצע בישות. אפשר לבצע כל אחת מהפעולות הבאות בישות:
  • רשימה
  • הרשמה
  • יצירה
  • עדכון
  • מחיקה

  בחירה של ישות מתוך הרשימה הזמינה יוצרת רשימה של פעולות שזמינות לישות. תיאור מפורט של הפעולות זמין במאמר פעולות על ישויות של משימת המחברים. עם זאת, אם מחבר לא תומך באף אחת מהפעולות על ישויות, הפעולות הלא נתמכות האלה לא יופיעו ברשימה Operations.

• פעולה: פעולה היא פונקציה מסוג first class שזמינה לשילוב דרך ממשק המחבר. פעולה מאפשרת לבצע שינויים בישות אחת או בכמה ישויות, והיא משתנה ממתחם למתחם. בדרך כלל, לפעולה יהיו כמה פרמטרים של קלט ופרמטר של פלט. עם זאת, יכול להיות שמחבר לא תומך באף פעולה, ובמקרה כזה הרשימה Actions תהיה ריקה.

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

פעולות

חיבור Solace תומך בפעולות הבאות:

• ‫sendMessage שולחת הודעה לתור.
• ‫requestReply: שולח הודעה לתור ומציין גם את תור התגובה שאליו המשיב צריך לכתוב את התגובה.

פעולת שליחת הודעה

בטבלאות הבאות מתוארים פרמטרי הקלט והפלט של הפעולה sendMessage.

פרמטרים של קלט לפעולה sendMessage

שם הפרמטר	חובה	סוג נתונים	תיאור
הודעה	כן	String	ההודעה שתישלח לתור של Solace. נכון לעכשיו, הגודל המקסימלי של הודעה שנתמך הוא 10MB.
queueName	לא	String	השם של התור ב-Solace. אם לא מציינים שם תור, נעשה שימוש בשם התור שמוגדר כברירת מחדל שצוין במהלך יצירת החיבור.
messageContentType	כן	String	סוג התוכן של ההודעה, שאפשר לציין אותו כ-Text או כ-Bytes. אם שולחים נתונים בינאריים, צריך להגדיר את הסוג כ-Bytes. כדי לשלוח הודעה בפורמט בינארי, צריך לבצע את המשימות הבאות: מקודדים את ההודעה הבינארית כמחרוזת Base64, ואז מגדירים את הפרמטר message לערך המקודד. מגדירים את הערך של הפרמטר messageContentType ל-Bytes.
messageType	כן	String	סוג ההודעה שאפשר לציין כ-Datagram או כ-Reply.
topicName	לא	String	השם של נושא Solace. אם לא מציינים שם של נושא, נעשה שימוש בשם התור שמוגדר כברירת מחדל שצוין במהלך יצירת החיבור.

פרמטרים של פלט של הפעולה sendMessage

שם הפרמטר	סוג נתונים	תיאור
messageId	String	המזהה של ההודעה שנשלחה.

דוגמאות

המטען הייעודי (payload) הבא משמש לשליחת הודעת טקסט של Datagram לתור.

  {
    "message": "Hello world",
    "messageContentType": "Text",
    "messageType": "Datagram",
    "queueName": "solace-queue"
  }

מטען הייעודי (payload) של הפלט אמור להיראות כך:

[{
    "messageId": "ID:414d51207365637572*******6501db3640"
}]

המטען הייעודי (payload) הבא משמש לשליחת הודעת תשובה בפורום.

{
    "message": "NDggNjUgNmMgNmMgNmYgMjAgNTcgNmYgNzIgNmMgNjQ=",
    "messageContentType": "Bytes",
    "messageType": "Reply",
    "topicName": "solace-topic"
}

מטען הייעודי (payload) של הפלט אמור להיראות כך:

[{
  "messageId": "ID:414d512073656375726561707068656ce595386501db3640"
}]

פעולת בקשת התשובה

בטבלאות הבאות מתוארים פרמטרי הקלט והפלט של הפעולה requestReply.

פרמטרים של קלט לפעולה requestReply

שם הפרמטר	חובה	סוג נתונים	תיאור
הודעה	כן	String	ההודעה שתישלח לתור של Solace. הגודל המקסימלי של הודעה שנתמך הוא 10MB.
queueName	לא	String	השם של התור ב-Solace. אם לא מציינים שם תור, נעשה שימוש בשם התור שמוגדר כברירת מחדל שצוין במהלך יצירת החיבור.
messageContentType	כן	String	סוג התוכן של ההודעה, שאפשר לציין אותו כ-Text או כ-Bytes. אם שולחים נתונים בינאריים, צריך להגדיר את הסוג כ-Bytes. כדי לשלוח הודעה בפורמט בינארי, צריך לבצע את המשימות הבאות: מקודדים את ההודעה הבינארית כמחרוזת Base64, ואז מגדירים את הפרמטר message לערך המקודד. מגדירים את הערך של הפרמטר messageContentType ל-Bytes.
replyToQueue	כן	String	התור שבו המשיב צריך לכתוב את התשובה.
replyTimeout	כן	String	הזמן (באלפיות השנייה) שעד אליו המחבר ממתין לתגובה בתור התגובות. הערך המקסימלי שנתמך הוא 180,000 מילישניות (3 דקות). אם תור התגובות מקבל הודעה אחרי תקופת הזמן הקצובה, המחבר לא מעבד את ההודעה. עם זאת, אפשר לראות את הפרטים של ההודעה על פסק הזמן ביומני הביצוע של השילוב. הערה: הגדרה של ערך גבוה יותר של זמן קצוב לתפוגה עשויה להשפיע על הביצועים של המחבר.

פרמטרים של פלט של הפעולה requestReply

שם הפרמטר	סוג נתונים	תיאור
replyMessage	String	הודעת תשובה מהמשיב.

דוגמאות

המטען הייעודי (payload) הבא משמש לשליחת הודעת תשובה מהמשיב.

{
  "message": "Hello world",
  "messageContentType": "Text",
  "queueName": "solace-queue",
  "replyToQueue": "solace-reply-queue",
  "replyTimeout": 10
}

מטען הייעודי (payload) של הפלט אמור להיראות כך:

{
    "replyMessage": "Message received"
}

יצירת חיבורים באמצעות Terraform

אפשר להשתמש במשאב של Terraform כדי ליצור חיבור חדש.

כדי ללמוד איך להחיל הגדרות ב-Terraform או להסיר אותן, ראו פקודות בסיסיות ב-Terraform.

כדי לראות תבנית לדוגמה של Terraform ליצירת חיבור, אפשר לעיין בתבנית לדוגמה.

כשיוצרים את החיבור הזה באמצעות Terraform, צריך להגדיר את המשתנים הבאים בקובץ ההגדרות של Terraform:

שם הפרמטר	סוג נתונים	חובה	תיאור
default_queue_name	מחרוזת	לא נכון	השם של תור ברירת המחדל, יכול להיות שיוחלף כשמבצעים פעולה.
default_topic_name	מחרוזת	לא נכון	שם הנושא שמוגדר כברירת מחדל. אפשר לשנות אותו כשמבצעים פעולה.
queue_manager_name	מחרוזת	נכון	השם של מנהל התורים שאליו רוצים להתחבר.
channel_name	מחרוזת	נכון	הערוץ שאליו מתחברים למנהל התורים.

שימוש בחיבור Solace בשילוב

אחרי שיוצרים את החיבור, הוא זמין גם ב-Apigee Integration וגם ב-Application Integration. אפשר להשתמש בחיבור בשילוב באמצעות המשימה Connectors.

• כדי להבין איך ליצור ולהשתמש במשימה Connectors ב-Apigee Integration, אפשר לעיין במאמר משימת Connectors.
• מידע על יצירה ושימוש במשימת מחברים ב-Application Integration זמין במאמר משימת מחברים.

קבלת עזרה מקהילת Google Cloud

אתם יכולים לפרסם את השאלות שלכם ולדון במחבר הזה בקהילת Google Cloud בפורומים של Cloud.

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

• איך משעים ומחדשים חיבור
• איך עוקבים אחרי השימוש בכלי לחיבור נתונים
• איך צופים ביומני המחברים