Utilisez DynamoDB à partir de Python comme 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))
- Il est nécessaire de changer le réglage pour utiliser Select.
Voir ci-dessous pour d'autres requêtes. https://dql.readthedocs.io/en/latest/topics/queries/index.html
mémorandum
Documentation DQL https://dql.readthedocs.io/en/latest/ref/dql.engine.html
L'état réel de la connexion est appelé Connexion DynamoDB du module dynamo3. https://pypi.org/project/dynamo3
Vidéo et Docker-composer
Comme expliqué dans la vidéo, j'ai également créé un environnement Docker-compose.
Recommended Posts