Amazon S3

מחבר Amazon S3 מספק גישת SQL לאובייקטים ולקטגוריות של Amazon S3.

לפני שמתחילים

לפני שמשתמשים במחבר Amazon S3, צריך לבצע את המשימות הבאות:

• בפרויקט שלכם ב-Google Cloud:
  • מוודאים שהגדרתם חיבור לרשת. מידע על תבניות רשת זמין במאמר קישוריות לרשת.
  • נותנים למשתמש שמגדיר את המחבר את תפקיד ה-IAM‏ roles/connectors.admin.
  • מקצים לחשבון השירות שרוצים להשתמש בו עבור המחבר את תפקידי ה-IAM הבאים:
    • roles/secretmanager.viewer
    • roles/secretmanager.secretAccessor

    חשבון שירות הוא סוג מיוחד של חשבון Google שמייצג משתמש לא אנושי, שצריך לאמת ולאשר כדי לתת לו גישה לנתונים ב-Google APIs. אם אין לכם חשבון שירות, אתם צריכים ליצור חשבון שירות. המחבר וחשבון השירות צריכים להיות שייכים לאותו פרויקט. מידע נוסף זמין במאמר בנושא יצירת חשבון שירות.

  • מפעילים את השירותים הבאים:
    • ‫secretmanager.googleapis.com (Secret Manager API)
    • ‫connectors.googleapis.com (Connectors API)

    במאמר הפעלת שירותים מוסבר איך להפעיל שירותים.

  אם השירותים או ההרשאות האלה לא הופעלו בפרויקט שלכם בעבר, תתבקשו להפעיל אותם כשאתם מגדירים את המחבר.

הגדרת המחבר

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

1. במסוף Cloud, עוברים לדף Integration Connectors > Connections ובוחרים או יוצרים פרויקט בענן.

   כניסה לדף Connections

2. לוחצים על + יצירת חיבור חדש כדי לפתוח את הדף יצירת חיבור.
3. בקטע מיקום, בוחרים את המיקום של החיבור.
   1. אזור: בוחרים מיקום מהרשימה הנפתחת.

      אזורים נתמכים למחברים:

      רשימה של כל האזורים הנתמכים מופיעה במאמר מיקומים.

   2. לוחצים על הבא.
4. בקטע פרטי החיבור, ממלאים את הפרטים הבאים:
   1. כלי לחיבור: בוחרים באפשרות Amazon S3 מהרשימה הנפתחת של כלי החיבור הזמינים.
   2. גרסת כלי החיבור: בוחרים את גרסת כלי החיבור מהרשימה הנפתחת של הגרסאות הזמינות.
   3. בשדה Connection Name (שם החיבור), מזינים שם למופע החיבור.

      השמות של החיבורים צריכים לעמוד בקריטריונים הבאים:

      • שמות החיבורים יכולים לכלול אותיות, מספרים או מקפים.
      • האותיות צריכות להיות קטנות.
      • שמות החיבורים צריכים להתחיל באות ולהסתיים באות או במספר.
      • שמות החיבורים לא יכולים לכלול יותר מ-49 תווים.
   4. אופציונלי: מזינים תיאור למופע החיבור.
   5. אופציונלי: מפעילים את Cloud Logging ואז בוחרים רמת יומן. כברירת מחדל, רמת היומן מוגדרת כ-Error.
   6. חשבון שירות: בוחרים חשבון שירות שיש לו את התפקידים הנדרשים.
   7. אופציונלי: מגדירים את ההגדרות של צומת החיבור:
      • מספר מינימלי של צמתים: מזינים את המספר המינימלי של צמתי חיבור.
      • מספר הצמתים המקסימלי: מזינים את מספר צמתי החיבור המקסימלי.

      צומת הוא יחידה (או עותק) של חיבור שמבצעת עיבוד של עסקאות. כדי לעבד יותר עסקאות לחיבור נדרשים יותר צמתים, ולהפך: כדי לעבד פחות עסקאות נדרשים פחות צמתים. כדי להבין איך הצמתים משפיעים על התמחור של המחבר, אפשר לעיין במאמר בנושא תמחור של צמתי חיבור. אם לא מזינים ערכים, כברירת מחדל, מספר הצמתים המינימלי מוגדר כ-2 (לזמינות טובה יותר) ומספר הצמתים המקסימלי מוגדר כ-50.

   הערה: אפשר להתאים אישית את הערכים של צומת החיבור רק אם אתם לקוחות עם תשלום לפי שימוש.
   8. ‫AWS Region: האזור שבו מתארחת מכונת Amazon S3
   9. אופציונלי: לוחצים על + הוספת תווית כדי להוסיף תווית לקישור בצורה של צמד מפתח/ערך.
   10. לוחצים על הבא.
