🚨 서버리스 이상징후 신고 서비스

import json
import uuid
import boto3
from datetime import datetime, timezone
 
dynamodb = boto3.resource("dynamodb", region_name="ap-northeast-2")
table = dynamodb.Table("IncidentReports")
 
def lambda_handler(event, context):
    try:
        # API Gateway에서 전달된 요청 Body 파싱
        body = json.loads(event.get("body", "{}"))
 
        # 필수 필드 검증
        required = ["reporter_name", "location", "description", "severity"]
        missing = [f for f in required if f not in body]
        if missing:
            return {
                "statusCode": 400,
                "headers": {"Content-Type": "application/json", "Access-Control-Allow-Origin": "*"},
                "body": json.dumps({"error": f"필수 필드 누락: {', '.join(missing)}"})
            }
 
        # 심각도 검증
        valid_severity = ["LOW", "MEDIUM", "HIGH", "CRITICAL"]
        if body["severity"] not in valid_severity:
            return {
                "statusCode": 400,
                "headers": {"Content-Type": "application/json", "Access-Control-Allow-Origin": "*"},
                "body": json.dumps({"error": f"유효하지 않은 심각도. 가능한 값: {valid_severity}"})
            }
 
        # DynamoDB에 저장
        item = {
            "incident_id": str(uuid.uuid4()),
            "created_at": datetime.now(timezone.utc).isoformat(),
            "reporter_name": body["reporter_name"],
            "location": body["location"],
            "description": body["description"],
            "severity": body["severity"],
            "status": "REPORTED",
        }
        table.put_item(Item=item)
 
        return {
            "statusCode": 201,
            "headers": {"Content-Type": "application/json", "Access-Control-Allow-Origin": "*"},
            "body": json.dumps({"message": "이상징후 신고가 접수되었습니다", "incident": item})
        }
 
    except Exception as e:
        return {
            "statusCode": 500,
            "headers": {"Content-Type": "application/json", "Access-Control-Allow-Origin": "*"},
            "body": json.dumps({"error": f"서버 오류: {str(e)}"})
        }

import json
import boto3
 
dynamodb = boto3.resource("dynamodb", region_name="ap-northeast-2")
table = dynamodb.Table("IncidentReports")
 
def lambda_handler(event, context):
    try:
        # 쿼리 파라미터 추출
        params = event.get("queryStringParameters") or {}
        severity_filter = params.get("severity")
        status_filter = params.get("status")
 
        # DynamoDB Scan (소규모 데이터에 적합)
        response = table.scan()
        items = response.get("Items", [])
 
        # 필터링
        if severity_filter:
            items = [i for i in items if i.get("severity") == severity_filter]
        if status_filter:
            items = [i for i in items if i.get("status") == status_filter]
 
        # 최신순 정렬
        items.sort(key=lambda x: x.get("created_at", ""), reverse=True)
 
        return {
            "statusCode": 200,
            "headers": {"Content-Type": "application/json", "Access-Control-Allow-Origin": "*"},
            "body": json.dumps({"count": len(items), "incidents": items})
        }
 
    except Exception as e:
        return {
            "statusCode": 500,
            "headers": {"Content-Type": "application/json", "Access-Control-Allow-Origin": "*"},
            "body": json.dumps({"error": f"서버 오류: {str(e)}"})
        }

# API Gateway URL (자신의 URL로 교체)
API_URL="https://xxxxxxxxxx.execute-api.ap-northeast-2.amazonaws.com"
 
# 1. 이상징후 신고 (현장 근무자가 모바일에서 전송)
curl -X POST "$API_URL/incidents" \
  -H "Content-Type: application/json" \
  -d '{
    "reporter_name": "박현장",
    "location": "A동 1층 1라인",
    "description": "컨베이어 벨트에서 심한 진동과 소음 발생. 즉시 확인 필요.",
    "severity": "HIGH"
  }'
 
# 2. 추가 신고
curl -X POST "$API_URL/incidents" \
  -H "Content-Type: application/json" \
  -d '{
    "reporter_name": "이반장",
    "location": "B동 지하 냉각실",
    "description": "냉각수 온도가 비정상적으로 높음. 40도 이상.",
    "severity": "CRITICAL"
  }'
 
# 3. 전체 신고 목록 조회
curl "$API_URL/incidents" | python3 -m json.tool
 
# 4. 심각도 필터링
curl "$API_URL/incidents?severity=CRITICAL" | python3 -m json.tool
 
# 5. 잘못된 요청 테스트 (필수 필드 누락)
curl -X POST "$API_URL/incidents" \
  -H "Content-Type: application/json" \
  -d '{"reporter_name": "테스트"}'