הרצת שאילתות במערך נתונים ציבורי באמצעות ספריית הלקוח BigQuery Go

פתיחה של Cloud Shell Editor

1. ב-Cloud Shell, יוצרים פרויקט וקובץ חדשים של Go:

   mkdir bigquery-go-quickstart \
       && touch \
       bigquery-go-quickstart/app.go
   

   הפקודה הזו יוצרת פרויקט Go בשם bigquery-go-quickstart וקובץ בשם app.go.

2. פותחים את Cloud Shell Editor:

   cloudshell workspace bigquery-go-quickstart
   

כדי ללמוד איך להכין קבצים לשאילתות, לוחצים על הבא.

הכנת קבצים לשאילתות

1. כדי לפתוח טרמינל ב-Cloud Shell Editor, לוחצים על Open Terminal.

2. פותחים את ספריית הפרויקט:

   cd bigquery-go-quickstart
   

3. יוצרים קובץ go.mod:

   go mod init quickstart
   

   הפלט אמור להיראות כך:

   go: creating new go.mod: module quickstart
   go: to add module requirements and sums:
           go mod tidy
   

4. מתקינים את ספריית הלקוח של BigQuery ל-Go:

   go get cloud.google.com/go/bigquery
   

   הפלט אמור להיראות כך: כדי לפשט את הפלט, השמטנו כמה שורות.

   go: downloading cloud.google.com/go/bigquery v1.49.0
   go: downloading cloud.google.com/go v0.110.0
   ...
   go: added cloud.google.com/go/bigquery v1.49.0
   go: added cloud.google.com/go v0.110.0
   

כדי ללמוד איך להריץ שאילתות במערך נתונים ציבורי ב-BigQuery, לוחצים על הבא.

הרצת שאילתות במערך נתונים ציבורי ב-BigQuery

1. לוחצים על פתיחת כלי העריכה.

2. בחלונית Explorer, מאתרים את הפרויקט BIGQUERY-GO-QUICKSTART.

3. לוחצים על הקובץ app.go כדי לפתוח אותו.

4. כדי ליצור שאילתה על מערך הנתונים bigquery-public-data.stackoverflow שמחזירה את 10 הדפים הכי נצפים ב-Stack Overflow ואת מספר הצפיות שלהם, מעתיקים את הקוד הבא לקובץ app.go:

   
   // Command simpleapp queries the Stack Overflow public dataset in Google BigQuery.
   package main
   
   import (
   	"context"
   	"fmt"
   	"io"
   	"log"
   	"os"
   
   	"cloud.google.com/go/bigquery"
   	"google.golang.org/api/iterator"
   )
   
   
   func main() {
   	projectID := os.Getenv("GOOGLE_CLOUD_PROJECT")
   	if projectID == "" {
   		fmt.Println("GOOGLE_CLOUD_PROJECT environment variable must be set.")
   		os.Exit(1)
   	}
   
   	ctx := context.Background()
   
   	client, err := bigquery.NewClient(ctx, projectID)
   	if err != nil {
   		log.Fatalf("bigquery.NewClient: %v", err)
   	}
   	defer client.Close()
   
   	rows, err := query(ctx, client)
   	if err != nil {
   		log.Fatal(err)
   	}
   	if err := printResults(os.Stdout, rows); err != nil {
   		log.Fatal(err)
   	}
   }
   
   // query returns a row iterator suitable for reading query results.
   func query(ctx context.Context, client *bigquery.Client) (*bigquery.RowIterator, error) {
   
   	query := client.Query(
   		`SELECT
   			CONCAT(
   				'https://stackoverflow.com/questions/',
   				CAST(id as STRING)) as url,
   			view_count
   		FROM ` + "`bigquery-public-data.stackoverflow.posts_questions`" + `
   		WHERE tags like '%google-bigquery%'
   		ORDER BY view_count DESC
   		LIMIT 10;`)
   	return query.Read(ctx)
   }
   
   type StackOverflowRow struct {
   	URL       string `bigquery:"url"`
   	ViewCount int64  `bigquery:"view_count"`
   }
   
   // printResults prints results from a query to the Stack Overflow public dataset.
   func printResults(w io.Writer, iter *bigquery.RowIterator) error {
   	for {
   		var row StackOverflowRow
   		err := iter.Next(&row)
   		if err == iterator.Done {
   			return nil
   		}
   		if err != nil {
   			return fmt.Errorf("error iterating through results: %w", err)
   		}
   
   		fmt.Fprintf(w, "url: %s views: %d\n", row.URL, row.ViewCount)
   	}
   }
   

5. לוחצים על Open Terminal (פתיחת טרמינל).

6. במסוף, מריצים את הסקריפט app.go. אם מתבקשים לאשר את Cloud Shell ומסכימים לתנאים, לוחצים על Authorize.

   go run app.go
   

   התוצאה אמורה להיראות כך:

   https://stackoverflow.com/questions/35159967 : 170023 views
   https://stackoverflow.com/questions/22879669 : 142581 views
   https://stackoverflow.com/questions/10604135 : 132406 views
   https://stackoverflow.com/questions/44564887 : 128781 views
   https://stackoverflow.com/questions/27060396 : 127008 views
   https://stackoverflow.com/questions/12482637 : 120766 views
   https://stackoverflow.com/questions/20673986 : 115720 views
   https://stackoverflow.com/questions/39109817 : 108368 views
   https://stackoverflow.com/questions/11057219 : 105175 views
   https://stackoverflow.com/questions/43195143 : 101878 views
   

הצלחתם להריץ שאילתות במערך נתונים ציבורי באמצעות ספריית הלקוח BigQuery Go.

כדי לא לצבור חיובים בחשבון ולקבל מידע על השלבים הבאים, לוחצים על הבא.