Database Reference
In-Depth Information
query = 'select count(*) from [%s]' % (table['id'])
query_request = {'query': query, 'timeoutMs': 0,
'maxResults': 1}
results = jobs.query(body=query_request,
**project_ref).execute()
while not results['jobComplete']:
get_results_request =
results['jobReference'].copy()
get_results_request['timeoutMs'] = 10000
get_results_request['maxResults'] = 10
results = jobs.getQueryResults(
**get_results_request).execute()
print results
# Now let's read the data from our table.
data = tabledata.list(**table_ref).execute()
table = tables.get(**table_ref).execute()
print 'Table %s\nData:%s' % (data, table)
# Now we should clean up our toys.
tables.delete(**table_ref).execute()
datasets.delete(**dataset_ref).execute()
# Now try reading the dataset after deleting it:
try:
datasets.get(**dataset_ref).execute()
print "That's funny, we should never get here!"
except HttpError as err:
print 'Expected error:\n%s' % (err,)
# Done!
def main(argv):
service = auth.build_bq_client()
project_id = 'bigquery-e2e' if len(argv) == 0 else
argv[0]
run_tour(service, project_id)
if __name__ == '__main__':
main(sys.argv[1:])
Error Handling in BigQuery
In a perfect world, every BigQuery operation would succeed and there would
be no need to debug or worry about errors. In practice, however, there are a
