sqlalchemy_bigquery_connection_and_query_quickstart.py

1from sqlalchemy import create_engine
2from sqlalchemy.schema import Table, MetaData
3
4# Project ID: your-project-id
5# Dataset ID: your_dataset_id
6# Table Name: your_table_name
7
8# The connection string follows the format:
9# bigquery://{project_id}/{dataset_id}
10engine = create_engine('bigquery://my-project-id/usa_names')
11
12# Standard SQLAlchemy usage
13metadata = MetaData(bind=engine)
14table = Table('usa_1910_current', metadata, autoload=True)
15
16# Execute a query
17with engine.connect() as connection:
18    rows = connection.execute(table.select().limit(5))
19    for row in rows:
20        print(row)