5. בקטע יעדים, מזינים את הפרטים של המארח המרוחק (מערכת העורף) שאליו רוצים להתחבר.
   1. סוג היעד: בוחרים סוג יעד.
      • כדי לציין את שם המארח או את כתובת ה-IP של היעד, בוחרים באפשרות כתובת המארח ומזינים את הכתובת בשדה מארח 1.
      • כדי ליצור חיבור פרטי, בוחרים באפשרות Endpoint attachment (צירוף נקודת קצה). ברשימה Endpoint Attachment, בוחרים את קובץ ה-Endpoint Attachment שנוצר עבור מערכת ה-Backend.
      הערה: מידע על יצירת צירוף של נקודת קצה זמין במאמר קישוריות לרשת פרטית. אחרי שיוצרים את ההצמדה של נקודת הקצה, היא מופיעה ברשימה Endpoint Attachment.

      אם רוצים ליצור חיבור ציבורי למערכות העורפיות עם אבטחה נוספת, אפשר להגדיר כתובות IP סטטיות יוצאות לחיבורים, ואז להגדיר את כללי חומת האש כך שרק כתובות ה-IP הסטטיות הספציפיות יופיעו ברשימת ההיתרים.

      כדי להזין יעדים נוספים, לוחצים על +הוספת יעד.

   2. לוחצים על הבא.
6. בקטע אימות, מזינים את פרטי האימות.
   1. בוחרים סוג אימות ומזינים את הפרטים הרלוונטיים.

      החיבור ל-Amazon S3 תומך בסוגי האימות הבאים:

      • פרטי הכניסה של הבסיס
      • תפקידי IAM ב-AWS
      • פרטי כניסה זמניים של AWS

   כדי להבין איך להגדיר את סוגי האימות האלה, אפשר לעיין במאמר בנושא הגדרת אימות.

   2. לוחצים על הבא.
7. בדיקה: בודקים את פרטי החיבור והאימות.
8. לוחצים על יצירה.

הגדרת אימות

מזינים את הפרטים בהתאם לאימות שבו רוצים להשתמש.

• פרטי כניסה של משתמש על

  כדי לבצע אימות באמצעות פרטי הכניסה של חשבון הבסיס.

  • מפתח גישה של AWS: מפתח הגישה של משתמש ה-Root
  • ‫AWS Access Secret: המפתח הסודי של משתמש ה-Root

• AWS IAM Roles

  כדי לבצע אימות באמצעות תפקיד AWS IAM.

  • מפתח גישה של AWS: מפתח הגישה של משתמש IAM שמוקצה לו התפקיד
  • ‫AWS Access Secret: המפתח הסודי של משתמש IAM שמוקצה לו התפקיד
  • AWS Role ARN: מציינים את ה-ARN של התפקיד שרוצים לאמת. רק פרטי הכניסה לתפקיד שצוין יאוחזרו.
  • מזהה חיצוני של AWS: נדרש רק כשמניחים תפקיד בחשבון אחר.

• AWS Temporary Credentials

  כדי לבצע אימות באמצעות פרטי כניסה זמניים

  • מפתח גישה של AWS: מפתח הגישה של משתמש IAM שמוקצה לו התפקיד
  • ‫AWS Access Secret: המפתח הסודי של משתמש IAM שמוקצה לו התפקיד
  • ‫AWS Session Token: האסימון הזה נוצר יחד עם פרטי הכניסה הזמניים.
  • AWS Role ARN: מציינים את ה-ARN של התפקיד שרוצים לאמת. רק פרטי הכניסה לתפקיד שצוין יאוחזרו.
  • מזהה חיצוני של AWS: נדרש רק כשמניחים תפקיד בחשבון אחר.

מידע על הגדרת חשבון AWS זמין במאמר הגדרת Amazon S3. במאמר יצירת קטגוריית S3 מוסבר איך ליצור קטגוריית S3. צריך לפנות לאדמין ב-AWS כדי ליצור פרטי כניסה לתפקיד AWS IAM או פרטי כניסה זמניים ל-AWS בחשבון AWS.

