Skip to content

Commit

Permalink
Update samples to support latest Google Cloud Python [(#656)](GoogleC…
Browse files Browse the repository at this point in the history
  • Loading branch information
Jon Wayne Parrott authored and shollyman committed Jul 22, 2020
1 parent 1e1afe1 commit 91ddb03
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 49 deletions.
2 changes: 1 addition & 1 deletion samples/snippets/requirements.txt
Original file line number Diff line number Diff line change
@@ -1 +1 @@
google-cloud-bigquery==0.20.0
google-cloud-bigquery==0.21.0
55 changes: 7 additions & 48 deletions samples/snippets/snippets.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,18 +35,7 @@
def list_projects():
bigquery_client = bigquery.Client()

projects = []
page_token = None

while True:
results, page_token = bigquery_client.list_projects(
page_token=page_token)
projects.extend(results)

if not page_token:
break

for project in projects:
for project in bigquery_client.list_projects():
print(project.project_id)


Expand All @@ -57,18 +46,7 @@ def list_datasets(project=None):
"""
bigquery_client = bigquery.Client(project=project)

datasets = []
page_token = None

while True:
results, page_token = bigquery_client.list_datasets(
page_token=page_token)
datasets.extend(results)

if not page_token:
break

for dataset in datasets:
for dataset in bigquery_client.list_datasets():
print(dataset.name)


Expand Down Expand Up @@ -98,17 +76,7 @@ def list_tables(dataset_name, project=None):
print('Dataset {} does not exist.'.format(dataset_name))
return

tables = []
page_token = None

while True:
results, page_token = dataset.list_tables(page_token=page_token)
tables.extend(results)

if not page_token:
break

for table in tables:
for table in dataset.list_tables():
print(table.name)


Expand Down Expand Up @@ -157,19 +125,10 @@ def list_rows(dataset_name, table_name, project=None):
# Reload the table so that the schema is available.
table.reload()

rows = []
page_token = None

# Load at most 25 results. You can change this to `while True` and change
# the max_results argument to load more rows from BigQuery, but note
# that this can take some time. It's preferred to use a query.
while len(rows) < 25:
results, total_rows, page_token = table.fetch_data(
max_results=25, page_token=page_token)
rows.extend(results)

if not page_token:
break
# Load at most 25 results. You can change the max_results argument to load
# more rows from BigQuery, but note that this can take some time. It's
# preferred to use a query.
rows = list(table.fetch_data(max_results=25))

# Use format to create a simple table.
format_string = '{!s:<16} ' * len(table.schema)
Expand Down

0 comments on commit 91ddb03

Please sign in to comment.