DynamoDB용 Python에서 REST API 설정

Dynamo DB는 AWS가 제공하는 서비스로서 광범위한 관리형 데이터베이스 세트에서 제공되는 NoSQL입니다. 대부분의 다른 서비스와 마찬가지로 완전히 서버리스이고 유연하며 확장이 쉽습니다.

데이터 모델

여기서는 NoSQL을 작업하고 있으므로 데이터 구조에 실질적인 제한이 없습니다. 테이블의 각 항목에 대한 속성으로 키-값 쌍을 사용하여 작업할 수 있습니다. 이 키워드를 다시 살펴보겠습니다.

테이블 - 상당히 친숙한 용어로, 본질적으로 데이터 모음(이 경우 항목)입니다. 콘솔에서 DynamoDB를 사용하는 시작점이기도 합니다.

항목 - 테이블의 항목입니다. SQL과 동등한 데이터베이스의 행으로 간주할 수 있습니다.

속성 - 항목을 구성하는 데이터 포인트입니다. 여기에는 항목별 속성, 메타데이터 또는 항목과 연결될 수 있는 거의 모든 것이 포함될 수 있습니다.

JSON 배열은 DynamoDB의 테이블과 동일하다고 생각할 수 있습니다. 우리만의 테이블을 만들면 상황이 더 명확해질 거라고 확신해요.

데이터베이스 설정

AWS 콘솔에서 DynamoDB에 새 테이블을 생성하는 것은 말 그대로 케이크 조각입니다. 필요한 것은 이름과 파티션 키뿐입니다. 이 경우 기본 키가 됩니다. 이는 테이블에서 항목을 검색하는 데 도움이 됩니다.

내가 플레이한 모든 게임에 대한 표를 만들고 10점 만점으로 평가하겠습니다 :)

콘솔에서 직접 테이블을 조작할 수 있습니다. 새 항목을 추가하여 어떻게 보이는지 확인해 보겠습니다.

첫 번째 출품작은 제가 가장 좋아하는 RPG(롤플레잉) 게임인 The Witcher 3이어야 합니다. 등급에 새 속성을 추가할 예정이며, 확실히 9.8이 될 것입니다. :)

API 설정

맞습니다. 이제 GUI 없이 이 모든 작업을 수행할 수 있는 Python 코드를 작성할 시간입니다. ;)

## app.py
from flask import Flask, jsonify, request
import boto3
from boto3.dynamodb.conditions import Key
import uuid  # Import uuid module for generating UUIDs

app = Flask(__name__)

# Initialize DynamoDB client
dynamodb = boto3.resource('dynamodb', region_name='ap-south-1')  # Replace with your region
## Do keep in mind to save your AWS credentials file in the root directory
table = dynamodb.Table('games')  # Replace with your table name

# Route to get all games
@app.route('/games', methods=['GET'])
def get_games():
    try:
        response = table.scan()
        games = response.get('Items', [])
        return jsonify({'games': games}), 200
    except Exception as e:
        return jsonify({'error': str(e)}), 500

if __name__ == '__main__':
    app.run(debug=True)

Python의 장점은 단 몇 줄의 코드만으로 완전한 API를 설정할 수 있다는 것입니다. 이제 이 코드 덩어리는 테이블에 액세스하고 테이블에서 데이터를 가져오는 데 충분합니다. 스캔 기능을 사용하여 게임 테이블에서 항목을 가져옵니다.

python3 app.py를 사용하여 앱을 시작할 수 있습니다

그리고 /games 엔드포인트를 컬링하면 다음과 같은 응답을 기대할 수 있습니다.

항목 생성 및 업데이트 경로

## app.py
from flask import Flask, jsonify, request
import boto3
from boto3.dynamodb.conditions import Key
import uuid  # Import uuid module for generating UUIDs

app = Flask(__name__)

# Initialize DynamoDB client
dynamodb = boto3.resource('dynamodb', region_name='ap-south-1')  # Replace with your region
## Do keep in mind to save your AWS credentials file in the root directory
table = dynamodb.Table('games')  # Replace with your table name

# Route to get all games
@app.route('/games', methods=['GET'])
def get_games():
    try:
        response = table.scan()
        games = response.get('Items', [])
        return jsonify({'games': games}), 200
    except Exception as e:
        return jsonify({'error': str(e)}), 500

if __name__ == '__main__':
    app.run(debug=True)

여기에서는 put_item을 사용하여 테이블에 항목을 추가하고 있습니다. 레코드를 업데이트하려면 update_item 함수를 사용합니다.

자세히 관찰해 보면 업데이트할 속성을 지정하는 UpdateExpression을 사용하고 있습니다. 이를 통해 어떤 속성이 변경되는지 정확하게 제어하고 실수로 덮어쓰는 것을 방지할 수 있습니다.

기록을 삭제하려면 다음과 같이 하면 됩니다.

# Route to create a new game
@app.route('/games', methods=['POST'])
def create_game():
    try:
        game_data = request.get_json()
        name = game_data.get('name')
        rating = game_data.get('rating')
        hours = game_data.get('hours', 0)

        # Generate a random UUID for the new game
        id = str(uuid.uuid4())

        if not name or not rating:
            return jsonify({'error': 'Missing required fields'}), 400

        # Store the game in DynamoDB
        table.put_item(Item={'id': id, 'name': name, 'rating': rating, 'hours': hours})

        # Return the created game with the generated UUID
        created_game = {'id': id, 'name': name, 'rating': rating}
        return jsonify({'message': 'Game added successfully', 'game': created_game}), 201
    except Exception as e:
        return jsonify({'error': str(e)}), 500

# Route to update an existing game
@app.route('/games/<int:id>', methods=['PUT'])
def update_game(id):
    try:
        game_data = request.get_json()
        name = game_data.get('name')
        rating = game_data.get('rating')
        hours = game_data.get('hours', 0)

        if not name and not rating:
            return jsonify({'error': 'Nothing to update'}), 400

        update_expression = 'SET '
        expression_attribute_values = {}

        if name:
            update_expression += ' #n = :n,'
            expression_attribute_values[':n'] = name
        if rating:
            update_expression += ' #r = :r,'
            expression_attribute_values[':r'] = rating
        if hours:
            update_expression += ' #h = :h,'
            expression_attribute_values[':h'] = hours

        update_expression = update_expression[:-1]  # remove trailing comma
        response = table.update_item(
            Key={'id': id},
            UpdateExpression=update_expression,
            ExpressionAttributeNames={'#n': 'name', '#r': 'rating', '#h': 'hours'},
            ExpressionAttributeValues=expression_attribute_values,
            ReturnValues='UPDATED_NEW'
        )
        updated_game = response.get('Attributes', {})
        return jsonify(updated_game), 200
    except Exception as e:
        return jsonify({'error': str(e)}), 500

---

자, Python 덕분에 몇 분 만에 DynamoDB용 CRUD 기능이 포함된 REST API를 설정할 수 있습니다.

위 내용은 DynamoDB용 Python에서 REST API 설정의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!