דוגמאות להגדרת חיבור

בקטע הזה מפורטים ערכים לדוגמה של השדות השונים שאתם מגדירים כשאתם יוצרים את החיבור ל-Amazon S3.

סוג החיבור של פרטי הכניסה של הבסיס

שם השדה	פרטים
מיקום	europe-west1
מחבר	Amazon S3
גרסת המחבר	1
שם החיבור	aws-s3
תיאור	aws-s3
חשבון השירות	SERVICE_ACCOUNT_NAME@serviceaccount
אזור AWS	צפון וירג'יניה
מספר הצמתים המינימלי	2
מספר הצמתים המקסימלי	50
פרטי הכניסה של הבסיס	כן
מפתח גישה ל-AWS	AWS_ACCESS_KEY
סוד הגישה של AWS	AWS_ACCESS_SECRET
גרסה של סוד	1

סוג החיבור של תפקידי IAM ב-AWS

שם השדה	פרטים
מיקום	europe-west1
מחבר	Amazon S3
גרסת המחבר	1
שם החיבור	aws-s3
תיאור	aws-s3
חשבון השירות	SERVICE_ACCOUNT_NAME@serviceaccount
אזור AWS	צפון וירג'יניה
מספר הצמתים המינימלי	2
מספר הצמתים המקסימלי	50
תפקידי IAM ב-AWS	כן
מפתח גישה ל-AWS	AWS_ACCESS_KEY
סוד הגישה של AWS	AWS_ACCESS_SECRET
גרסה של סוד	1

סוג החיבור של פרטי כניסה זמניים של AWS

שם השדה	פרטים
מיקום	europe-west1
מחבר	Amazon S3
גרסת המחבר	1
שם החיבור	aws-s3
תיאור	aws-s3
חשבון השירות	SERVICE_ACCOUNT_NAME@serviceaccount
אזור AWS	צפון וירג'יניה
מספר הצמתים המינימלי	2
מספר הצמתים המקסימלי	50
פרטי כניסה זמניים של AWS	כן
מפתח גישה ל-AWS	AWS_ACCESS_KEY
סוד הגישה של AWS	AWS_ACCESS_SECRET
גרסה של סוד	1
טוקן סשן של AWS	AWS_SESSION_TOKEN

ישויות, פעולות ופעולות

כל Integration Connectors מספקים שכבת הפשטה לאובייקטים של האפליקציה המחוברת. אפשר לגשת לאובייקטים של אפליקציה רק דרך ההפשטה הזו. ההפשטה מוצגת לכם כישויות, פעולות ופעולות.

הערה: אפשר לראות את הישויות, הפעולות והפעולות של מחבר במשימת המחברים.

• ישות: ישות היא אובייקט או אוסף של מאפיינים באפליקציה או בשירות המקושרים. ההגדרה של ישות משתנה ממחבר למחבר. לדוגמה, במחבר של מסד נתונים, הטבלאות הן הישויות, במחבר של שרת קבצים, התיקיות הן הישויות, ובמחבר של מערכת הודעות, התורים הם הישויות.

  עם זאת, יכול להיות שמחבר לא תומך בישויות או שאין לו ישויות, ובמקרה כזה הרשימה Entities תהיה ריקה.

• פעולה: פעולה היא הפעילות שאפשר לבצע בישות. אפשר לבצע כל אחת מהפעולות הבאות בישות:
  • רשימה
  • הרשמה
  • יצירה
  • עדכון
  • מחיקה

  בחירה של ישות מתוך הרשימה הזמינה יוצרת רשימה של פעולות שזמינות לישות. תיאור מפורט של הפעולות זמין במאמר פעולות על ישויות של משימת המחברים. עם זאת, אם מחבר לא תומך באף אחת מהפעולות על ישויות, הפעולות הלא נתמכות האלה לא יופיעו ברשימה Operations.

• פעולה: פעולה היא פונקציה מסוג first class שזמינה לשילוב דרך ממשק המחבר. פעולה מאפשרת לבצע שינויים בישות אחת או בכמה ישויות, והיא משתנה ממתחם למתחם. בדרך כלל, לפעולה יהיו כמה פרמטרים של קלט ופרמטר של פלט. עם זאת, יכול להיות שמחבר לא תומך באף פעולה, ובמקרה כזה הרשימה Actions תהיה ריקה.

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

