Database Reference
In-Depth Information
if console.table:
dataset, table = console.table
next_page = _TableData(PROJECT_ID, dataset,
table)
result = next_page.fetch()
else:
result = bigquery.jobs().query(
projectId=PROJECT_ID,
body={'query': console.query, 'maxResults':
10000}).execute()
if 'jobReference' in result:
job_id = result['jobReference']['jobId']
next_page = _QueryResults(PROJECT_ID, job_id)
while 'jobComplete' in result and not
result['jobComplete']:
result = next_page.fetch()
formatter.start(self.response)
while result.get('rows'):
formatter.format(result['rows'], self.response)
result = (next_page.fetch(result['pageToken'])
if 'pageToken' in result else {})
if result.get('code', 200) != 200:
self.response.set_status(
500, message=('Could not fetch data for
%s\n%s' %
(str(console.table or console.query),
json.dumps(result))))
return
formatter.finish(self.response)
CONSOLES = [
ConsoleData(
[
{'label': 'Minute', 'type': 'number'},
{'label': 'Records', 'type': 'number'},
],
query=(
'''SELECT Minute, Records
