fastapi-postgresql-example-app

SECRET_KEY=secret
DEBUG=True
DB_CONNECTION=postgres://postgres:123456@localhost/traffic
HOST=localhost
PORT=54321
USERNAME=postgres
PASSWORD=123456
DATABASE=traffic

# 安装依赖
pip install -r requirements.txt
# 启动 可以使用下面的方法
uvicorn app.main:app --reload --host 0.0.0.0 --port 18000

# 摄像头列表
class Traffic_Cameras(BaseModel):
    id = AutoField(primary_key=True)
    camera_id = CharField() # 摄像头ID
    camera_name = CharField() # 摄像头名称
    camera_type = CharField() # 摄像头类型
    camera_lonlat = CharField(null=True, help_text="经纬度", verbose_name="经纬度") # 经纬度
    camera_road_id = CharField() # 摄像头道路ID
    camera_position = CharField() # 安装位置
    camera_scene = CharField(null=True) # 镜头
    camera_video_url = CharField(null=True) # 视频流地址
    camera_original_image_url = CharField(null=True) # 原始图片地址
    camera_image_url = CharField(null=True) # 标注后的图片地址
    created_at = DateTimeField(default=datetime.datetime.now)
    updated_at = DateTimeField(default=datetime.datetime.now)

# 创建数据表
def create_tables(db):
    db.create_tables([
        User,
        Traffic_Cameras,
        Traffic_Road,
        Traffic_Event_Code,
        Traffic_Lane_Code
    ])

# 查询摄像头列表
@router.get("/selectlist", name="查询摄像头列表", dependencies=[Depends(get_db)])
async def cameras_selectlist(
    road_id: str,
    request: Request=None
):
    query = Traffic_Cameras.select().where(Traffic_Cameras.camera_road_id == road_id).dicts()
    results = [item for item in query]

    return {

        "code": 200,
        "message": "查询成功",
        "data": results
    }

from app.api.routes import (
  authentication,
  users,
  traffic_cameras,
)

router = APIRouter()
router.include_router(authentication.router, tags=["authentication"], prefix="/users")
router.include_router(users.router, tags=["users"], prefix="/user")
router.include_router(traffic_cameras.router, tags=["监控摄像头"], prefix="/traffic_cameras")

# 创建摄像头
@router.post("/create", name="创建摄像头", dependencies=[Depends(get_db), Depends(get_current_user_authorizer())])
async def create_cameras(
    Create_Camera_Item: Create_Camera_Item,
    request: Request = None
):
    results = Create_Camera_Item.__dict__
    results['camera_id'] = str(uuid.uuid4())
    Traffic_Cameras.create(**results)
    print('创建摄像头', results)

    return {
        "code": 200,
        "message": "创建成功",
        "data": results
    }

FROM python

WORKDIR /home/fastapi

COPY . .

RUN pip install -r requirements.txt -i https://pypi.tuna.tsinghua.edu.cn/simple

EXPOSE 18000

CMD ["uvicorn", "app.main:app", "--reload", "--host", "0.0.0.0", "--port", "18000"]

# 构建镜像
docker build -t fastapi-postgresql-example-app .

# 运行镜像
docker run -d -p 18000:18000 -v $PWD/static/images:/home/fastapi/static/images --name fastapi-postgresql-example-app fastapi-postgresql-example-app

version: '3'

services:
  app:
    restart: always # 代表只要Docker启动，那么这个容器就跟着一起启动
    build: './'
    container_name: fastapi-postgresql-example-app # 指定容器名称
    ports:
      - "18000:18000"
    volumes:
      - './static/images:/home/fastapi/static/images'
    environment: # 指定时区
      TZ: Asia/Shanghai
    depends_on:
      - db
  db:
    restart: always
    image: postgres # 指定镜像名称
    container_name: fastapi-postgres # 指定容器名称 --name
    ports: # -p
      - 54321:5432 # 指定端口号的映射
    environment:
      POSTGRES_PASSWORD: 123456 # 指定 postgresql 的 postgres 用户登录密码
      TZ: Asia/Shanghai # 指定时区
    volumes:
      - './postgresData/data:/var/lib/postgresql/data' # 映射数据卷

docker-compose up -d
docker-compose down

# 图片访问和保存地址
ImagesUrl=http://{远程IP}:18000/api
ROOT_FILE_PATH=/home/fastapi/static/images

app
├── api              - web related stuff.
│   ├── dependencies - dependencies for routes definition.
│   ├── errors       - definition of error handlers.
│   └── routes       - web routes.
├── core             - application configuration, startup events, logging.
├── db               - db related stuff.
│   └── repositories - all crud stuff.
├── models           - pydantic models for this application.
│   ├── domain       - main models that are used almost everywhere.
│   └── schemas      - schemas for using in web routes.
├── resources        - strings that are used in web responses.
├── services         - logic that is not just crud related.
└── main.py          - FastAPI application creation and configuration.