מעקב אחרי שושלת נתונים של טבלה ב-BigQuery
בעזרת שושלת נתונים אתם יכולים לעקוב אחרי המקור של הנתונים, השינויים שבוצעו בהם והתנועה שלהם בטבלאות ב-BigQuery לאורך זמן. מעקב אחרי התנועות האלה עוזר לכם לשמור על תאימות, לפתור בעיות בנתונים ולבצע ניתוח של שורש הבעיה. במדריך למתחילים הזה תשתמשו במסוףGoogle Cloud כדי להעתיק שתי טבלאות ציבוריות של new_york_taxi_trips, לשלב את מספר הנסיעות שלהן בטבלה חדשה ב-BigQuery ולצפות בתרשים החזותי של שושלת היוחסין. כדי לבצע פעולות ב-data lineage באופן פרוגרמטי, אפשר להשתמש בספריות הלקוח של Knowledge Catalog ו-data lineage.
לפני שמתחילים
מגדירים את הפרויקט:
- נכנסים לחשבון Google Cloud . אנחנו ממליצים למשתמשים חדשים ב- Google Cloud ליצור חשבון כדי שיוכלו להעריך את הביצועים של המוצרים שלנו בתרחישים מהעולם האמיתי. לקוחות חדשים מקבלים בחינם גם קרדיט בשווי 300$ להרצה, לבדיקה ולפריסה של עומסי העבודה.
-
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 theresourcemanager.projects.createpermission. Learn how to grant roles.
-
If you're using an existing project for this guide, verify that you have the permissions required to complete this guide. If you created a new project, then you already have the required permissions.
-
Verify that billing is enabled for your Google Cloud project.
Enable the Dataplex, BigQuery, and Data Lineage APIs, if any are not already enabled.
Roles required to enable APIs
To enable APIs, you need the
serviceusage.services.enablepermission. If you created the project, then you likely already have this permission through the Owner role (roles/owner). Otherwise, you can get this permission through the Service Usage Admin role (roles/serviceusage.serviceUsageAdmin). Learn how to grant roles.-
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 theresourcemanager.projects.createpermission. Learn how to grant roles.
-
If you're using an existing project for this guide, verify that you have the permissions required to complete this guide. If you created a new project, then you already have the required permissions.
-
Verify that billing is enabled for your Google Cloud project.
Enable the Dataplex, BigQuery, and Data Lineage APIs, if any are not already enabled.
Roles required to enable APIs
To enable APIs, you need the
serviceusage.services.enablepermission. If you created the project, then you likely already have this permission through the Owner role (roles/owner). Otherwise, you can get this permission through the Service Usage Admin role (roles/serviceusage.serviceUsageAdmin). Learn how to grant roles.
התפקידים הנדרשים
כדי לקבל את ההרשאות שדרושות לצפייה בתרשימים של שושלת היוחסין, בקשו מהאדמין לתת לכם את התפקידים הבאים ב-IAM:
- Dataplex Catalog Viewer (
roles/dataplex.catalogViewer) בפרויקט המשאבים של Knowledge Catalog (לשעבר Dataplex Universal Catalog) - צפייה בשושלת נתונים (
roles/datalineage.viewer) בפרויקט שבו משתמשים ב-BigQuery - BigQuery Data Viewer (
roles/bigquery.dataViewer) בפרויקט שבו משתמשים ב-BigQuery
להסבר על מתן תפקידים, ראו איך מנהלים את הגישה ברמת הפרויקט, התיקייה והארגון.
יכול להיות שאפשר לקבל את ההרשאות הנדרשות גם באמצעות תפקידים בהתאמה אישית או תפקידים מוגדרים מראש.
הוספת מערך נתונים ציבורי לפרויקט
נכנסים לדף BigQuery במסוף Google Cloud .
בחלונית הימנית, לוחצים על database Data Explorer.
אם החלונית הימנית לא מוצגת, לוחצים על הרחבת החלונית הימנית כדי לפתוח אותה.
בחלונית נתונים, לוחצים על הוספת נתונים.
בחלונית Add data, בוחרים באפשרות Public datasets.
בחלונית Marketplace, מחפשים את
NYC TLC Tripsולוחצים על התוצאה NYC TLC Trips.לוחצים על View dataset.
הפעולה הזו מוסיפה את הפרויקט של מערך הנתונים הציבורי כקובץ עזר שאפשר לראות בחלונית Explorer. בחלונית הפרטים מוצג Dataset info, כולל מידע כמו Dataset ID, Data location ותאריך Last modified.
יצירת מערך נתונים בפרויקט
בחלונית הימנית, לוחצים על Explorer.
בחלונית Explorer, בוחרים את הפרויקט שבו רוצים ליצור את מערך הנתונים.
לוחצים על Actions ואז על Create dataset.
בדף Create dataset, בשדה Dataset ID מזינים את הערך
data_lineage_demo. משאירים את ערכי ברירת המחדל בשאר השדות.לוחצים על Create dataset.
בחלונית Explorer, לוחצים על Datasets ואז על מערך הנתונים
data_lineage_demoשנוסף.
בחלונית הפרטים מוצג מידע על קבוצת הנתונים.
העתקת שתי טבלאות שנגישות באופן ציבורי למערך הנתונים שלכם
פותחים את עורך השאילתות: בחלונית הפרטים, לצד הכרטיסייה
data_lineage_demo, לוחצים על שאילתת SQL. בשלב הזה נוצרת כרטיסייה בשםUntitled.בעורך השאילתות, מעתיקים את הטבלה הראשונה באמצעות הזנת השאילתה הבאה. מחליפים את
PROJECT_IDבמזהה הפרויקט.CREATE TABLE `PROJECT_ID.data_lineage_demo.nyc_green_trips_2021` COPY `bigquery-public-data.new_york_taxi_trips.tlc_green_trips_2021`לוחצים על Run. בשלב הזה נוצרת הטבלה הראשונה, שנקראת
nyc_green_trips_2021.בחלונית Query results, לוחצים על Go to table. בשלב הזה מוצג התוכן של הטבלה הראשונה.
בעורך השאילתות, מחליפים את השאילתה הקודמת בשאילתה הבאה כדי להעתיק את הטבלה השנייה. מחליפים את
PROJECT_IDבמזהה הפרויקט.CREATE TABLE `PROJECT_ID.data_lineage_demo.nyc_green_trips_2022` COPY `bigquery-public-data.new_york_taxi_trips.tlc_green_trips_2022`לוחצים על Run. בשלב הזה נוצרת הטבלה השנייה, שנקראת
nyc_green_trips_2022.בחלונית Query results, לוחצים על Go to table. בשלב הזה מוצג התוכן של הטבלה השנייה.
צבירת נתונים בטבלה חדשה
בעורך השאילתות, מזינים את השאילתה הבאה. מחליפים את
PROJECT_IDבמזהה הפרויקט.CREATE TABLE `PROJECT_ID.data_lineage_demo.total_green_trips_22_21` AS SELECT vendor_id, COUNT(*) AS number_of_trips FROM ( SELECT vendor_id FROM `PROJECT_ID.data_lineage_demo.nyc_green_trips_2022` UNION ALL SELECT vendor_id FROM `PROJECT_ID.data_lineage_demo.nyc_green_trips_2021` ) GROUP BY vendor_idלוחצים על Run. בשלב הזה נוצרת טבלה משולבת בשם
total_green_trips_22_21.בחלונית Query results, לוחצים על Go to table. בשלב הזה מוצגת הטבלה המשולבת.
צפייה בתרשים השושלת ב-Knowledge Catalog
נכנסים לדף Search של Knowledge Catalog במסוף Google Cloud .
בתיבת החיפוש, מזינים את הערך
total_green_trips_22_21ולוחצים על חיפוש.ברשימת התוצאות, לוחצים על
total_green_trips_22_21. בשלב הזה מוצגת הכרטיסייה Details של הטבלה ב-BigQuery.לוחצים על הכרטיסייה Lineage.
בתרשים השושלת, כל צומת מלבני מייצג טבלה – מקורית, מועתקת או משולבת. אתם יכולים לבצע את הפעולות הבאות:
כדי להציג או להסתיר את המקור של טבלה, לוחצים על + (הרחבה) או על - (כיווץ).
כדי להציג מידע על הטבלה, לוחצים על צומת. בשלב הזה מוצגת חלונית Details של הצומת.
כדי להציג מידע על התהליך, לוחצים על
.
בשלב הזה מוצגת חלונית Details של התהליך, שבה מופיעה המשימה שהמירה טבלת מקור לטבלת יעד.
הסרת המשאבים
כדי לא לצבור חיובים בחשבון Google Cloud על המשאבים שבהם השתמשתם בדף הזה, מבצעים את הפעולות הבאות.
מחיקת הפרויקט
- במסוף Google Cloud , נכנסים לדף Manage resources.
- ברשימת הפרויקטים, בוחרים את הפרויקט שרוצים למחוק ולוחצים על Delete.
- כדי למחוק את הפרויקט, כותבים את מזהה הפרויקט בתיבת הדו-שיח ולוחצים על Shut down.
מחיקת מערך הנתונים
נכנסים לדף BigQuery במסוף Google Cloud .
בחלונית הימנית, לוחצים על Explorer.
בחלונית Explorer, מחפשים את מערך הנתונים
data_lineage_demoשיצרתם.לוחצים על מערך הנתונים ואז על מחיקה.
מאשרים את פעולת המחיקה.