1818def run_authorized_view_tutorial (override_values = {}):
1919 # Note to user: This is a group email for testing purposes. Replace with
2020 # your own group email address when running this code.
21- analyst_group_email = ' example-analyst-group@google.com'
21+ analyst_group_email = " example-analyst-group@google.com"
2222
2323 # [START bigquery_authorized_view_tutorial]
2424 # Create a source dataset
2525 # [START bigquery_avt_create_source_dataset]
2626 from google .cloud import bigquery
2727
2828 client = bigquery .Client ()
29- source_dataset_id = ' github_source_data'
29+ source_dataset_id = " github_source_data"
3030
3131 # [END bigquery_authorized_view_tutorial]
3232 # [END bigquery_avt_create_source_dataset]
@@ -38,13 +38,13 @@ def run_authorized_view_tutorial(override_values={}):
3838
3939 source_dataset = bigquery .Dataset (client .dataset (source_dataset_id ))
4040 # Specify the geographic location where the dataset should reside.
41- source_dataset .location = 'US'
41+ source_dataset .location = "US"
4242 source_dataset = client .create_dataset (source_dataset ) # API request
4343 # [END bigquery_avt_create_source_dataset]
4444
4545 # Populate a source table
4646 # [START bigquery_avt_create_source_table]
47- source_table_id = ' github_contributors'
47+ source_table_id = " github_contributors"
4848 job_config = bigquery .QueryJobConfig ()
4949 job_config .destination = source_dataset .table (source_table_id )
5050 sql = """
@@ -56,15 +56,16 @@ def run_authorized_view_tutorial(override_values={}):
5656 sql ,
5757 # Location must match that of the dataset(s) referenced in the query
5858 # and of the destination table.
59- location = 'US' ,
60- job_config = job_config ) # API request - starts the query
59+ location = "US" ,
60+ job_config = job_config ,
61+ ) # API request - starts the query
6162
6263 query_job .result () # Waits for the query to finish
6364 # [END bigquery_avt_create_source_table]
6465
6566 # Create a separate dataset to store your view
6667 # [START bigquery_avt_create_shared_dataset]
67- shared_dataset_id = ' shared_views'
68+ shared_dataset_id = " shared_views"
6869
6970 # [END bigquery_authorized_view_tutorial]
7071 # [END bigquery_avt_create_shared_dataset]
@@ -75,13 +76,13 @@ def run_authorized_view_tutorial(override_values={}):
7576 # [START bigquery_avt_create_shared_dataset]
7677
7778 shared_dataset = bigquery .Dataset (client .dataset (shared_dataset_id ))
78- shared_dataset .location = 'US'
79+ shared_dataset .location = "US"
7980 shared_dataset = client .create_dataset (shared_dataset ) # API request
8081 # [END bigquery_avt_create_shared_dataset]
8182
8283 # Create the view in the new dataset
8384 # [START bigquery_avt_create_view]
84- shared_view_id = ' github_analyst_view'
85+ shared_view_id = " github_analyst_view"
8586 view = bigquery .Table (shared_dataset .table (shared_view_id ))
8687 sql_template = """
8788 SELECT
@@ -91,7 +92,8 @@ def run_authorized_view_tutorial(override_values={}):
9192 `{}.{}.{}`
9293 """
9394 view .view_query = sql_template .format (
94- client .project , source_dataset_id , source_table_id )
95+ client .project , source_dataset_id , source_table_id
96+ )
9597 view = client .create_table (view ) # API request
9698 # [END bigquery_avt_create_view]
9799
@@ -100,25 +102,27 @@ def run_authorized_view_tutorial(override_values={}):
100102 # analyst_group_email = 'data_analysts@example.com'
101103 access_entries = shared_dataset .access_entries
102104 access_entries .append (
103- bigquery .AccessEntry (' READER' , ' groupByEmail' , analyst_group_email )
105+ bigquery .AccessEntry (" READER" , " groupByEmail" , analyst_group_email )
104106 )
105107 shared_dataset .access_entries = access_entries
106108 shared_dataset = client .update_dataset (
107- shared_dataset , ['access_entries' ]) # API request
109+ shared_dataset , ["access_entries" ]
110+ ) # API request
108111 # [END bigquery_avt_shared_dataset_access]
109112
110113 # Authorize the view to access the source dataset
111114 # [START bigquery_avt_source_dataset_access]
112115 access_entries = source_dataset .access_entries
113116 access_entries .append (
114- bigquery .AccessEntry (None , ' view' , view .reference .to_api_repr ())
117+ bigquery .AccessEntry (None , " view" , view .reference .to_api_repr ())
115118 )
116119 source_dataset .access_entries = access_entries
117120 source_dataset = client .update_dataset (
118- source_dataset , ['access_entries' ]) # API request
121+ source_dataset , ["access_entries" ]
122+ ) # API request
119123 # [END bigquery_avt_source_dataset_access]
120124 # [END bigquery_authorized_view_tutorial]
121125
122126
123- if __name__ == ' __main__' :
127+ if __name__ == " __main__" :
124128 run_authorized_view_tutorial ()
0 commit comments