图床项目--v1

.idea/.gitignore

@@ -0,0 +1,8 @@
+# 默认忽略的文件
+/shelf/
+/workspace.xml
+# 基于编辑器的 HTTP 客户端请求
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

.idea/fastapi_01.iml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

.idea/inspectionProfiles/Project_Default.xml

@@ -0,0 +1,12 @@
+<component name="InspectionProjectProfileManager">
+  <profile version="1.0">
+    <option name="myName" value="Project Default" />
+    <inspection_tool class="PyUnresolvedReferencesInspection" enabled="true" level="WARNING" enabled_by_default="true">
+      <option name="ignoredIdentifiers">
+        <list>
+          <option value="tensorflow.keras" />
+        </list>
+      </option>
+    </inspection_tool>
+  </profile>
+</component>

.idea/inspectionProfiles/profiles_settings.xml

@@ -0,0 +1,6 @@
+<component name="InspectionProjectProfileManager">
+  <settings>
+    <option name="USE_PROJECT_PROFILE" value="false" />
+    <version value="1.0" />
+  </settings>
+</component>

.idea/misc.xml

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.10 (jango) (2)" project-jdk-type="Python SDK" />
+</project>

.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/fastapi_01.iml" filepath="$PROJECT_DIR$/.idea/fastapi_01.iml" />
+    </modules>
+  </component>
+</project>

main.py

@@ -0,0 +1,23 @@
+from fastapi import FastAPI
+from pydantic import BaseModel, ValidationError
+from typing import List, Optional
+from datetime import datetime
+from typing import Dict
+from routers import items,files
+import uvicorn
+
+app = FastAPI()
+
+app.include_router(files.router)
+app.include_router(items.router)
+
+
+if __name__ == '__main__':
+    uvicorn.run(app,host="127.0.0.1",port=8000)
+
+
+
+
+
+
+

models/model.py

@@ -0,0 +1,14 @@
+"""
+    encoding: UTF-8
+    @author:clx
+    @file:model.py
+    @time:2023/5/30 6:29
+"""
+from typing import Optional
+
+from pydantic import BaseModel
+
+
+class Item(BaseModel):
+    id: int
+    name: str

pydantic_test.py

@@ -0,0 +1,62 @@
+"""
+    encoding: UTF-8
+    @author:clx
+    @file:pydantic_test.py
+    @time:2023/5/29 22:55
+"""
+import random
+
+import fastapi
+
+from starlette.responses import FileResponse
+# from fastapi.responses import FileResponse
+# from datetime import datetime
+# from typing import Optional, List
+#
+# from pydantic import BaseModel
+# from fastapi import FastAPI
+#
+# app = FastAPI()
+#
+# class User(BaseModel):
+#     id:int
+#     name:str = "Jone"
+#     signup_ts = Optional[datetime]
+#     friends:List[int]
+#
+# dic = {
+#     "id":1,
+#     "signup_ts":"2022-11-21",
+#     "friends":[1,2,"3"]
+# }
+# user = User(**dic)
+# print(user.id)
+
+import os
+from pathlib import Path
+
+def fun():
+    f = os.path.join(r"./", "name")
+
+    print(f)
+    print(Path(f).name)
+
+    fr = FileResponse(
+        path=f,
+        filename=Path(f).name
+    )
+
+# fun()
+
+# a = "dsadas.txt"
+# file_ext = os.path.splitext(a)
+# front,ext = file_ext
+# print(front,ext)
+
+# print("".join(random.sample("qwertyuiopasdfghjklzxcvbnm1234567890",5)))
+
+import time
+import re
+a = str(time.time())
+b = re.sub(r"\.","",a)
+print(b)

pytest.py

@@ -0,0 +1,23 @@
+"""
+    encoding: UTF-8
+    @author:clx
+    @file:pytest.py
+    @time:2023/5/30 20:06
+"""
+import uvicorn
+from fastapi import FastAPI
+from fastapi.testclient import TestClient
+
+app = FastAPI()
+
+client = TestClient(app)
+
+def test_create_file():
+    response = client.get("/item/res")
+    assert response.status_code == 200
+    assert response.json() == [
+    {"id": 1, "name": "jack"},
+    {"id": 2, "name": "mark"},
+    {"id": 3, "name": "tom"},
+    {"id": 4, "name": "sery"}
+]

routers/files.py

