באמצעות רפליקציה ב-Cloud Data Fusion, אתם יכולים להעביר בסטרימינג שינויים בנתונים בזמן אמת ממסדי נתונים תפעוליים. אתם יכולים להפעיל את Replication במכונה קיימת כדי לפרוס צינורות עיבוד נתונים של סימון נתונים שהשתנו (CDC) באופן רציף.
מידע נוסף זמין במאמר סקירה כללית על רפליקציה.
הפעלת הרפליקציה
cURL
מפעילים את מאיץ הרפליקציה במכונה:
curl -H "Authorization: Bearer $(gcloud auth print-access-token)" \ -H "Content-Type: application/json" \ https://datafusion.googleapis.com/v1/projects/PROJECT_NAME/locations/LOCATION/instances/INSTANCE_NAME?updateMask=accelerators \ -X PATCH \ -d '{ "accelerators":[{"accelerator_type":"CDC", "state":"ENABLED"}]} 'בפקודה לדוגמה הבאה אפשר לראות איך כוללים תוויות שכבר הוחלו על מכונה:
curl -H "Authorization: Bearer $(gcloud auth print-access-token)" \ -H "Content-Type: application/json" \ https://datafusion.googleapis.com/v1/projects/PROJECT_NAME/locations/LOCATION/instances/INSTANCE_NAME?updateMask=accelerators \ -X PATCH \ -d '{ "accelerators":[{"accelerator_type":"CDC", "state":"ENABLED"}], "labels":{"KEY_1":"VALUE_1","KEY_2":"VALUE_2"}}'מחליפים את מה שכתוב בשדות הבאים:
-
PROJECT_NAME: שם הפרויקט ב- Google Cloud -
LOCATION: המיקום, לדוגמהus-east1 -
INSTANCE_NAME: השם של מכונת Cloud Data Fusion -
KEY_1ו-VALUE_1: המפתחות והערכים של התוויות
-
אופציונלי: כדי לוודא שהשינוי בוצע בהצלחה, לוחצים על System Admin (מנהל מערכת). Delta Assessor מופיע ברשימת השירותים.
המשבצת Replication מופיעה בדף הבית של Cloud Data Fusion.
לוחצים על System Admin כדי לבדוק את הסטטוס של השירות Delta Assessor. כשהסטטוס ירוק, אפשר ליצור משימות רפליקציה.