pydynamodb

import os from pydynamodb import connect aws_access_key_id = os.environ.get('AWS_ACCESS_KEY_ID', 'YOUR_ACCESS_KEY') aws_secret_access_key = os.environ.get('AWS_SECRET_ACCESS_KEY', 'YOUR_SECRET_KEY') region_name = os.environ.get('AWS_DEFAULT_REGION', 'us-east-1') try: # Establish a connection conn = connect( aws_access_key_id=aws_access_key_id, aws_secret_access_key=aws_secret_access_key, region_name=region_name ) # Create a cursor object cursor = conn.cursor() # Execute a DDL statement (MySQL-like syntax) cursor.execute("CREATE TABLE IF NOT EXISTS MyTestTable (id STRING HASH KEY, name STRING)") print("Table 'MyTestTable' created or already exists.") # Execute a DML statement (PartiQL syntax) cursor.execute("INSERT INTO MyTestTable VALUE {'id': ?, 'name': ?}", '1', 'Alice') print("Inserted item 'Alice'.") # Query data cursor.execute("SELECT * FROM MyTestTable WHERE id = ?", '1') result = cursor.fetchall() print(f"Queried result: {result}") # Clean up (optional) # cursor.execute("DROP TABLE MyTestTable") # print("Table 'MyTestTable' dropped.") # Close the connection cursor.close() conn.close() except Exception as e: print(f"An error occurred: {e}")