Skip to content

Commit ad6ebb3

Browse files
committed
BQ: JSON on query output, even when paging
For composability with JSON capable tools in a unix pipeline. See GoogleCloudPlatform#184
1 parent 80b5a2b commit ad6ebb3

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

bigquery/api/sync_query.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,17 +60,21 @@ def main(project_id, query, timeout, num_retries):
6060

6161
# [START paging]
6262
# Page through the result set and print all results.
63+
results = []
6364
page_token = None
65+
6466
while True:
6567
page = bigquery.jobs().getQueryResults(
6668
pageToken=page_token,
6769
**query_job['jobReference']).execute(num_retries=2)
6870

69-
print(json.dumps(page.get('rows', [])))
71+
results.extend(page.get('rows', []))
7072

7173
page_token = page.get('pageToken')
7274
if not page_token:
7375
break
76+
77+
print(json.dumps(results))
7478
# [END paging]
7579
# [END run]
7680

0 commit comments

Comments
 (0)