שליחת שאילתות לנתוני Apache Iceberg
במאמר הזה מוסבר איך להריץ שאילתות על נתונים שמאוחסנים בטבלת BigLake בפורמט Apache Iceberg ב-BigQuery.
התפקידים הנדרשים
כדי לשלוח שאילתות לטבלאות BigLake בפורמט Apache Iceberg ב-BigQuery, צריך לוודא שלמשתמש שקורא ל-BigQuery API יש את התפקידים הבאים:
- משתמש עם הרשאת גישה ל-BigQuery Connection (
roles/bigquery.connectionUser) - צפייה בנתוני BigQuery (
roles/bigquery.dataViewer) - משתמש BigQuery (
roles/bigquery.user)
מבצע הקריאה החוזרת יכול להיות החשבון שלכם, חשבון שירות של Spark Connection או חשבון שירות של Cloud Resource Connection. בהתאם להרשאות שלכם, אתם יכולים להקצות לעצמכם את התפקידים האלה או לבקש מהאדמין להקצות אותם לכם. מידע נוסף על מתן תפקידים זמין במאמר איך בודקים אילו תפקידים אפשר לתת במשאבים.
כדי לראות בדיוק אילו הרשאות נדרשות לשאילתות בטבלאות Spark BigLake, מרחיבים את הקטע Required permissions:
ההרשאות הנדרשות
bigquery.connections.usebigquery.jobs.createbigquery.readsessions.create(נדרש רק אם קוראים נתונים באמצעות BigQuery Storage Read API)bigquery.tables.getbigquery.tables.getData
יכול להיות שתוכלו לקבל את ההרשאות האלה גם באמצעות תפקידים בהתאמה אישית או תפקידים מוגדרים מראש אחרים.
שליחת שאילתות לטבלאות BigLake Iceberg ב-BigQuery
אחרי שיוצרים טבלת BigLake Iceberg ב-BigQuery, אפשר להריץ עליה שאילתות באמצעות תחביר GoogleSQL, בדיוק כמו בטבלת BigQuery רגילה. לדוגמה, SELECT field1, field2
FROM mydataset.my_iceberg_table;.