שימוש בתוסף של מקור נתונים מסוג batch של Salesforce כדי לנתח נתוני לידים ב-BigQuery

כאן מוסבר איך להשתמש בתוסף של מקור נתונים באצוות של Salesforce ב-Cloud Data Fusion כדי לנתח נתוני לידים ב-BigQuery.


לחצו על תראו לי איך כדי לקרוא הסבר מפורט על המשימה ישירות במסוף Google Cloud :

תראו לי איך


תרחיש

נניח שמנהל שיווק מתכנן קמפיין שיווק באימייל שמטרגט קהל ספציפי מאוד כדי לקדם מוצר חדש. יש לכם רשימה של לידים ב-Salesforce Sales Cloud. לפני שיוצרים קמפיין ממוקד, כדאי להשתמש בתוסף של מקור נתונים מסוג batch של Salesforce ב-Cloud Data Fusion כדי לחלץ נתונים ספציפיים של לידים, וכך להבין טוב יותר את קהל היעד.

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

  1. נכנסים לחשבון Google Cloud . אם אתם משתמשים חדשים ב- Google Cloud, צרו חשבון כדי שתוכלו להעריך את הביצועים של המוצרים שלנו בתרחישים מהעולם האמיתי. לקוחות חדשים מקבלים בחינם גם קרדיט בשווי 300$ להרצה, לבדיקה ולפריסה של עומסי העבודה.
  2. In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

    Roles required to select or create a project

    • Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
    • Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

    Go to project selector

  3. Verify that billing is enabled for your Google Cloud project.

  4. In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

    Roles required to select or create a project

    • Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
    • Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

    Go to project selector

  5. Verify that billing is enabled for your Google Cloud project.

  6. מפעילים את ממשקי ה-API של Cloud Data Fusion,‏ BigQuery,‏ Cloud Storage ו-Dataproc.

    תפקידים שנדרשים להפעלת ממשקי API

    כדי להפעיל ממשקי API, נדרשת ההרשאה serviceusage.services.enable. אם יצרתם את הפרויקט, סביר להניח שכבר יש לכם את ההרשאה הזו דרך התפקיד 'בעלים' (roles/owner). אחרת, תוכלו לקבל את ההרשאה הזו דרך התפקיד 'אדמין בממשק 'שימוש בשירות'' (roles/serviceusage.serviceUsageAdmin). איך מקצים תפקידים

    הפעלת ממשקי ה-API

  7. יצירת מכונת Cloud Data Fusion
  8. מגדירים חיבור ל-Salesforce API על ידי יצירת אפליקציה מקושרת של Salesforce ל-Cloud Data Fusion.

ניהול הרשאות

ליצור ולהקצות את התפקידים וההרשאות הנדרשים בהתאמה אישית.

יצירת תפקיד בהתאמה אישית והוספת הרשאות

  1. נכנסים לדף Roles במסוף Google Cloud :

    לדף Roles

  2. לוחצים על יצירת תפקיד.

  3. בשדה Title, מזינים Custom Role-Tutorial.

  4. לוחצים על הוספת הרשאות.

  5. בחלון Add permissions, בוחרים את ההרשאות הבאות ולוחצים על Add:

    • bigquery.datasets.create
    • bigquery.jobs.create
    • storage.buckets.create
  6. לוחצים על יצירה.

