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