gcloud_aio_bigquery_async_query_quickstart.py

1import asyncio
2from gcloud.aio.bigquery import BigQuery
3
4async def run_query():
5    # Replace 'your-project-id' with your actual GCP project ID
6    project = 'your-project-id'
7    query = 'SELECT name FROM `bigquery-public-data.usa_names.usa_1910_current` LIMIT 10'
8
9    async with BigQuery(project=project) as bq:
10        # Submit the query and wait for the result
11        result = await bq.query(query)
12        
13        # Print the rows returned by the query
14        for row in result['rows']:
15            print(row)
16
17if __name__ == '__main__':
18    loop = asyncio.get_event_loop()
19    loop.run_until_complete(run_query())