הקצאת תפקיד בהתאמה אישית לחשבון השירות של Compute Engine שמוגדר כברירת מחדל

  1. עוברים לדף Instances ב-Cloud Data Fusion:

    כניסה לדף Instances

  2. לוחצים על השם של המופע.

  3. חשוב לרשום את חשבון השירות של Compute Engine שמוגדר כברירת מחדל. המידע הזה מופיע בדף הפרטים של המופע.

    הפורמט של שם חשבון השירות של Compute Engine שמוגדר כברירת מחדל ב-Cloud Data Fusion הוא CUSTOMER_PROJECT_NUMBER-compute@developer.gserviceaccount.com.

  4. נכנסים לדף IAM:

    כניסה לדף IAM

  5. בסרגל Filer, מזינים את השם של חשבון השירות שמוגדר כברירת מחדל ב-Compute Engine.

  6. בחשבון השירות של Compute Engine שמוגדר כברירת מחדל, לוחצים על עריכה.

  7. לוחצים על הוספת תפקיד נוסף.

  8. בשדה Select a role (בחירת תפקיד), בוחרים באפשרות Custom Role-Tutorial (תפקיד בהתאמה אישית – הדרכה).

  9. לוחצים על Save.

הגדרת הפלאגין של מקור הנתונים באצווה של Salesforce ב-Cloud Data Fusion

  1. עוברים לדף Instances ב-Cloud Data Fusion:

    כניסה לדף Instances

  2. לוחצים על View instance (הצגת המופע) ליד המופע הרצוי. ממשק האינטרנט של Cloud Data Fusion נפתח.

  3. עוברים לדף Studio.

  4. לוחצים על מרכז.

  5. בסרגל החיפוש, מזינים Salesforce.

  6. לוחצים על Salesforce plugins (תוספים של Salesforce) ואז על Deploy (פריסה).

  7. בחלון Salesforce plugins deploy (פריסת תוספים של Salesforce), לוחצים על Finish (סיום).

    בסיום הפריסה, תוצג תיבת דו-שיח עם הודעה על הצלחה.

  8. בתיבת הדו-שיח, לוחצים על יצירת צינור.

    מוצג הדף Cloud Data Fusion Studio.

  9. בוחרים באפשרות צינור עיבוד נתונים – אצווה כסוג צינור עיבוד הנתונים.

  10. בתפריט מקור, לוחצים על Salesforce.

  11. עוברים לצומת Salesforce ולוחצים על Properties. ייפתח הדף של מאפייני הפלאגין של Salesforce.

  12. בשדה שם הפניה, מזינים שם למקור. לדוגמה, Leads_generated.

  13. בקטע חיבור, לוחצים על המתג שימוש בחיבור.

  14. לוחצים על Browse connections (עיון בחיבורים). נפתח החלון Browse connections (עיון בחיבורים).

  15. לוחצים על הוספת חיבור ובוחרים באפשרות Salesforce.

  16. בחלון יצירת חיבור ל-Salesforce, לוחצים על הכרטיסייה הגדרה ומבצעים את הפעולות הבאות:

    1. בשדה שם, מזינים שם שיעזור לזהות את החיבור, לדוגמה, Salesforce_connection.

    2. בקטע Credentials (פרטי כניסה), מזינים את הפרטים הבאים של חשבון Salesforce:

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

    4. לוחצים על יצירה.

    5. בוחרים באפשרות Salesforce_connection וחוזרים לדף המאפיינים של התוסף Salesforce.

חילוץ נתונים מתוסף של מקור נתונים למעקב אחרי קבוצות ב-Salesforce

  1. בדף המאפיינים של הפלאגין Salesforce, בקטע SOQL query, מזינים את השאילתה הבאה:

    Select LastName,FirstName,Company,Email,Phone,LeadSource,Industry,OwnerId,CreatedDate,LastModifiedDate,LastActivityDate from Lead where Status like '%Open%'
    

    השאילתה הזו מאחזרת את הפרטים של ליד פוטנציאלי שנדרשים להפעלת קמפיין מ-sObject‏ Lead.

  2. כדי לקבוע את התוקף של סכימת האובייקט, לוחצים על קבל סכימה.

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

    • שינוי אחרון אחרי
    • השינוי האחרון בוצע לפני
    • משך הזמן
    • הזחה
שאילתת SOQL לחילוץ נתונים

טרנספורמציה של נתונים באמצעות הפלאגין Wrangler