פעולות

בקטע הזה מפורטות חלק מהפעולות שהמחבר תומך בהן. כדי להבין איך להגדיר את הפעולות, אפשר לעיין בדוגמאות לפעולות.

הערה: התוצאות של כל הפעולות יהיו זמינות כתגובת JSON בפרמטר התגובה של משימת Connectors connectorOutputPayload אחרי שמריצים את השילוב.

הפעולה CopyObject

הפעולה הזו מאפשרת להעתיק אובייקט מקטגוריה אחת לקטגוריה אחרת או בתוך אותה קטגוריה.

פרמטרים של קלט בפעולה CopyObject

שם הפרמטר	סוג הנתונים	חובה	תיאור
BucketSource	String	כן	שם הקטגוריה שממנה רוצים להעתיק את האובייקט.
ObjectSource	אובייקט	כן	שם האובייקט שרוצים להעתיק.
BucketDestination	String	כן	שם הקטגוריה שאליה רוצים להעתיק את האובייקט.
ObjectDestination	String	לא	שם האובייקט בקטגוריית היעד. אם לא מציינים שם, השם יהיה זהה לשם המקורי.

פרמטרים של פלט של הפעולה CopyObject

אם ההעתקה בוצעה ללא שגיאות, הפעולה הזו מחזירה את הסטטוס 200 (OK).

במאמר דוגמאות לפעולות מוסבר איך להגדיר את הפעולה CopyObject.

הפעולה DownloadObjects

הפעולה הזו מקבלת עוד אובייקטים מקטגוריה.

פרמטרים של קלט בפעולה DownloadObjects

שם הפרמטר	סוג הנתונים	חובה	תיאור
קטגוריה	String	כן	שם הקטגוריה שבה נמצא האובייקט שרוצים להוריד.
אובייקט	String	לא	שם האובייקט שצריך להוריד. אם לא מציינים את האפשרות הזו, כל האובייקטים מהקטגוריה שצוינה יורדו.
HasBytes	בוליאני	כן	מציינים אם התוכן צריך להיות מורד כמחרוזת בקידוד Base64.
UpdatedStartDate	תאריך ושעה	לא	תאריך ההתחלה של טווח הזמן להורדת אובייקטים. אם לא מציינים את התאריך, האובייקטים יורדים מהתאריך הכי ישן עד לתאריך UpdatedEndDate.
UpdatedEndDate	תאריך ושעה	לא	תאריך הסיום של טווח הזמן להורדת אובייקטים. אם לא מציינים את הפרמטר הזה, האובייקטים יורדו מהתאריך שצוין ב-UpdatedStartDate עד היום הנוכחי.

פרמטרים של פלט של הפעולה DownloadObjects

אם ההורדה מתבצעת בהצלחה, הפעולה הזו מחזירה את הסטטוס 200 (OK).

במאמר דוגמאות לפעולות מוסבר איך להגדיר את הפעולה DownloadObjects.

הפעולה UploadObject

הפעולה הזו מאפשרת להעלות אובייקט לקטגוריה.

פרמטרים של קלט בפעולה UploadObject

שם הפרמטר	סוג הנתונים	חובה	תיאור
קטגוריה	String	כן	שם הקטגוריה שאליה צריך להעלות את האובייקט.
ContentBytes	String	לא	תוכן הבייטים להעלאה כקובץ.
HasBytes	בוליאני	כן	מציינים אם התוכן צריך להיות מועלה כמחרוזת בקידוד Base64.
AccessPolicy	String	לא	מדיניות הגישה לאובייקט הזה. הערכים המותרים הם PRIVATE,‏ ANONREAD,‏ ANONREADWRITE ו-AUTHREAD. ערך ברירת המחדל הוא PRIVATE.
תוכן	String	לא	התוכן שרוצים להעלות.
FileName	String	לא	השם של הקובץ שרוצים להעלות. הערך הזה נדרש כשמציינים את הפרמטר FileContent.

פרמטרים של פלט הפעולה UploadObject

הפעולה הזו מחזירה את הסטטוס 200 (OK) אם העלאת האובייקט מתבצעת בהצלחה.

