CockroachDB
מחבר CockroachDB מאפשר לבצע פעולות של הוספה, מחיקה, עדכון וקריאה במסד נתונים של CockroachDB.
לפני שמתחילים
לפני שמשתמשים במחבר CockroachDB, צריך לבצע את המשימות הבאות:
- בפרויקט שלכם ב-Google Cloud:
- מוודאים שהגדרתם חיבור לרשת. מידע על תבניות רשת זמין במאמר קישוריות לרשת.
- נותנים למשתמש שמגדיר את המחבר את תפקיד ה-IAM roles/connectors.admin.
- מקצים לחשבון השירות שרוצים להשתמש בו עבור המחבר את תפקידי ה-IAM הבאים:
roles/secretmanager.viewerroles/secretmanager.secretAccessor
חשבון שירות הוא סוג מיוחד של חשבון Google שמייצג משתמש לא אנושי, שצריך לאמת ולאשר כדי לתת לו גישה לנתונים ב-Google APIs. אם אין לכם חשבון שירות, אתם צריכים ליצור חשבון שירות. המחבר וחשבון השירות צריכים להיות שייכים לאותו פרויקט. מידע נוסף זמין במאמר בנושא יצירת חשבון שירות.
- מפעילים את השירותים הבאים:
-
secretmanager.googleapis.com(Secret Manager API) -
connectors.googleapis.com(Connectors API)
במאמר הפעלת שירותים מוסבר איך להפעיל שירותים.
-
אם השירותים או ההרשאות האלה לא הופעלו בפרויקט שלכם בעבר, תתבקשו להפעיל אותם כשאתם מגדירים את המחבר.
מידע נוסף על יצירת אשכול ללא שרת ועל שימוש בכל הפרמטרים של האפליקציה שנוצרה זמין במאמר יצירת אשכול CockroachDB Serverless ב-Cockroachlabs
מידע על יצירת אישור בחתימה עצמית זמין במאמר Cockroach cert.
הגדרת המחבר
החיבור הוא ספציפי למקור נתונים. אם יש לכם הרבה מקורות נתונים, תצטרכו ליצור חיבור נפרד לכל אחד מהם. כדי ליצור קישור:
- במסוף Cloud, עוברים לדף Integration Connectors > Connections ובוחרים או יוצרים פרויקט בענן.
- לוחצים על + יצירת חיבור חדש כדי לפתוח את הדף יצירת חיבור.
- בקטע מיקום, בוחרים את המיקום של החיבור.
- אזור: בוחרים מיקום מהרשימה הנפתחת.
רשימה של כל האזורים הנתמכים מופיעה במאמר מיקומים.
- לוחצים על הבא.
- אזור: בוחרים מיקום מהרשימה הנפתחת.
- בקטע פרטי החיבור, ממלאים את הפרטים הבאים:
- מחבר: בוחרים באפשרות CockroachDB מהרשימה הנפתחת של המחברים הזמינים.
- גרסת כלי החיבור: בוחרים את גרסת כלי החיבור מהרשימה הנפתחת של הגרסאות הזמינות.
- בשדה Connection Name (שם החיבור), מזינים שם למופע החיבור.
השמות של החיבורים צריכים לעמוד בקריטריונים הבאים:
- שמות החיבורים יכולים לכלול אותיות, מספרים או מקפים.
- האותיות צריכות להיות קטנות.
- שמות החיבורים צריכים להתחיל באות ולהסתיים באות או במספר.
- שמות החיבורים לא יכולים לכלול יותר מ-49 תווים.
- אופציונלי: מזינים תיאור למופע החיבור.
- אופציונלי: מפעילים את Cloud Logging ואז בוחרים רמת יומן. כברירת מחדל, רמת היומן מוגדרת כ-
Error. - חשבון שירות: בוחרים חשבון שירות שיש לו את התפקידים הנדרשים.
- אופציונלי: מגדירים את ההגדרות של צומת החיבור:
- מספר מינימלי של צמתים: מזינים את המספר המינימלי של צמתי חיבור.
- מספר הצמתים המקסימלי: מזינים את מספר צמתי החיבור המקסימלי.
צומת הוא יחידה (או עותק) של חיבור שמבצעת עיבוד של עסקאות. כדי לעבד יותר עסקאות לחיבור נדרשים יותר צמתים, ולהפך: כדי לעבד פחות עסקאות נדרשים פחות צמתים. כדי להבין איך הצמתים משפיעים על התמחור של המחבר, אפשר לעיין במאמר בנושא תמחור של צמתי חיבור. אם לא מזינים ערכים, כברירת מחדל, מספר הצמתים המינימלי מוגדר כ-2 (לזמינות טובה יותר) ומספר הצמתים המקסימלי מוגדר כ-50.
- Database: השם של מסד הנתונים של Cockroach.
- Allow Prepared Statement: מאפשרת הכנה של הצהרת שאילתה לפני ההפעלה שלה.
- שליפת מטא-נתונים של קבוצת תוצאות: בשדה הזה מגדירים אם הספק מקבל מהשרת מידע מפורט על העמודות של קבוצת התוצאות.
- UseSSL: השדה הזה קובע אם SSL מופעל.
- SSLServerCert: השדה הזה קובע אם SSL מופעל.
- אופציונלי: לוחצים על + הוספת תווית כדי להוסיף תווית לקישור בצורה של צמד מפתח/ערך.
- לוחצים על הבא.
- בקטע יעדים, מזינים את הפרטים של המארח המרוחק (מערכת העורף) שאליו רוצים להתחבר.
- סוג היעד: בוחרים סוג יעד.
- כדי לציין את שם המארח או את כתובת ה-IP של היעד, בוחרים באפשרות כתובת המארח ומזינים את הכתובת בשדה מארח 1.
- כדי ליצור חיבור פרטי, בוחרים באפשרות Endpoint attachment (צירוף נקודת קצה). ברשימה Endpoint Attachment, בוחרים את קובץ ה-Endpoint Attachment שנוצר עבור מערכת ה-Backend.
אם רוצים ליצור חיבור ציבורי למערכות העורפיות עם אבטחה נוספת, אפשר להגדיר כתובות IP סטטיות יוצאות לחיבורים, ואז להגדיר את כללי חומת האש כך שרק כתובות ה-IP הסטטיות הספציפיות יופיעו ברשימת ההיתרים.
כדי להזין יעדים נוספים, לוחצים על +הוספת יעד.
- לוחצים על הבא.
- סוג היעד: בוחרים סוג יעד.
-
בקטע אימות, מזינים את פרטי האימות.
- בוחרים סוג אימות ומזינים את הפרטים הרלוונטיים.
החיבור ל-CockroachDB תומך בסוגי האימות הבאים:
- שם משתמש וסיסמה
- לוחצים על הבא.
כדי להבין איך להגדיר את סוגי האימות האלה, אפשר לעיין במאמר בנושא הגדרת אימות.
- בוחרים סוג אימות ומזינים את הפרטים הרלוונטיים.
- בדיקה: בודקים את פרטי החיבור והאימות.
- לוחצים על יצירה.
הגדרת אימות
מזינים את הפרטים בהתאם לאימות שבו רוצים להשתמש.
-
שם משתמש וסיסמה
- שם משתמש: שם המשתמש של המחבר
- סיסמה: סוד ב-Secret Manager שמכיל את הסיסמה שמשויכת למחבר.
דוגמאות להגדרת חיבור
בקטע הזה מפורטים ערכים לדוגמה לשדות השונים שאתם מגדירים כשאתם יוצרים את החיבור ל-CockroachDB.
CockroachDB – סוג החיבור 'אימות בסיסי'
| שם השדה | פרטים |
|---|---|
| מיקום | us-central1 |
| מחבר | CockroachDB |
| גרסת המחבר | 1 |
| שם החיבור | cockroach-db-cloud-conn |
| הפעלת Cloud Logging | כן |
| חשבון השירות | SERVICE_ACCOUNT_NAME@serviceaccount |
| SSL | כן |
| SSLServerCert | cockroach-db-ssl-cert |
| SecretVersion | 1 |
| מסד נתונים | TestGCP |
| הרשאה לשימוש בהצהרה מוכנה | כן |
| אחזור מטא-נתונים של קבוצת תוצאות | כן |
| רמת הפירוט | 5 |
| מספר הצמתים המינימלי | 2 |
| מספר הצמתים המקסימלי | 50 |
| סוג היעד(שרת) | כתובת המארח |
| כתובת המארח | googlecloud-bcone-cluster-13792.5xj.cockroachlabs.cloud. זה השם של אשכול הענן של CockroachDB. |
| יציאה | 26257 |
| שם משתמש | שם משתמש |
| סיסמה | סיסמה |
| גרסה של סוד | 1 |
CockroachDB – סוג החיבור PSC
| שם השדה | פרטים |
|---|---|
| מיקום | us-central1 |
| מחבר | CockroachDB |
| גרסת המחבר | 1 |
| שם החיבור | cockroach-db-cloud-conn-psc |
| הפעלת Cloud Logging | כן |
| חשבון השירות | SERVICE_ACCOUNT_NAME@serviceaccount |
| SSL | כן |
| SSLServerCert | gcp-bcone-crdb-hosted-node-crt |
| SecretVersion | 1 |
| מסד נתונים | בנק |
| הרשאה לשימוש בהצהרה מוכנה | לא |
| אחזור מטא-נתונים של קבוצת תוצאות | לא |
| רמת הפירוט | 5 |
| מספר הצמתים המינימלי | 2 |
| מספר הצמתים המקסימלי | 50 |
| סוג היעד(שרת) | כתובת המארח |
| כתובת המארח | 192.0.2.0/24 (זו צריכה להיות נקודת הקצה שנוצרה על סמך כתובת ה-IP של השרת שמארח את מכונת מסד הנתונים של Cockroach) |
| יציאה | 26257 |
| שם משתמש | שם משתמש |
| סיסמה | סיסמה |
| גרסה של סוד | 1 |
ישויות, פעולות ופעולות
כל Integration Connectors מספקים שכבת הפשטה לאובייקטים של האפליקציה המחוברת. אפשר לגשת לאובייקטים של אפליקציה רק דרך ההפשטה הזו. ההפשטה מוצגת לכם כישויות, פעולות ופעולות.
- ישות: ישות היא אובייקט או אוסף של מאפיינים באפליקציה או בשירות המקושרים. ההגדרה של ישות משתנה ממחבר למחבר. לדוגמה, במחבר של מסד נתונים, הטבלאות הן הישויות, במחבר של שרת קבצים, התיקיות הן הישויות, ובמחבר של מערכת הודעות, התורים הם הישויות.
עם זאת, יכול להיות שמחבר לא תומך בישויות או שאין לו ישויות, ובמקרה כזה הרשימה
Entitiesתהיה ריקה. - פעולה: פעולה היא הפעילות שאפשר לבצע בישות. אפשר לבצע כל אחת מהפעולות הבאות בישות:
בחירה של ישות מתוך הרשימה הזמינה יוצרת רשימה של פעולות שזמינות לישות. תיאור מפורט של הפעולות זמין במאמר פעולות על ישויות של משימת המחברים. עם זאת, אם מחבר לא תומך באף אחת מהפעולות על ישויות, הפעולות הלא נתמכות האלה לא יופיעו ברשימה
Operations. - פעולה: פעולה היא פונקציה מסוג first class שזמינה לשילוב דרך ממשק המחבר. פעולה מאפשרת לבצע שינויים בישות אחת או בכמה ישויות, והיא משתנה ממתחם למתחם. בדרך כלל, לפעולה יהיו כמה פרמטרים של קלט ופרמטר של פלט. עם זאת, יכול להיות שמחבר לא תומך באף פעולה, ובמקרה כזה הרשימה
Actionsתהיה ריקה.
מגבלות המערכת
מחבר CockroachDB יכול לעבד טרנזקציה אחת בשנייה, לכל צומת, ומגביל טרנזקציות שחורגות מהמגבלה הזו. כברירת מחדל, Integration Connectors מקצה 2 צמתים (לזמינות טובה יותר) לחיבור.
מידע על המגבלות שחלות על Integration Connectors זמין במאמר מגבלות.
פעולות
בקטע הזה מפורטות הפעולות שהמחבר תומך בהן. כדי להבין איך להגדיר את הפעולות, אפשר לעיין בדוגמאות לפעולות.
פעולת ExecuteCustomQuery
הפעולה הזו מאפשרת להריץ שאילתה בהתאמה אישית.
כדי ליצור שאילתה בהתאמה אישית, פועלים לפי השלבים הבאים:
- פועלים לפי ההוראות המפורטות ל הוספת משימה של מחברים.
- כשמגדירים את משימת המחבר, בוחרים באפשרות פעולות בסוג הפעולה שרוצים לבצע.
- ברשימה Action, בוחרים באפשרות Execute custom query ולוחצים על Done.
- מרחיבים את הקטע Task input (קלט למשימה) ומבצעים את הפעולות הבאות:
- בשדה Timeout after, מזינים את מספר השניות להמתנה עד להפעלת השאילתה.
ערך ברירת המחדל:
180שניות. - בשדה Maximum number of rows (מספר השורות המקסימלי), מזינים את מספר השורות המקסימלי שיוחזר ממסד הנתונים.
ערך ברירת המחדל:
25. - כדי לעדכן את השאילתה המותאמת אישית, לוחצים על עריכת סקריפט בהתאמה אישית. תיפתח תיבת הדו-שיח עורך הסקריפטים.
- בתיבת הדו-שיח הכלי לעריכת סקריפטים, מזינים את שאילתת ה-SQL ולוחצים על שמירה.
אפשר להשתמש בסימן שאלה (?) בהצהרת SQL כדי לייצג פרמטר יחיד שצריך לציין ברשימת פרמטרים של שאילתה. לדוגמה, שאילתת ה-SQL הבאה בוחרת את כל השורות מהטבלה
Employeesשתואמות לערכים שצוינו בעמודהLastName:SELECT * FROM Employees where LastName=?
- אם השתמשתם בסימני שאלה בשאילתת ה-SQL, צריך להוסיף את הפרמטר על ידי לחיצה על + הוספת שם פרמטר לכל סימן שאלה. במהלך ההפעלה של השילוב, הפרמטרים האלה מחליפים את סימני השאלה (?) בשאילתת ה-SQL באופן עקבי. לדוגמה, אם הוספתם שלושה סימני שאלה (?), אתם צריכים להוסיף שלושה פרמטרים לפי הסדר.
כדי להוסיף פרמטרים של שאילתה:
- מהרשימה סוג בוחרים את סוג הנתונים של הפרמטר.
- בשדה ערך, מזינים את הערך של הפרמטר.
- כדי להוסיף כמה פרמטרים, לוחצים על + הוספת פרמטר של שאילתה.
הפעולה Execute custom query לא תומכת במשתני מערך.
- בשדה Timeout after, מזינים את מספר השניות להמתנה עד להפעלת השאילתה.
אם הפעולה בוצעה ללא שגיאות, היא מחזירה את הסטטוס 200 (OK) עם גוף תגובה שכולל את תוצאות השאילתה.
דוגמאות לפעולות
דוגמה – חיפוש הערך הגדול יותר
בדוגמה הזו מוסבר איך להפעיל פונקציה בהגדרת המשתמש. הפונקציה find_greater
בדוגמה הזו משווה בין שני מספרים שלמים ומחזירה את המספר השלם הגדול יותר.
- בתיבת הדו-שיח
Configure connector task, לוחצים עלActions. - בוחרים את הפעולה
find_greaterולוחצים על סיום. - בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על
connectorInputPayloadואז מזינים ערך דומה לערך הבא בשדהDefault Value:{ "$1": 1.0, "$2": 5.0 }
אם הפעלת הפעולה תסתיים בהצלחה, הערך של השדה connectorOutputPayload במשימת המחבר יהיה דומה לערך הבא:
[{ "bignum": 5.0 }]
דוגמאות לפעולות על ישויות
בקטע הזה מוסבר איך לבצע חלק מהפעולות על ישויות במחבר הזה.
דוגמה – רשימה של כל רשומות העובדים
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
EmployeesמהרשימהEntity. - בוחרים את הפעולה
Listולוחצים על סיום. - בקטע Task Input של המשימה Connectors, אפשר להגדיר את filterClause בהתאם לדרישות הלקוח.
הערך של פסוקית הסינון צריך תמיד להיות מועבר בתוך מירכאות בודדות (') בפורמט הזה.
אפשר להשתמש בה כדי לסנן את הרשומות לפי כל עמודה.
אפשר לבצע את הפעולה List בישויות הבאות:
Cockroach_Datatypes, Accounts, SpatialData, UNICODE, LANGUAGES ו-View_Cockroach
דוגמה – שליפת רשומת עובדים
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
EmployeesמהרשימהEntity. - בוחרים את הפעולה
Getולוחצים על סיום. - מגדירים את מזהה הישות ל-5, שהוא המפתח שיועבר. כדי להגדיר את מזהה הישות, בקטע Data Mapper (מיפוי נתונים) של Data Mapping (מיפוי נתונים), לוחצים על Open Data Mapping Editor (פתיחת כלי מיפוי הנתונים), מזינים
5בשדה Input Value (ערך קלט) ובוחרים באפשרות EntityId בתור Local variable (משתנה מקומי).צריך להעביר את הערך של מזהה הישות ישירות. כאן 5 הוא הערך הייחודי של המפתח הראשי, שצריך להעביר.
יש מקרים מסוימים שבהם העברת מזהה ישות יחיד תגרום לשגיאה, כי יהיו שני מפתחות מורכבים.
במקרים כאלה, אפשר להשתמש ב-Filter Clause ולהעביר את הערך, למשל EmployeeId='5'.
אפשר לבצע את הפעולה List בישויות הבאות:
Cockroach_Datatypes, Accounts, SpatialData, UNICODE ו-LANGUAGES
דוגמה – מחיקת רשומה של עובד
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
EmployeesמהרשימהEntity. - בוחרים את הפעולה
Deleteולוחצים על סיום. - מגדירים את מזהה הישות ל-2, שהוא המפתח שיועבר. כדי להגדיר את מזהה הישות, בקטע Data Mapper (מיפוי נתונים) של Data Mapping (מיפוי נתונים), לוחצים על Open Data Mapping Editor (פתיחת כלי מיפוי הנתונים), מזינים
2בשדה Input Value (ערך קלט) ובוחרים באפשרות EntityId בתור Local variable (משתנה מקומי).אם לישות יש שני מפתחות עסקיים מורכבים או מפתחות ראשיים, במקום לציין את entityId, אפשר גם להגדיר את filterClause ל-
EmployeeId='2'.
אפשר לבצע את פעולת המחיקה בישויות הבאות:
Cockroach_Datatypes, Accounts, SpatialData, UNICODE ו-LANGUAGES
דוגמה – יצירת רשומת עובדים
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
EmployeesמהרשימהEntity. - בוחרים את הפעולה
Createולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload כמשתנה מקומי.{ "id": 100.0, "gender": "Male", "firstname": "Charlie", "lastname": "Cruz", "designation": "Tester", "dept": "IT" }אם השילוב יצליח, לפרמטר התגובה
connectorOutputPayloadשל המשימהEmployeesיהיה ערך שדומה לדוגמה הבאה:{ "id": 100.0, "gender": "Male", "firstname": "Charlie", "lastname": "Cruz", "designation": "Tester", "dept": "IT" }
דוגמה – יצירת רשומה של Cockroach_Datatypes
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות Cockroach_Datatypes מהרשימה
Entity. - בוחרים את הפעולה
Createולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload כמשתנה מקומי.{ "col_int": 8.0, "col_date": "2016-03-26", "col_inet": "190.0.0.0", "col_collate": "Cruz", "col_string": "Charlie", "col_timestamp": "1992-10-05 12:12:12", "col_float": 12.12, "col_decimal": 10.1, "col_json": "{\"type\": \"account creation\", \"username\": \"harvestboy93\"}", "col_bool": true, "col_interval": "1 year 2 mons 3 days 04:05:06", "col_array": "{sky,road,car}", "col_uuid": "63616665-6630-3064-6465-616462656562", "col_time": "05:41:39", "col_bytes": "abc", "col_bit": "1", "col_name": "Charlie", "col_character": "A", "col_tsvector": "ts", "col_tsquery": "normal", "col_oid": "11", "col_bytea": "01100001" }אם השילוב יצליח, לפרמטר התגובה
connectorOutputPayloadשל המשימהCockroach_Datatypesיהיה ערך שדומה לדוגמה הבאה:{ "col_int": 8.0, "col_date": "2016-03-26", "col_inet": "190.0.0.0", "col_collate": "Cruz", "col_string": "Charlie", "col_timestamp": "1992-10-05 12:12:12", "col_float": 12.12, "col_decimal": 10.1, "col_json": "{\"type\": \"account creation\", \"username\": \"harvestboy93\"}", "col_bool": true, "col_interval": "1 year 2 mons 3 days 04:05:06", "col_array": "{sky,road,car}", "col_uuid": "63616665-6630-3064-6465-616462656562", "col_time": "05:41:39", "col_bytes": "abc", "col_bit": "1", "col_name": "Charlie", "col_character": "A", "col_tsvector": "ts", "col_tsquery": "normal", "col_oid": "11", "col_bytea": "01100001" }
דוגמה – יצירת רשומת LANGUAGES של ישות
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
LANGUAGESמהרשימהEntity. - בוחרים את הפעולה
Createולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload כמשתנה מקומי.{ "id": 5.0, "hinditext": "नमस्ते", "englishtest": "Namaste", "arabictext": "مرحبا", "germantext": "Günther" }אם השילוב יצליח, לפרמטר התגובה
connectorOutputPayloadשל המשימהLANGUAGESיהיה ערך שדומה לזה:{ "id": 6.0, "hinditext": "नमस्ते", "englishtest": "Namaste", "arabictext": "مرحبا", "germantext": "Günther" }
דוגמה – יצירת רשומת UNICODE
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות UNICODE מהרשימה
Entity. - בוחרים את הפעולה
Createולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload כמשתנה מקומי.{ "id": 2.0, "unicodedata": "Unicode データ型はグローバル化されたデータの保存に使用されます", "test": "UnicodeTest" }
אם השילוב יצליח, לפרמטר התגובה connectorOutputPayload של המשימה UNICODE יהיה ערך שדומה לזה:
{
"id": 2.0,
"unicodedata": "Unicode データ型はグローバル化されたデータの保存に使用されます",
"test": "UnicodeTest"
}
דוגמה – יצירת רשומת SpatialData
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות SpatialData (נתונים מרחביים) מהרשימה
Entity. - בוחרים את הפעולה
Createולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload כמשתנה מקומי.{ "id": 10.0, "data": "01020000000500000070CE88D2DE3453C075029A081B164540984C158C4AEA52C0DC68006F81B4444009F9A067B36252C02DB29DEFA7864440FA7E6ABC747B52C0D122DBF97EDA444070CE88D2DE3453C075029A081B164548" }בדוגמה הזו ייווצרו רשומות של נתונים מרחביים. אם השילוב יצליח, לפרמטר התגובה
connectorOutputPayloadשל המשימהSpatialDataיהיה ערך שדומה לזה:{ "id": 10.0, "data": "01020000000500000070CE88D2DE3453C075029A081B164540984C158C4AEA52C0DC68006F81B4444009F9A067B36252C02DB29DEFA7864440FA7E6ABC747B52C0D122DBF97EDA444070CE88D2DE3453C075029A081B164548" }
דוגמה – יצירת רשומה של חשבונות
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
AccountsמהרשימהEntity. - בוחרים את הפעולה
Createולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload כמשתנה מקומי.{ "balance": 2000.0, "status": "open", "id": 7.0 }בדוגמה הזו ייווצרו רשומות של נתונים מרחביים. אם השילוב יצליח, לפרמטר התגובה
connectorOutputPayloadשל המשימהSpatialDataיהיה ערך שדומה לזה:{ "balance": 2000.0, "status": "open", "id": 7.0 }
דוגמה – עדכון רשומה של עובד
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות 'עובדים' מהרשימה
Entity. - בוחרים את הפעולה
Updateולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.{ "dept": "Comp", "designation": "QA" } - מגדירים את מזהה הישות ב-Data Mapper לישות Employees . כדי להגדיר את מזהה הישות, לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.במקום לציין את entityId, אפשר גם להגדיר את filterClause לערך
1.הרצת הדוגמה הזו מחזירה תגובה שדומה לתגובה הבאה במשתנה הפלט
connectorOutputPayloadשל משימת המחבר:{ }
דוגמה – עדכון רשומת LANGUAGES
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
LANGUAGESמהרשימהEntity. - בוחרים את הפעולה
Updateולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.{ "englishtest": "UpdateTest_TEST" } - מגדירים את מזהה הישות בכלי למיפוי נתונים לישות של המערכים. כדי להגדיר את מזהה הישות, לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.במקום לציין את entityId, אפשר גם להגדיר את filterClause לערך
1.הרצת הדוגמה הזו מחזירה תגובה שדומה לתגובה הבאה במשתנה הפלט
connectorOutputPayloadשל משימת המחבר:{ }
דוגמה – עדכון רשומת UNICODE
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
UNICODEמהרשימהEntity. - בוחרים את הפעולה
Updateולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.{ "unicodedata": "ータ型はグロ", "test": "UpdateTest" } - מגדירים את מזהה הישות במיפוי הנתונים לישות של ObjectType . כדי להגדיר את מזהה הישות, לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.במקום לציין את entityId, אפשר גם להגדיר את filterClause לערך
3.הרצת הדוגמה הזו מחזירה תגובה שדומה לתגובה הבאה במשתנה הפלט
connectorOutputPayloadשל משימת המחבר:{ }
דוגמה – עדכון של רשומת SpatialData
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
SpatialdataמהרשימהEntity. - בוחרים את הפעולה
Updateולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.{ "data": "01020000000500000070CE88D2DE3453C075029A081B164540984C158C4AEA52C0DC68006F81B4444009F9A067B36252C02DB29DEFA7864440FA7E6ABC747B52C0D122DBF97EDA444070CE88D2DE3453C075029A081B164543" } - מגדירים את מזהה הישות ב-Data Mapper לישות של TableType . כדי להגדיר את מזהה הישות, לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.במקום לציין את entityId, אפשר גם להגדיר את filterClause לערך
id= 1.הרצת הדוגמה הזו מחזירה תגובה שדומה לתגובה הבאה במשתנה הפלט
connectorOutputPayloadשל משימת המחבר:{ "id": 1, "data": "01020000000500000070CE88D2DE3453C075029A081B164540984C158C4AEA52C0DC68006F81B4444009F9A067B36252C02DB29DEFA7864440FA7E6ABC747B52C0D122DBF97EDA444070CE88D2DE3453C075029A081B164543" }
דוגמה – עדכון רשומה של חשבון
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
AccountsמהרשימהEntity. - בוחרים את הפעולה
Updateולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.{ "balance": 1500.0, "status": "open" } - מגדירים את מזהה הישות ב-Data Mapper לישות של TableType . כדי להגדיר את מזהה הישות, לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.במקום לציין את entityId, אפשר גם להגדיר את filterClause לערך
id= 1.הרצת הדוגמה הזו מחזירה תגובה שדומה לתגובה הבאה במשתנה הפלט
connectorOutputPayloadשל משימת המחבר:{ "id": 1, "balance": 1500, "status": "open" }
דוגמה – עדכון רשומה של Cockroach_Datatypes
- בתיבת הדו-שיח
Configure connector task, לוחצים עלEntities. - בוחרים באפשרות
Cockroach_DatatypesמהרשימהEntity. - בוחרים את הפעולה
Updateולוחצים על סיום. - בקטע Data Mapper (מיפוי נתונים) במשימה Data Mapping (מיפוי נתונים), לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.{ "col_date": "2019-03-26", "col_collate": "Charlie", "col_string": "Cruz" } - מגדירים את מזהה הישות ב-Data Mapper לישות של TableType . כדי להגדיר את מזהה הישות, לוחצים על
Open Data Mapping Editor, מזינים ערך דומה לערך הבא בשדהInput Valueובוחרים באפשרות EntityId/ConnectorInputPayload/FilterClause כמשתנה מקומי.במקום לציין את entityId, אפשר גם להגדיר את filterClause לערך
2.הרצת הדוגמה הזו מחזירה תגובה שדומה לתגובה הבאה במשתנה הפלט
connectorOutputPayloadשל משימת המחבר:{ }
יצירת חיבורים באמצעות Terraform
אפשר להשתמש במשאב של Terraform כדי ליצור חיבור חדש.
כדי ללמוד איך להחיל הגדרות ב-Terraform או להסיר אותן, ראו פקודות בסיסיות ב-Terraform.
כדי לראות תבנית לדוגמה של Terraform ליצירת חיבור, אפשר לעיין בתבנית לדוגמה.
כשיוצרים את החיבור הזה באמצעות Terraform, צריך להגדיר את המשתנים הבאים בקובץ ההגדרות של Terraform:
| שם הפרמטר | סוג נתונים | חובה | תיאור |
|---|---|---|---|
| use_ssl | בוליאני | לא נכון | השדה הזה קובע אם SSL מופעל. |
| ssl_server_cert | SECRET | לא נכון | השדה הזה קובע אם SSL מופעל. |
| מסד נתונים | מחרוזת | נכון | השם של מסד הנתונים של Cockroach. |
| allow_prepared_statement | בוליאני | לא נכון | מאפשרים הכנה של הצהרת שאילתה לפני ההפעלה שלה. |
| fetch_result_set_metadata | בוליאני | לא נכון | השדה הזה קובע אם הספק מקבל מהשרת מידע מפורט על עמודות של קבוצת תוצאות. |
שימוש בחיבור ל-CockroachDB בשילוב
אחרי שיוצרים את החיבור, הוא זמין גם ב-Apigee Integration וגם ב-Application Integration. אפשר להשתמש בחיבור בשילוב באמצעות המשימה Connectors.
- כדי להבין איך ליצור ולהשתמש במשימה Connectors ב-Apigee Integration, אפשר לעיין במאמר משימת Connectors.
- מידע על יצירה ושימוש במשימת מחברים ב-Application Integration זמין במאמר משימת מחברים.