@@ -0,0 +1,104 @@
+"""
+    encoding: UTF-8
+    @author:clx
+    @file:files.py.py
+    @time:2023/5/30 6:08
+"""
+import os
+import random
+import time
+import re
+import aiofiles
+from fastapi import APIRouter, File, UploadFile, Request, Response, status, HTTPException
+from fastapi.responses import FileResponse, StreamingResponse
+from typing import Annotated, List
+from minio import Minio
+from io import BytesIO
+
+minio_client = Minio(
+    "127.0.0.1:9000",
+    access_key="minioadmin",
+    secret_key="minioadmin",
+    secure=False
+)
+
+router = APIRouter()
+
+
+# 测试
+# @router.post("/file/local")
+# async def create_file(file: UploadFile = File(...)):
+#     filename = file.filename
+#     stream = await file.read()
+#     with open(r"D:\pythonProject\django\fastapi_01\static\img\{}".format(filename), "ab+") as fp:
+#         fp.write(stream)
+
+
+# minio ?上传文件时在重复时，需要修改文件名
+@router.post("/file")
+async def create_file(file: UploadFile = File(...)):
+    timestamp = str(time.time())
+    uid = re.sub(r"\.", "", timestamp)
+    front, ext = os.path.splitext(file.filename)
+    file_name = uid + ext  # 168549427474778.png
+    data = await file.read()
+    file_stream = BytesIO(initial_bytes=data)
+    size = len(data)
+    uri = os.path.join("/file/", file_name)
+    if (minio_client.put_object(
+            "file1",
+            file_name,
+            file_stream,
+            size
+    )):
+        return {"status": 200, "path": uri}
+    else:
+        return {"msg": "上传失败", "status": 400}
+
+
+# @router.get("/file/minio/{file_name}")
+# async def download_file(file_name:str):
+#     if not minio_client.bucket_exists("file1"):
+#         return {"msg":"The bucket not exist","status":404}
+#     data =  minio_client.get_object("file1",file_name)
+#     content = data.read()
+#     with open(r"D:\pythonProject\django\fastapi_01\static\file\{}".format(file_name),"wb") as fp:
+#         # for d in data.stream(32 * 1024):
+#         #     file_data.write(d)
+#         fp.write(content)
+#     return {"msg":"下载图片成功！","status":200}
+
+# 响应式下载
+
+
+# 图片预览
+# response = StreamingResponse(file_content,media_type='image/jpg)
+
+# 图片下载功能
+@router.get("/file/{uid}")
+async def download_file(uid: str):
+    try:
+        file_obj = minio_client.get_object("file1", uid)
+        file_content = BytesIO(file_obj.read())
+        # response = StreamingResponse(file_content,
+        #                              media_type='application/octet-stream',
+        #                              headers={"Content-Disposition": f"attachment; filename={uid}"})
+        response = StreamingResponse(file_content, media_type='image/png')
+    except Exception as e:
+        return {"error": str(e)}
+    return response
+
+# 删除
+@router.delete("/file/{uid}")
+async def delete_file(uid: str):
+    try:
+        minio_client.get_object("file1", uid)
+        minio_client.remove_object("file1", uid)
+        return {"msg": "删除图片成功！", "status": 204}
+    except:
+        return {"msg": "Not Found", "status": 404}
+
+# test
+# @router.get("/file/response")
+# async def file():
+#     return FileResponse(r'D:\pythonProject\django\fastapi_01\static\file\wallhaven-6d5k6x.jpg', filename='demo.jpg')

routers/items.py

@@ -0,0 +1,54 @@
+"""
+    encoding: UTF-8
+    @author:clx
+    @file:items.py
+    @time:2023/5/30 6:08
+"""
+from typing import Dict
+
+from fastapi import APIRouter, HTTPException
+from models.model import Item
+
+router = APIRouter()
+
+res = [
+    {"id": 1, "name": "jack"},
+    {"id": 2, "name": "mark"},
+    {"id": 3, "name": "tom"},
+    {"id": 4, "name": "sery"}
+]
+
+@router.get("/item/res")
+async def get_res():
+    return res
+
+@router.get("/item/res/{res_id}")
+async def get_res_id(res_id:int):
+    for data in res:
+        if data["id"] == res_id:
+            return data
+
+@router.post("/item/res")
+async def create_res(item:Item):
+    res.append(item.dict())
+    return res
+
+@router.put("/item/res/{res_id}")
+async def update_res(res_id:int,item:Item):
+    for data in res:
+        print(data["id"])
+        print(res_id)
+        if data["id"] == res_id:
+            res.remove(data)
+            data = item.dict()
+            res.append(data)
+            return {"status":True}
+    else:
+        return HTTPException(status_code=404, detail="id:{} not found.".format(res_id))
+
+@router.delete("/item/res/{res_id}")
+async def delete_res(res_id:int):
+    for data in res:
+        if data["id"] == res_id:
+            res.remove(data)
+    return {"status":True}

test_main.http

@@ -0,0 +1,11 @@
+# Test your FastAPI endpoints
+
+GET http://127.0.0.1:8000/
+Accept: application/json
+
+###
+
+GET http://127.0.0.1:8000/hello/User
+Accept: application/json
+
+###