העברת ארגומנט של זמן ריצה לעבודת שכפול

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

העברת ארגומנט של Debezium לעבודת שכפול

כדי להעביר ארגומנט מאפליקציית Debezium לעבודת שכפול של MySQL או SQL Server ב-Cloud Data Fusion, צריך לציין ארגומנט של זמן ריצה באמצעות הקידומת source.connector.

המסוף

1. עוברים למופע:

   1. במסוף Google Cloud , נכנסים לדף Cloud Data Fusion.

   2. כדי לפתוח את המכונה ב-Cloud Data Fusion Studio, לוחצים על Instances (מכונות) ואז על View instance (הצגת מכונה).

      כניסה לדף Instances

2. לוחצים על תפריט > מרכז הבקרה.

3. מאתרים את האפליקציה של עבודת השכפול ולוחצים על העדפות. נפתח החלון העדפות.

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

   

5. לוחצים על Save & Close (שמירה וסגירה).

‫API בארכיטקטורת REST

כדי להגדיר ארגומנט של זמן ריצה באמצעות API בארכיטקטורת REST, אפשר לעיין בהפניה לשירותי מיקרו של העדפות CDAP.

הגדרת פרמטרים של JDBC

כדי להעביר פרמטר JDBC למשימת שכפול של MySQL או SQL Server, צריך לציין את הארגומנט של זמן הריצה עם הקידומת source.connector.database.

לדוגמה, כדי להגדיר את פרמטר ה-JDBC‏ sessionVariables ל-MAX_EXECUTION_TIME=43200000, מגדירים ארגומנט של זמן ריצה עם המפתח source.connector.database.sessionVariables והערך MAX_EXECUTION_TIME=43200000.

כדי להגדיר כמה פרמטרים של JDBC, צריך להגדיר ארגומנט של זמן ריצה לכל פרמטר. לדוגמה, כדי להגדיר את פרמטרי ה-JDBC‏ encrypt=true&trustServerCertificate=true, מעבירים את הארגומנטים הבאים:

מפתח	ערך
source.connector.database.encrypt	true
source.connector.database.trustServerCertificate	true

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

בקטע הקודם.

הגדרת הפרמטר של המפתח הראשי

לטבלת המקור שמשוכפלת צריך להיות מפתח ראשי. הדרישה הזו חלה רק כש-Oracle הוא מסד הנתונים של המקור. במקורות של SQL Server ו-MySQL, אפשר לציין מפתח ראשי מותאם אישית, גם אם בטבלת המקור אין מפתח כזה.

מגדירים את הפרמטר key באמצעות ארגומנט זמן הריצה הבא:

source.connector.message.key.columns = SCHEMA.TABLE:KEY_COLUMN

מחליפים את מה שכתוב בשדות הבאים:

• ‫SCHEMA: השם של סכימת המקור.
• ‫TABLE: שם טבלת המקור.
• ‫KEY_COLUMN: העמודה שמכילה את המפתח המאובטח.

אפשר להגדיר את המפתח הראשי לכמה טבלאות באמצעות המאפיין key. בדוגמה הבאה מוצג איך להגדיר את המפתח לטבלאות inventory.customers ו-purchase.orders:

source.connector.message.key.columns = inventory.customers:pk1,pk2;purchase.orders:pk3,pk4

הגדרת מצב בידוד לתמונת מצב בשכפול של SQL Server

מידע נוסף על ארגומנט זמן הריצה למצב בידוד זמין במאמר רמות בידוד בשכפול של SQL Server.

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

• מידע נוסף על שכפול ב-Cloud Data Fusion
• מידע נוסף זמין במאמר Replication API reference.