-
Notifications
You must be signed in to change notification settings - Fork 4
4. SQLAlchemy
Peng Ren edited this page Sep 23, 2024
·
2 revisions
Install SQLAlchemy with pip install "SQLAlchemy>=1.0.0, <2.0.0" or pip install "SQLAlchemy>2.0.0".
SQLAlchemy 1.x and 2.x are both supported.
The connection string has the following format:
dynamodb://{aws_access_key_id}:{aws_secret_access_key}@dynamodb.{region_name}.amazonaws.com:443?verify=false&...
from pydynamodb import sqlalchemy_dynamodb
from sqlalchemy.engine import create_engine
from sqlalchemy.sql.schema import Column, MetaData, Table
conn_str = (
"dynamodb://{aws_access_key_id}:{aws_secret_access_key}@dynamodb.{region_name}.amazonaws.com:443"
+ "?verify=false"
)
conn_str = conn_str.format(
aws_access_key_id=aws_access_key_id,
aws_secret_access_key=aws_secret_access_key,
region_name=region_name,
)
engine = create_engine(conn_str)
with engine.connect() as connection:
many_rows = Table("many_rows", MetaData(),
Column('key_partition', String, nullable=False),
Column('key_sort', Integer),
Column('col_str', String),
Column('col_num', Numeric)
)
rows = conn.execute(many_rows.select()).fetchall()
print(rows)