אפשר להזרים עדכונים של נתוני שינוי (CDC) מאשכול Amazon Aurora MySQL אל יעדים כמו BigQuery או Cloud Storage באמצעות Datastream. לפני שיוצרים מקור נתונים, צריך להגדיר קבוצת פרמטרים של אשכול, להגדיר את תקופת השמירה של היומן הבינארי ולהעניק הרשאות שכפול למשתמש במסד הנתונים של Datastream.
לפני שמתחילים, ודאו שיש לכם אשכול קיים של Amazon Aurora ושאתם מחוברים לנקודת הקצה של הכותב בשרת מסד הנתונים הראשי.
יצירת קבוצת פרמטרים
מפעילים את מרכז הבקרה של Amazon RDS.
בחלונית ההזזה לניווט, לוחצים על קבוצות פרמטרים.
לוחצים על יצירת קבוצת פרמטרים. מופיע הדף Create Parameter Group.
משתמשים בטבלה הבאה כדי למלא את השדות בדף הזה:
שדה תיאור קבוצת פרמטרים משפחתית בוחרים את הקבוצה המשפחתית שתואמת למסד הנתונים שלכם. סוג בוחרים באפשרות DB Cluster Parameter Group. שם הקבוצה נותנים שם לקבוצת הפרמטרים. תיאור צריך להוסיף תיאור לקבוצת הפרמטרים. לוחצים על יצירה.
מסמנים את התיבה שמימין לקבוצת הפרמטרים החדשה שיצרתם.
בקטע פעולות בקבוצת פרמטרים, לוחצים על עריכה.
מגדירים את ערכי הפרמטרים הבאים:
לרפליקציה מבוססת-GTID:
פרמטר ערך binlog_format ROWlog_bin_use_v1_row_events 1read_only 0net_read_timeout 3600net_write_timeout 3600wait_timeout 86400expire-logs-days 7binlog_row_image FULLmax_allowed_packet 1G(הערך המומלץ)log-replica-updates 1enforce-gtid-consistency ONgtid_mode
אפשר להגדיר את הפרמטר הזה לערךONONרק אחרי שמגדירים אתenforce-gtid-consistencyלערךON. באופן כללי,gtid_modeיכול לקבל את הערכים הבאים:OFFOFF_PERMISSIVEON_PERMISSIVEON
gtid_modeרק שלב אחד בכל פעם. לדוגמה, אם המצב הנוכחי מוגדר ל-OFF, מבצעים את הפעולות הבאות:- משנים את ההגדרה ל-
OFF_PERMISSIVE. - משנים את ההגדרה ל-
ON_PERMISSIVE. - משנים את ההגדרה ל-
ON.
לרפליקציה מבוססת-binlog:
פרמטר ערך binlog_format ROW
לוחצים על שמירת השינויים.
הקצאת קבוצת הפרמטרים למופע של מסד הנתונים
מפעילים את מרכז השליטה של Amazon RDS.
בחלונית הזזה לניווט, לוחצים על מסדי נתונים ואז בוחרים את מופע מסד הנתונים.
בתפריט פעולות על המופע, בוחרים באפשרות שינוי. מופיעה תיבת הדו-שיח Modify DB Instance.
בקטע Additional configuration, בוחרים את קבוצת הפרמטרים של אשכול מסד הנתונים שיצרתם.
מגדירים את Backup retention period ל-7 days.
לוחצים על Continue.
בחלונית Scheduling of Modifications, בוחרים באפשרות Apply immediately.
הגדרת תקופת השמירה של היומן הבינארי
מזינים את הפקודה הבאה ב-MySQL:
call mysql.rds_set_configuration('binlog retention hours', 168);
מפעילים מחדש את שרת MySQL כדי שהשינויים ייכנסו לתוקף.
יצירת משתמש ב-Datastream
יוצרים משתמש Datastream:
CREATE USER 'datastream'@'%' IDENTIFIED BY 'YOUR_PASSWORD';
נותנים להם את ההרשאות הבאות:
GRANT REPLICATION SLAVE, SELECT, REPLICATION CLIENT ON *.* TO 'datastream'@'%'; GRANT EXECUTE ON PROCEDURE mysql.rds_show_configuration TO 'datastream'@'%'; FLUSH PRIVILEGES;