fc

Author: naman47vyas

Diff for: .gitignore

@@ -0,0 +1 @@
+.env

Diff for: Dockerfile

@@ -0,0 +1,12 @@
+FROM python:3.9-slim
+
+WORKDIR /app
+
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY . .
+
+EXPOSE 8080
+
+CMD ["python", "main.py"]

Diff for: Dockerfile.nginx

@@ -0,0 +1,38 @@
+FROM nginx:1.22.1
+
+ENV NGINX_VERSION="1.22.1"
+ENV NGINX_VTS_VERSION="0.2.2"
+
+# Install build dependencies and add nginx source repository
+RUN apt-get update \
+    && apt-get install -y gnupg2 \
+    && curl -s http://nginx.org/packages/keys/nginx_signing.key | apt-key add - \
+    && echo "deb-src http://nginx.org/packages/debian/ bullseye nginx" >> /etc/apt/sources.list
+
+# Download nginx source and install build dependencies
+RUN apt-get update \
+    && apt-get install -y dpkg-dev curl \
+    && mkdir -p /opt/rebuildnginx \
+    && chmod 0777 /opt/rebuildnginx \
+    && cd /opt/rebuildnginx \
+    && su --preserve-environment -s /bin/bash -c "apt-get source nginx=${NGINX_VERSION}" _apt \
+    && apt-get build-dep -y nginx=${NGINX_VERSION}
+
+# Download and integrate VTS module
+RUN cd /opt \
+    && curl -sL https://github.com/vozlt/nginx-module-vts/archive/v${NGINX_VTS_VERSION}.tar.gz | tar -xz \
+    && sed -i -r -e "s/\.\/configure(.*)/.\/configure\1 --add-module=\/opt\/nginx-module-vts-${NGINX_VTS_VERSION}/" \
+       /opt/rebuildnginx/nginx-${NGINX_VERSION}/debian/rules \
+    && cd /opt/rebuildnginx/nginx-${NGINX_VERSION} \
+    && dpkg-buildpackage -b \
+    && cd /opt/rebuildnginx \
+    && dpkg --install nginx_${NGINX_VERSION}-1~bullseye_amd64.deb
+
+# Cleanup
+RUN apt-get remove --purge -y dpkg-dev curl \
+    && apt-get -y --purge autoremove \
+    && rm -rf /var/lib/apt/lists/* \
+    && rm -rf /opt/rebuildnginx \
+    && rm -rf /opt/nginx-module-vts-${NGINX_VTS_VERSION}
+
+CMD ["nginx", "-g", "daemon off;"]

Diff for: README.md

@@ -0,0 +1,61 @@
+# Nginx Load Balancing Demo with VTS Module
+
+This project demonstrates load balancing between two FastAPI services using Nginx with the Virtual Host Traffic Status (VTS) module for monitoring.
+Prerequisites
+
+- Docker
+- docker-compose
+- curl (for testing)
+
+## Quick Start
+
+Create necessary configuration files as shown in the project structure.
+
+Build and start the services:
+
+```
+docker-compose up --build
+```
+
+## Accessing Services
+
+Test the basic endpoint:
+``` bash
+curl http://localhost:8000/
+```
+
+Create a new item:
+``` bash
+curl -X POST http://localhost:8000/item \
+  -H "Content-Type: application/json" \
+  -d '{"name": "test item", "price": 10.99, "desc": "A test item"}'
+```
+
+Get all items:
+```
+curl http://localhost:8000/items
+```
+
+## Monitoring
+
+### VTS Module Features
+
+- Access detailed traffic statistics at `/status`
+- Monitor request counts, bandwidth usage, and response times
+- View per-server metrics for load balancing
+
+### Basic Nginx Status
+
+- Access basic Nginx metrics at `/nginx_status`
+- View current connections and request statistics
+
+### Load Balancer Configuration
+The Nginx load balancer is configured with:
+
+- Round-robin distribution between two FastAPI servers
+- HTTP headers for tracking (X-Real-IP, X-Forwarded-For)
+- Server identification header (X-Served-By)
+- Access restrictions for status pages
+
+
+

Diff for: __pycache__/main.cpython-310.pyc

@@ -0,0 +1,44 @@
+version: '3'
+services:
+  nginx:
+    build:
+      context: .
+      dockerfile: Dockerfile.nginx
+    ports:
+      - "8000:80"
+    volumes:
+      - type: bind
+        source: ./nginx.conf
+        target: /etc/nginx/nginx.conf
+        read_only: true 
+    networks:
+      - app_network
+    healthcheck:
+      test: ["CMD", "curl", "-f", "http://localhost/nginx_status"]
+      interval: 30s
+      timeout: 10s
+      retries: 3
+
+  fastapi1:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    networks:
+      - app_network
+    environment:
+      - SERVER_NAME=server1
+    command: python main.py
+
+  fastapi2:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    networks:
+      - app_network
+    environment:
+      - SERVER_NAME=server2
+    command: python main.py
+
+networks:
+  app_network:
+    driver: bridge

Diff for: __pycache__/main.cpython-39.pyc

@@ -0,0 +1,33 @@
+from pydantic import BaseModel
+from fastapi import FastAPI
+from typing import List
+import uvicorn
+
+
+class Item(BaseModel):
+  name: str
+  price: float
+  desc: str
+
+class ItemList(BaseModel):
+  all_items: List[Item]
+
+items = ItemList
+
+app = FastAPI()
+
+@app.get("/")
+def index():
+  return "Hi mom"
+
+@app.post("/item")
+def create_item(item: Item):
+  items.all_items.append(item)
+  return {"message": "Item added successfully"}
+
+@app.get("/items")
+def get_all_items():
+  return items
+
+if __name__ == "__main__":
+  uvicorn.run(app, host="0.0.0.0", port=8080)

Diff for: docker-compose.yaml

@@ -0,0 +1,66 @@
+user nginx;
+worker_processes 1;
+error_log /var/log/nginx/error.log warn;
+pid /var/run/nginx.pid;
+
+events {
+    worker_connections 1024;
+}
+
+http {
+    include /etc/nginx/mime.types;
+    default_type application/octet-stream;
+
+    # VTS (Virtual Host Traffic Status) configuration
+    vhost_traffic_status_zone;
+    vhost_traffic_status_filter_by_host on;
+
+    upstream fastapi_servers {
+        server fastapi1:8080;
+        server fastapi2:8080;
+    }
+
+    server {
+        listen 80;
+        server_name localhost;
+
+        # VTS status page
+        location /status {
+            vhost_traffic_status_display;
+            vhost_traffic_status_display_format html;
+            access_log off;
+            allow 127.0.0.1;
+            allow 10.0.0.0/8;
+            allow 172.16.0.0/12;
+            allow 192.168.0.0/16;
+            deny all;
+        }
+
+        # Original stub status endpoint
+        location /nginx_status {
+            stub_status on;
+            access_log off;
+            allow 127.0.0.1;
+            allow 10.0.0.0/8;
+            allow 172.16.0.0/12;
+            allow 192.168.0.0/16;
+            deny all;
+        }
+
+        location / {
+            proxy_pass http://fastapi_servers;
+            proxy_set_header Host $host;
+            proxy_set_header X-Real-IP $remote_addr;
+            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+            proxy_set_header X-Forwarded-Proto $scheme;
+            add_header X-Served-By $upstream_addr;
+        }
+    }
+
+    log_format main '$remote_addr - $remote_user [$time_local] "$request" '
+                    '$status $body_bytes_sent "$http_referer" '
+                    '"$http_user_agent" "$http_x_forwarded_for"';
+    access_log /var/log/nginx/access.log main;
+    sendfile on;
+    keepalive_timeout 65;
+}

Diff for: main.py

@@ -0,0 +1,25 @@
+annotated-types==0.7.0
+anyio==4.6.2.post1
+beautifulsoup4==4.12.3
+bs4==0.0.2
+certifi==2024.8.30
+charset-normalizer==3.4.0
+click==8.1.7
+exceptiongroup==1.2.2
+fastapi==0.115.4
+h11==0.14.0
+idna==3.10
+markdown-it-py==3.0.0
+mdurl==0.1.2
+pip-search==0.0.12
+pydantic==2.9.2
+pydantic_core==2.23.4
+Pygments==2.18.0
+requests==2.32.3
+rich==13.9.4
+sniffio==1.3.1
+soupsieve==2.6
+starlette==0.41.2
+typing_extensions==4.12.2
+urllib3==2.2.3
+uvicorn==0.32.0