במאמר דוגמאות לפעולות מוסבר איך להגדיר את הפעולה UploadObject.

פעולת DeleteObject

הפעולה הזו מאפשרת למחוק אובייקט מקטגוריה.

פרמטרים של קלט לפעולה DeleteObject

שם הפרמטר	סוג הנתונים	חובה	תיאור
קטגוריה	String	כן	שם הקטגוריה שבה נמצא האובייקט שרוצים למחוק.
אובייקט	String	כן	שם האובייקט שצריך למחוק.

פרמטרים של פלט של הפעולה DeleteObject

אם המחיקה מתבצעת בהצלחה, הפעולה הזו מחזירה את הסטטוס 200 (OK).

במאמר דוגמאות לפעולות מוסבר איך להגדיר את הפעולה DeleteObject.

פעולת MoveObject

הפעולה הזו מאפשרת למשתמשים להעביר אובייקט קיים מקטגוריה ספציפית לקטגוריה אחרת או לאותה קטגוריה.

פרמטרים של קלט לפעולה MoveObject

שם הפרמטר	סוג הנתונים	חובה	תיאור
BucketSource	String	כן	שם קטגוריית המקור שבה נמצא האובייקט שרוצים להעביר.
ObjectSource	String	כן	שם האובייקט שרוצים להעביר.
BucketDestination	String	כן	שם קטגוריית היעד שאליה רוצים להעביר את האובייקט.
ObjectDestination	String	לא	שם האובייקט בקטגוריית היעד. אם לא מציינים שם חדש, השם המקורי נשמר.

פרמטרים של פלט של הפעולה MoveObject

הפעולה הזו מחזירה את הסטטוס 200 (OK) אם פעולת ההעברה בוצעה בהצלחה.

במאמר דוגמאות לפעולות מוסבר איך להגדיר את הפעולה MoveObject.

פעולת PutBucketAcl

הפעולה הזו מאפשרת לעדכן את הרשימה של בקרת הגישה (ACL) של קטגוריה.

פרמטרים של קלט לפעולה PutBucketAcl

שם הפרמטר	סוג הנתונים	חובה	תיאור
קטגוריה	String	כן	שם הקטגוריה שצריך להחיל עליה את רשימת ה-ACL.
ACL	String	כן	רמת הגישה שתחול על הקטגוריה.

פרמטרים של פלט של הפעולה PutBucketAcl

הפעולה הזו מחזירה את הסטטוס 200 (OK) אם העדכון של רשימת בקרת הגישה (ACL) של הדלי בוצע בהצלחה.

במאמר דוגמאות לפעולות מוסבר איך להגדיר את הפעולה PutBucketAcl.

פעולת PutObjectAcl

הפעולה הזו מאפשרת לעדכן את הרשימה של בקרת הגישה (ACL) של אובייקט בקטגוריה.

פרמטרים של קלט לפעולה PutObjectAcl

שם הפרמטר	סוג הנתונים	חובה	תיאור
קטגוריה	String	כן	שם הקטגוריה שבה האובייקט נמצא.
ACL	String	כן	רמת הגישה שתחול על האובייקט.
מפתח	String	כן	שם האובייקט שעליו צריך להחיל את רשימת ה-ACL.

פרמטרים של פלט של הפעולה PutObjectAcl

אם העדכון של ה-ACL של האובייקט מתבצע בהצלחה, הפעולה הזו מחזירה את הסטטוס 200 (OK).

במאמר דוגמאות לפעולות מוסבר איך להגדיר את הפעולה PutObjectAcl.

דוגמאות לפעולות

בקטע הזה מוסבר איך לבצע חלק מהפעולות במחבר הזה.

דוגמה – העתקת אובייקט

בדוגמה הזו מועתק אובייקט מקטגוריה אחת לקטגוריה אחרת.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Actions.
2. בוחרים את הפעולה CopyObject ולוחצים על סיום.
3. בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על connectorInputPayload ומזינים ערך דומה לערך הבא בשדה Default Value:

   {
   "BucketSource": "aws-s3-bucket-source",
   "ObjectSource": "pic.jpg",
   "BucketDestination": "aws-s3-bucket-destination",
   "ObjectDestination": "new_pic.jpg"
   }

אם הפעולה מצליחה, לפרמטר התגובה CopyObject של המשימה connectorOutputPayload יהיה ערך שדומה לזה:

