Menyediakan REST API dalam Python untuk DynamoDB

Dynamo DB ialah tawaran NoSQL AWS dalam set pangkalan data terurus yang luas sebagai perkhidmatan yang mereka sediakan. Seperti kebanyakan perkhidmatan lain, perkhidmatan ini tanpa pelayan sepenuhnya, fleksibel dan mudah untuk skala.

Model Data

Memandangkan kami sedang mengusahakan NoSQL di sini, tiada sekatan sebenar pada struktur data. Kita boleh beroperasi dengan pasangan nilai kunci sebagai atribut untuk setiap item dalam jadual. Mari lihat kata kunci ini sekali lagi.

Jadual - istilah yang agak biasa, ia pada dasarnya adalah koleksi data, dalam kes ini, item. Ia juga merupakan titik permulaan bekerja dengan DynamoDB pada konsol.

Item - entri dalam jadual. Anda boleh menganggapnya satu baris dalam pangkalan data setara SQL.

Atribut - Titik data yang membentuk item. Ia boleh mengandungi atribut khusus item, metadata atau hampir apa sahaja yang boleh dikaitkan dengan item.

Anda boleh menganggap tatasusunan JSON sebagai setara dengan jadual dalam DynamoDB. Saya pasti perkara akan menjadi lebih jelas apabila kita mencipta jadual kita sendiri.

Menyediakan pangkalan data

Ini betul-betul sekeping kek untuk mencipta jadual baharu dalam DynamoDB daripada AWS Console. Apa yang anda perlukan ialah nama dan kunci partition, yang merupakan kunci utama anda dalam kes ini. Ini akan membantu anda mencari item dalam jadual.

Saya sedang mencipta jadual untuk semua permainan yang telah saya mainkan dan saya akan menilai mereka daripada 10 :)

Anda boleh mengacaukan jadual terus dari konsol, mari cuba tambah item baharu untuk melihat rupanya.

Entri pertama saya mestilah permainan RPG (lakonan) kegemaran saya - The Witcher 3. Saya akan menambah atribut baharu untuk penilaian dan ia akan menjadi 9.8 yang kukuh daripada saya :)

Menyediakan API

Betul, sudah tiba masanya untuk menulis beberapa kod Python untuk melakukan semua ini tanpa GUI ;)

## 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)

Keindahan Python ialah anda boleh menyediakan API lengkap dalam hanya beberapa baris kod. Sekumpulan kod ini kini mencukupi untuk kami mengakses jadual dan mengambil data daripadanya. Kami menggunakan fungsi imbasan untuk mengambil item daripada meja permainan.

Anda boleh memulakan apl dengan menggunakan python3 app.py

Dan anda boleh menjangkakan respons yang kelihatan seperti ini apabila anda melencong untuk titik akhir /games.

Laluan untuk membuat dan mengemas kini entri

## 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)

Di sini, kami menggunakan put_item untuk menambah item pada jadual. Untuk mengemas kini rekod, kami menggunakan fungsi kemas kini_item.

Jika anda memerhati dengan teliti, kami menggunakan UpdateExpression di mana kami menentukan atribut yang kami kemas kini. Ini membolehkan kami mengawal dengan tepat atribut mana yang akan ditukar dan mengelakkan tiruan yang tidak disengajakan.

Dan untuk memadamkan rekod, anda boleh menggunakan sesuatu seperti ini -

# 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

---

Nah, begitulah, anda cuma sediakan REST API dengan Fungsi CRUD untuk DynamoDB dalam masa beberapa minit terima kasih kepada Python.

Atas ialah kandungan terperinci Menyediakan REST API dalam Python untuk DynamoDB. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!