added docker-compose.yaml, server db in async for postgres, server db in async for flask

Author: Kinetics20

performance/__init__.py

@@ -0,0 +1,14 @@
+services:
+  postgres_db:
+    image: postgres:17
+    ports:
+      - "5439:5432"
+    volumes:
+      - postgres:/var/lib/postgresql/data
+    environment:
+      POSTGRES_PASSWORD: password
+      POSTGRES_USER: postgres
+      POSTGRES_DB: products
+
+volumes:
+  postgres:

performance/docker-compose.yaml

@@ -0,0 +1,39 @@
+import asyncpg
+from asyncpg import Pool, Record
+from starlette.applications import Starlette
+from starlette.routing import Route
+from starlette.requests import Request
+from starlette.responses import Response, JSONResponse
+
+
+async def create_database_pool() -> None:
+    pool: Pool = await asyncpg.create_pool(
+        host='127.0.0.1',
+        port=5439,
+        user='postgres',
+        password='password',
+        database='products',
+        min_size=6,
+        max_size=6
+    )
+
+    app.state.DB = pool
+
+
+async def destroy_database_pool() -> None:
+    await app.state.close()
+
+
+async def brands(request: Request) -> Response:
+    connection: Pool = request.app.state.DB
+    query = 'SELECT brand_id, brand_name FROM brand;'
+    results: list[Record] = await connection.fetch(query)
+    result_as_dict: list[dict] = [dict(brand) for brand in results]
+    return JSONResponse(result_as_dict)
+
+
+app = Starlette(
+    routes=[Route('/brands', brands)],
+    on_startup=[create_database_pool],
+    on_shutdown=[destroy_database_pool]
+)

performance/server_1.py

@@ -0,0 +1,16 @@
+from flask import Flask, jsonify
+import psycopg2
+
+app = Flask(__name__)
+
+conn_info = "dbname=products user=postgres password=password host=127.0.0.1 port=5439"
+db = psycopg2.connect(conn_info)
+
+
+@app.route('/brands')
+def brands():
+    cur = db.cursor()
+    cur.execute('SELECT brand_id, brand_name FROM brand')
+    rows = cur.fetchall()
+    cur.close()
+    return jsonify([{'brand_id': row[0], 'brand_name': row[1]} for row in rows])