[{
"Status": "Success"
}]

דוגמה – הורדת אובייקט

בדוגמה הזו מורידים אובייקט מהקטגוריה שצוינה.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Actions.
2. בוחרים את הפעולה DownloadObjects ולוחצים על סיום.
3. בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על connectorInputPayload ומזינים ערך דומה לערך הבא בשדה Default Value:

   {
   "Bucket": "aws-s3-bucket-source",
   "HasBytes": true
   }

אם הפעולה מצליחה, לפרמטר התגובה DownloadObjects של המשימה connectorOutputPayload יהיה ערך שדומה לזה:

[{
"Success": "True",
"RemoteFile": "prefix1%2Faws-s3-bucket-source%2Finventory-test-1%2F2023-09-10T01-00Z%2Fmanifest.json",
"ContentBytes": "ewogICJzb3VyY2VCdWNrZXQiIDogImF3cy1zMy1idWNrZXQtYmNvbmUiLAogICJnOK"
},
{
"Success": "True",
"RemoteFile": "upload1.txt",
"ContentBytes": "VGhpcyBpcyBhIHRlc3RpbmcgZmlsZQ=="
}]

דוגמה – העלאת אובייקט

בדוגמה הזו מועלה אובייקט לקטגוריה שצוינה.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Actions.
2. בוחרים את הפעולה UploadObject ולוחצים על סיום.
3. בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על connectorInputPayload ומזינים ערך דומה לערך הבא בשדה Default Value:

   {
   "Bucket": "aws-s3-bucket-source",
   "FileName": "upload_1.txt",
   "Content": "This is a testing file",
   "AccessPolicy": "PUBLIC"
   }

אם הפעולה מצליחה, לפרמטר התגובה UploadObject של המשימה connectorOutputPayload יהיה ערך שדומה לזה:

[{
"Status": "success",
"bucket": "aws-s3-bucket-source",
"rss:title": "Object 'upload_1.txt' was created in the bucket: aws-s3-bucket-source",
"object": "upload_1.txt"
}]

דוגמה – מחיקת אובייקט

בדוגמה הזו נמחק אובייקט מהקטגוריה שצוינה.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Actions.
2. בוחרים את הפעולה DeleteObject ולוחצים על סיום.
3. בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על connectorInputPayload ומזינים ערך דומה לערך הבא בשדה Default Value:

   {
   "Bucket": "aws-s3-bucket-source",
   "Object": "abc.png"
   }

אם הפעולה מצליחה, לפרמטר התגובה DeleteObject של המשימה connectorOutputPayload יהיה ערך שדומה לזה:

[{
"Status": "Success"
}]

דוגמה – העברת אובייקט

בדוגמה הזו, אובייקט מועבר מקטגוריה אחת לקטגוריה אחרת.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Actions.
2. בוחרים את הפעולה MoveObject ולוחצים על סיום.
3. בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על connectorInputPayload ומזינים ערך דומה לערך הבא בשדה Default Value:

   {
   "BucketSource": "aws-s3-bucket-source",
   "ObjectSource": "abc.png",
   "BucketDestination": "aws-s3-bucket-destination",
   "ObjectDestination": "moved.png"
   }

אם הפעולה מצליחה, לפרמטר התגובה MoveObject של המשימה connectorOutputPayload יהיה ערך שדומה לזה:

[{
"Status": "Success"
}]

דוגמה – עדכון ה-ACL של קטגוריה

בדוגמה הזו מעדכנים את הרשאות בקרת הגישה של קטגוריה.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Actions.
2. בוחרים את הפעולה PutBucketAcl ולוחצים על סיום.
3. בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על connectorInputPayload ומזינים ערך דומה לערך הבא בשדה Default Value:

   {
   "BucketSource": "aws-s3-bucket-source",
   "ACL": "public-read"
   }

אם הפעולה מצליחה, לפרמטר התגובה PutBucketAcl של המשימה connectorOutputPayload יהיה ערך שדומה לזה:

[{
"Status": "Success"
}]

דוגמה – עדכון ה-ACL של אובייקט

בדוגמה הזו מעדכנים את הרשאות בקרת הגישה לאובייקט בקטגוריה.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Actions.
2. בוחרים את הפעולה PutObjectAcl ולוחצים על סיום.
3. בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על connectorInputPayload ומזינים ערך דומה לערך הבא בשדה Default Value:

   {
   "Bucket": "aws-s3-bucket-source",
   "ACL": "aws-exec-read",
   "Key": "AWS_S3_BusinessCase_V2.xlsx"
   }

