BQ: Use futures API for quickstart.

tswast · tswast · commit 473fd9df981c · 2017-08-08T12:11:16.000-07:00
diff --git a/bigquery/cloud-client/simple_app.py b/bigquery/cloud-client/simple_app.py
@@ -17,29 +17,31 @@
 """Simple application that performs a query with BigQuery."""
 # [START all]
 # [START create_client]
+import uuid
+
 from google.cloud import bigquery
 
 
 def query_shakespeare():
     client = bigquery.Client()
     # [END create_client]
     # [START run_query]
-    # See: https://cloud.google.com/bigquery/sql-reference/
-    query_results = client.run_sync_query("""
+    query_job = client.run_async_query(str(uuid.uuid4()), """
         #standardSQL
         SELECT corpus AS title, COUNT(*) AS unique_words
         FROM `publicdata.samples.shakespeare`
         GROUP BY title
         ORDER BY unique_words DESC
         LIMIT 10""")
 
-    query_results.run()
+    query_job.begin()
+    query_job.result()  # Wait for job to complete.
     # [END run_query]
 
     # [START print_results]
-    rows = query_results.fetch_data()
-
-    for row in rows:
+    destination_table = query_job.destination
+    destination_table.reload()
+    for row in destination_table.fetch_data():
         print(row)
     # [END print_results]
 
