שילוב עם LiveRamp
בדף הזה מתוארות ההגדרות הנדרשות כדי להעביר נתונים מ-LiveRamp כמקור נתונים של עומס העבודה השיווקי של Cortex Framework Data Foundation.
LiveRamp היא פלטפורמה לשיתוף נתונים שעוזרת לעסקים להתחבר לנתונים שלהם, לשלוט בהם ולהפעיל אותם כדי לשפר את חוויית הלקוח ולהשיג תוצאות עסקיות טובות יותר. Cortex Framework מציע את הכלים והפלטפורמה לניתוח הנתונים, לשילוב שלהם עם מקורות נתונים אחרים ולשימוש ב-AI כדי לקבל תובנות מעמיקות ולבצע אופטימיזציה של אסטרטגיית השיווק.
בתרשים הבא מתואר איך מקור הנתונים של LiveRamp זמין דרך עומס העבודה השיווקי של Cortex Framework Data Foundation:

קובץ תצורה
קובץ config.json מגדיר את ההגדרות שנדרשות כדי להתחבר למקורות נתונים להעברת נתונים מעומסי עבודה שונים. הקובץ הזה מכיל את הפרמטרים הבאים של LiveRamp:
"marketing": {
"deployLiveRamp": true,
"LiveRamp": {
"datasets": {
"cdc": ""
}
}
}
בטבלה הבאה מתואר הערך של כל פרמטר של LiveRamp:
| פרמטר | משמעות | ערך ברירת המחדל | תיאור |
marketing.LiveRamp
|
פריסת LiveRamp | true
|
מריצים את הפריסה של מקור הנתונים LiveRamp. |
marketing.LiveRamp.datasets.cdc
|
מערך נתונים של CDC ל-LiveRamp | מערך נתוני CDC ל-LiveRamp. |
חיבור API
השכבה Data Foundation של Cortex Framework מאפשרת זיהוי זהויות על ידי שילוב עם LiveRamp.מערכות Cortex Framework יכולות לבצע חיפוש של RampID, שמאפשר לעסקים לזהות קהלים מוכרים או פלחי לקוחות מתוך מערכות ה-CRM שלהם.
מזהה RampID הוא מזהה שנוצר על ידי ה-API של LiveRamp באמצעות פרטים אישיים מזהים (PII) כמו כתובת אימייל, מספר טלפון ושם. ה-RampID מאפשר לעסקים לזהות ולאחד רשומות בכמה מערכות, כמו קהלים של קמפיינים שונים. השילוב עם LiveRamp מאפשר לעסקים לשפר את היכולת שלהם לזהות ולטרגט את הקהלים שלהם, וכך ליצור קמפיינים שיווקיים יעילים ומותאמים אישית יותר.
LiveRamp Identity Resolution Retrieval API מאפשר לעסקים לזהות באופן פרוגרמטי נתונים אישיים של אנשים פרטיים. ב-Cortex Framework נעשה שימוש בנקודת הקצה של Lookup של LiveRamp על ידי שליחת נתוני PII מגובבים באמצעות קריאה ל-API.
טבלאות קלט ופלט
אחרי פריסת Cortex Framework, המערכת יוצרת את שתי הטבלאות הבאות ב-BigQuery במערך הנתונים הרלוונטי שמופיע ב-config.json.
טבלה של rampid_lookup_input
הטבלה rampid_lookup_input היא הקלט לתהליך RampID Lookup.
| עמודה | סוג הנתונים | תיאור | דוגמה | מפתח ראשי |
| id | מחרוזת | מזהה ייחודי של הרשומה הזו. | "123" | כן |
| segment_name | מחרוזת | השם של הקהל, פלח ה-CRM או פלח הלקוחות. | 'ערך גבוה' | לא |
| source_system_name | מחרוזת | מערכת המקור שממנה הגיע הרשומה. | "Salesforce" | לא |
| name | מחרוזת | שם הלקוח | "John Doe" | לא |
| אימייל | מחרוזת | כתובת האימייל של הלקוח | "example@example.com" | לא |
| phone_number | מחרוזת | מספר הטלפון של הלקוח | "1234567890" | לא |
| postal_code | מחרוזת | המיקוד של הלקוח | "12345" | לא |
| is_processed | BOOL |
מציין אם הרשומה כבר עברה עיבוד.
לרשומות חדשות, מאכלסים את השדה הזה בערך FALSE. עדכוני המערכת משנים את הערך ל-TRUE אחרי העיבוד. |
לא נכון | לא |
| load_timestamp | TIMESTAMP | חותמת זמן של מועד הוספת הרשומה למערכת. הפעולה הזו מיועדת למטרות ביקורת בלבד. | "2020-01-01 00:00:00 UTC" | לא |
| processed_timestamp | TIMESTAMP | חותמת הזמן שבה המערכת ביצעה חיפוש API עבור הרשומה הזו. המאפיין הזה תמיד מאוכלס על ידי המערכת. | "2020-01-01 00:00:00 UTC" | לא |
צריך למלא את הטבלה rampid_lookup_input באופן תקופתי (בהתאם לצורכי העסק) בפרטים אישיים מזהים של הלקוחות, כמו:
Cortex Framework לא מספק דרך אוטומטית לעשות זאת, אבל הוא מספק סקריפט לדוגמה ddls/samples/populate_rampid_lookup_input.sql שמראה איך אפשר לאכלס את הטבלה הזו באמצעות נתונים במערכת Salesforce שכבר נפרסה עם Cortex Framework. אתם יכולים להשתמש בקובץ הזה כהנחיה אם הנתונים שלכם מגיעים ממערכת אחרת.
חשוב לוודא שאין רשומות כפולות בטבלה rampid_lookup_input (לדוגמה, אותו אדם מופיע כמה פעמים עם אותם פרטים אישיים מזהים, גם אם ID שלו שונה). חיפוש ב-DAG של Cortex Framework ייכשל אם פלח מכיל הרבה רשומות כפולות. האכיפה מתבצעת באמצעות ממשקי LiveRamp API.
הטבלה rampid_lookup
הטבלה rampid_lookup היא טבלת פלט שמכילה RampID לכל פלח ברשומת הקלט. העיצוב של LiveRamp לא מאפשר מיפוי של RampID לרשומה ספציפית.
| עמודה | סוג הנתונים | תיאור |
| segment_name | מחרוזת | שם הפלח מטבלת הקלט. |
| ramp_id | מחרוזת | LiveRamp RampID |
| חותמת רשומה | TIMESTAMP | חותמת הזמן שבה בוצעה בדיקת המידע של RampID. |
מזהי LiveRamp RampID יכולים להשתנות לאורך זמן,
אפילו עבור אותו אדם. כלומר, מעת לעת צריך לבצע חיפוש חדש של נתונים שכבר עברו עיבוד. ב-Cortex Framework יש סקריפט לדוגמה ddls/samples/clean_up_segment_matching.sql שמראה איך אפשר לעשות את זה ברמת הפלח. כך תוכלו לאפס פלח שלם, והמערכת תבצע חיפוש של הפלח הזה ותספק לכם את מזהי RampID העדכניים.
יכול להיות שבטבלת הפלט rampid_lookup יהיו קצת פחות רשומות מאשר בטבלת הקלט. זהו התנהגות צפויה, כי Cortex Framework מנסה לנפות באגים ברשומות הקלט באמצעות פרטים מזהים אישיים (PII) כדי לוודא שהחיפוש ב-LiveRamp API לא ייכשל.
אימות חשבון
- פונים אל LiveRamp כדי לקבל פרטי כניסה לאימות. הפרטים האלה צריכים לכלול את מזהה הלקוח ואת סוד הלקוח.
יוצרים סוד באמצעות Secret Manager עם השם
cortex-framework-liveramp, ומשתמשים בערך הבא. הוראות מפורטות מופיעות במאמרי העזרה של Secret Manager.{ 'client_id':'CLIENT_ID', 'client_secret':'CLIENT_SECRET', 'grant_type':'client_credentials' }מחליפים את מה שכתוב בשדות הבאים:
- 'CLIENT_ID' עם מזהה הלקוח שהתקבל בשלב 1.
- 'CLIENT_SECRET' בסוד הלקוח שהתקבל בשלב 1.
חיבורים ל-Managed Airflow
יוצרים את החיבורים הבאים ב-Managed Airflow. פרטים נוספים זמינים במאמר בנושא ניהול חיבורים ב-Airflow.
| שם החיבור | מטרה |
liveramp_cdc_bq
|
LiveRamp API > העברת מערך נתונים של CDC |
הגדרות אישיות
קובץ ה-config.ini שולט בחלק מההתנהגויות של Managed Airflow DAG, וגם באופן השימוש ב-APIs של LiveRamp. מגדירים את הקובץ LiveRamp/src/pipelines/config.ini לפי הצרכים שלכם. הפרמטרים האלה כבר מתוארים בקובץ, אבל חשוב לשים לב לפרמטר liveramp_api_base_url. כברירת מחדל, הפרמטר הזה מצביע על כתובת ה-URL של API בסביבת הייצור של LiveRamp. למטרות בדיקה, יכול להיות שתצטרכו להפנות אותו לגרסת הביניים, בהתאם להגדרה שלכם.
מה השלב הבא?
- מידע נוסף על מקורות נתונים ועומסי עבודה אחרים זמין במאמר מקורות נתונים ועומסי עבודה.
- מידע נוסף על השלבים לפריסה בסביבות ייצור זמין במאמר דרישות מוקדמות לפריסת Cortex Framework Data Foundation.