הגדרת מסד נתונים של MongoDB בניהול עצמי ל-CDC

אתם יכולים להשתמש ב-Datastream כדי להעביר עדכונים של סימון נתונים שהשתנו (CDC) ממערכי רפליקות או מאשכולות מפוצלים בניהול עצמי של MongoDB אל יעד נתמך, כמו BigQuery או Cloud Storage. כדי להכין את המקור, יוצרים משתמש Datastream עם הרשאות קריאה במסד הנתונים admin לפריסה.

קבוצת רפליקות

במאמר פריסת קבוצת רפליקות בניהול עצמי במסמכי התיעוד של MongoDB מוסבר איך פורסים קבוצת רפליקות של MongoDB.

כדי להגדיר את Datastream לשימוש עם קבוצת רפליקות של MongoDB בניהול עצמי:

1. מתקינים את MongoDB Shell. במאמר Install mongosh מוסבר איך מתקינים את MongoDB Shell.
2. פותחים את חלון הטרמינל ומריצים את הפקודה mongosh כדי להתחבר לקבוצת הרפליקות או לצומת הראשי.

3. יוצרים משתמש ל-Datastream במסד הנתונים admin:

   use admin
   db.createUser({
     user: "USERNAME",
     pwd: "PASSWORD",
     roles: [ "readAnyDatabase", {role: "read", db: "admin"} ]
   })
   

   מחליפים את USERNAME ואת PASSWORD בשם המשתמש ובסיסמה שבחרתם.

אשכול מפוצל (sharded)

למידע על פריסת אשכול עם פיצול, קראו את המאמר פריסת אשכול עם פיצול במסמכי התיעוד של MongoDB.

כדי להגדיר את Datastream לשימוש עם אשכול מפוצל של MongoDB בניהול עצמי, מבצעים את השלבים הבאים:

1. מתקינים את MongoDB Shell. במאמר התקנת mongosh מוסבר איך מתקינים את MongoDB Shell.
2. פותחים את חלון הטרמינל ומריצים את הפקודה mongosh כדי להתחבר לאשכול המפוצל של MongoDB.

3. יוצרים משתמש Datastream בכל צומת של פיצול ראשי ובנתב השאילתות mongos:

   use admin
   db.createUser({
      user: "USERNAME",
      pwd: "PASSWORD",
      roles: [ "readAnyDatabase" ]
   })
   

   מחליפים את USERNAME ואת PASSWORD בשם המשתמש ובסיסמה שלכם. אפשר לבחור כל שם משתמש וסיסמה, אבל הם חייבים להיות זהים בכל הצמתים של ה-shard הראשי ובנתב השאילתות של mongos.

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

   db.adminCommand({ listShards: 1 })