Operate DynamoDB from Python like SQL.
set up
pip install dql
code
import dql
import boto3
import os
table_name=os.environ['TABLE_NAME'] # dynamodb
engine = dql.Engine()
c = engine.connect(
region=os.environ['AWS_DEFAULT_REGION'],
access_key=os.environ['AWS_ACCESS_KEY_ID'],
secret_key=os.environ['AWS_SECRET_ACCESS_KEY'],
host=os.environ['HOST'],
port=int(os.environ['PORT']),
is_secure=False
)
print("--scan--")
results = engine.execute(f"SCAN * FROM {table_name} LIMIT 10")
for item in results:
print(dict(item))
print("--delete--")
results = engine.execute(f"DELETE FROM {table_name} WHERE tm>=1235 and tm<=1236")
print("--scan--")
results = engine.execute(f"SCAN * FROM {table_name} LIMIT 10")
for item in results:
print(dict(item))
- It is necessary to change the setting to use Select.
See below for other queries. https://dql.readthedocs.io/en/latest/topics/queries/index.html
memorandum
DQL documentation https://dql.readthedocs.io/en/latest/ref/dql.engine.html
The actual state of connection is called DynamoDB Connection of dynamo3 module. https://pypi.org/project/dynamo3
Video and Docker-compose
As explained in the video, I also created a Docker-compose environment.
Recommended Posts