אם הפעולה מצליחה, לפרמטר התגובה PutObjectAcl של המשימה connectorOutputPayload יהיה ערך שדומה לזה:

[{
"Status": "Success"
}]

דוגמאות לפעולות על ישויות

בקטע הזה מוסבר איך לבצע חלק מהפעולות על ישויות במחבר הזה.

דוגמה – הצגת המטא-נתונים של כל האובייקטים

בדוגמה הזו מאחזרים את המטא-נתונים של כל האובייקטים בישות Object.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Entities.
2. בוחרים באפשרות Object מהרשימה Entity.
3. בוחרים את הפעולה List ולוחצים על סיום.
4. אופציונלי: בקטע Task Input (קלט משימה) במשימה Connectors (מחברים), אפשר לסנן את קבוצת התוצאות על ידי ציון filter clause (סעיף מסנן). תמיד מציינים את הערך של סעיף הסינון בתוך גרשיים בודדים ('). לדוגמה, Bucket='test-bucket'. אפשר גם לציין כמה תנאי סינון באמצעות אופרטורים לוגיים. לדוגמה, Bucket='test-bucket' and OwnerId='b1ecc809ad8467088afb'.

דוגמה – אחזור מטא-נתונים של קטגוריה

בדוגמה הזו מאחזרים את המטא-נתונים של הקטגוריה עם המזהה שצוין מהישות Bucket.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Entities.
2. בוחרים באפשרות Bucket מהרשימה Entity.
3. בוחרים את הפעולה Get ולוחצים על סיום.
4. בקטע Task Input (קלט של המשימה) במשימה Connectors (מחברים), לוחצים על EntityId (מזהה הישות) ואז מזינים demo_replication בשדה Default Value (ערך ברירת המחדל).

   כאן, demo_replication הוא מזהה ייחודי של קטגוריה בישות Bucket.

דוגמה – יצירת קטגוריה

בדוגמה הזו נוצרת קטגוריה בישות Bucket.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Entities.
2. בוחרים באפשרות Bucket מהרשימה Entity.
3. בוחרים את הפעולה Create ולוחצים על סיום.
4. בקטע Task Input (קלט המשימה) של המשימה Connectors (מחברים), לוחצים על connectorInputPayload ומזינים ערך דומה לערך הבא בשדה Default Value:

   {
   "Bucket": "Demo1697528098686"
   }

   אם השילוב יצליח, בשדה connectorOutputPayload של משימת המחבר יופיע ערך שדומה לערך הבא:

   [{
   "Bucket": "Demo1697528098686"
   }]

דוגמה – מחיקת קטגוריה

בדוגמה הזו נמחקת הקטגוריה עם המזהה שצוין בישות Bucket.

1. בתיבת הדו-שיח Configure connector task, לוחצים על Entities.
2. בוחרים באפשרות Bucket מהרשימה Entity.
3. בוחרים את הפעולה Delete ולוחצים על סיום.
4. בקטע Task Input (קלט משימה) של המשימה Connectors (מחברים), לוחצים על entityId ואז מזינים demo1697528098686 בשדה Default Value (ערך ברירת מחדל).

הערה: אם לישות יש מפתח ראשי מורכב, אפשר לציין סעיף סינון.

שימוש בחיבור Amazon S3 בשילוב

אחרי שיוצרים את החיבור, הוא זמין גם ב-Apigee Integration וגם ב-Application Integration. אפשר להשתמש בחיבור בשילוב באמצעות המשימה Connectors.

• כדי להבין איך ליצור ולהשתמש במשימה Connectors ב-Apigee Integration, אפשר לעיין במאמר משימת Connectors.
• מידע על יצירה ושימוש במשימת מחברים ב-Application Integration זמין במאמר משימת מחברים.

קבלת עזרה מקהילת Google Cloud

אתם יכולים לפרסם את השאלות שלכם ולדון במחבר הזה בקהילת Google Cloud בפורומים של Cloud.

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

• איך משעים ומחדשים חיבור
• איך עוקבים אחרי השימוש בכלי לחיבור נתונים
• איך צופים ביומני המחברים