משתמשים בתוסף Wrangler ב-Cloud Data Fusion כדי לנקות ולהעשיר את הנתונים:

  1. חוזרים לדף Studio.

  2. בתפריט Transform, לוחצים על Wrangler.

  3. מחברים את Wrangler לתוסף של מקור אצווה ב-Salesforce.

  4. עוברים לפלאגין Wrangler ולוחצים על Properties (מאפיינים). ייפתח דף המאפיינים של הפלאגין Wrangler.

  5. מוודאים שסכימת הקלט מאוכלסת.

  6. לוחצים על Wrangle.

  7. בחלונית חיבורים, בוחרים חיבור תקין.

  8. בוחרים את אובייקט ה-sObject שרוצים לשנות – לדוגמה, Lead.

  9. לבצע טרנספורמציה של הנתונים באמצעות ההוראות הנדרשות:

    keep :LastName,:FirstName,:Company,:Phone,:Email,:LeadSource,:OwnerId,
    :CreatedDate,:LastModifiedDate,:LastActivityDatemerge :FirstName :LastName :Name ' '
    fill-null-or-empty :Email 'no email found'
    mask-number :Phone ########xxxxxxxx
    format-date :LastActivityDate yyyy-MM-dd HH:mm:ss
    drop :LastName,:FirstName
    
    טרנספורמציה של נתונים

טעינת נתונים ל-BigQuery

  1. חוזרים לדף Studio.

  2. בתפריט Sink, לוחצים על BigQuery.

  3. עוברים לצומת BigQuery ולוחצים על Properties (מאפיינים). ייפתח דף המאפיינים של התוסף BigQuery.

  4. בקטע Basic, בשדה Reference name, מזינים שם שיעזור לזהות את יעד הנתונים. לדוגמה, Leads_generated.

  5. בשדה Dataset (מערך נתונים), מזינים את מערך הנתונים שאליו שייכת הטבלה. לדוגמה, Salesforce_Leads.

  6. בשדה Table, מזינים את הטבלה שבה רוצים לאחסן את הרשומות שחולצו. לדוגמה, Incoming_Open_Leads.

  7. כדי לאמת את הפלאגין, לוחצים על אימות.

טעינת נתונים

פריסה, תזמון והפעלה של צינור עיבוד הנתונים

  1. כדי לפרוס את צינור עיבוד הנתונים, לוחצים על פריסה.

  2. כדי להגדיר לוח זמנים מתאים לרענון באמצעות מתזמנים, פועלים לפי השלבים הבאים:

    1. לוחצים על תזמון.
    2. מזינים את הפרטים הבאים:

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

    פריסה והפעלה של צינור עיבוד הנתונים

  3. כדי להריץ את צינור הנתונים, לוחצים על הפעלה.

אימות חילוץ הנתונים והטמעתם

  1. במסוף Google Cloud , עוברים לדף BigQuery:

    כניסה לדף BigQuery

  2. מחפשים את מערך הנתונים Salesforce_Leads ואת שם הטבלה Incoming_Open_Leads כדי לראות את הרשומות שחולצו.

  3. כדי להריץ את השאילתה, לוחצים על Query.

ניתוח נתוני הלידים מאפשר להבין טוב יותר את הקהל ולספק קמפיינים מותאמים אישית בהיקף גדול.

הסרת המשאבים

כדי לא לצבור חיובים לחשבון Google Cloud על המשאבים שבהם השתמשתם בדף הזה, פועלים לפי השלבים הבאים:

מחיקת מופע Cloud Data Fusion

פועלים לפי ההוראות כדי למחוק את מכונת Cloud Data Fusion.

מחיקת הפרויקט

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

כדי למחוק את הפרויקט:

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

    כניסה לדף Manage resources

  2. ברשימת הפרויקטים, בוחרים את הפרויקט שרוצים למחוק ולוחצים על Delete.
  3. כדי למחוק את הפרויקט, כותבים את מזהה הפרויקט בתיבת הדו-שיח ולוחצים על Shut down.

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