AWS Data

AWS Data Services / AWS 데이터 서비스

MCP 없이 boto3/CLI로 직접 데이터 서비스를 관리합니다.

When to Use / 사용 시점

• "DynamoDB 테이블 조회" / "Query DynamoDB tables"
• "Aurora 쿼리 실행" / "Run Aurora queries"
• "Redshift 데이터 조회" / "Query Redshift data"
• "ElastiCache 관리" / "Manage ElastiCache"

DynamoDB

# List tables / 테이블 목록
aws dynamodb list-tables

# Scan table / 테이블 스캔
aws dynamodb scan --table-name my-table --max-items 10

# Query / 쿼리
aws dynamodb query --table-name my-table \
  --key-condition-expression "PK = :pk" \
  --expression-attribute-values '{":pk": {"S": "user#123"}}'

# Put item / 항목 추가
aws dynamodb put-item --table-name my-table \
  --item '{"PK": {"S": "user#123"}, "SK": {"S": "profile"}, "name": {"S": "John"}}'

import boto3
ddb = boto3.client('dynamodb')

ddb.list_tables()
ddb.scan(TableName='my-table', Limit=10)
ddb.query(
    TableName='my-table',
    KeyConditionExpression='PK = :pk',
    ExpressionAttributeValues={':pk': {'S': 'user#123'}}
)

# Using resource API (simpler) / 리소스 API 사용 (더 간단)
table = boto3.resource('dynamodb').Table('my-table')
table.get_item(Key={'PK': 'user#123', 'SK': 'profile'})
table.put_item(Item={'PK': 'user#123', 'SK': 'profile', 'name': 'John'})

Aurora PostgreSQL / MySQL (RDS Data API)

rds = boto3.client('rds-data')

# Execute SQL / SQL 실행
rds.execute_statement(
    resourceArn='arn:aws:rds:...:cluster:...',
    secretArn='arn:aws:secretsmanager:...',
    database='mydb',
    sql='SELECT * FROM users LIMIT 10'
)

# With parameters / 파라미터 사용
rds.execute_statement(
    resourceArn='...', secretArn='...', database='mydb',
    sql='SELECT * FROM users WHERE id = :id',
    parameters=[{'name': 'id', 'value': {'longValue': 42}}]
)

Amazon Redshift

redshift_data = boto3.client('redshift-data')

# Execute query / 쿼리 실행
response = redshift_data.execute_statement(
    ClusterIdentifier='my-cluster',
    Database='mydb',
    DbUser='admin',
    Sql='SELECT * FROM sales ORDER BY amount DESC LIMIT 10'
)

# Get results / 결과 조회
import time
time.sleep(5)
redshift_data.get_statement_result(Id=response['Id'])

# List databases / 데이터베이스 목록
redshift_data.list_databases(ClusterIdentifier='my-cluster', Database='dev', DbUser='admin')

ElastiCache / Valkey / Redis

# List replication groups / 복제 그룹 목록
aws elasticache describe-replication-groups

# List cache clusters / 캐시 클러스터 목록
aws elasticache describe-cache-clusters

# List serverless caches / 서버리스 캐시 목록
aws elasticache describe-serverless-caches

ec = boto3.client('elasticache')
ec.describe_replication_groups()
ec.describe_cache_clusters()
ec.describe_serverless_caches()

Amazon Neptune (Graph DB)

neptune = boto3.client('neptunedata')

# OpenCypher query / OpenCypher 쿼리
neptune.execute_open_cypher_query(
    openCypherQuery='MATCH (n) RETURN n LIMIT 10'
)

# Gremlin query / Gremlin 쿼리
neptune.execute_gremlin_query(
    gremlinQuery='g.V().limit(10)'
)

# Get graph status / 그래프 상태
neptune.get_engine_status()

S3 Tables

s3t = boto3.client('s3tables')
s3t.list_table_buckets()
s3t.list_namespaces(tableBucketARN='arn:...')
s3t.list_tables(tableBucketARN='arn:...', namespace='default')

Quick Reference / 빠른 참조