Kintone app build backend created

This commit is contained in:
2023-07-10 13:13:43 +09:00
parent 80446a3860
commit 081be5f35b
5 changed files with 48 additions and 22 deletions

Binary file not shown.

View File

@@ -0,0 +1,23 @@
from fastapi import APIRouter, UploadFile,HTTPException,File
from io import BytesIO
import typing as t
import pandas as pd
kinton_router = r = APIRouter()
@r.post("/upload",)
async def upload(files:t.List[UploadFile] = File(...)):
dataframes = []
for file in files:
if file.filename.endswith('.xlsx'):
try:
content = await file.read()
df = pd.read_excel(BytesIO(content))
dataframes.append(df)
except Exception as e:
raise HTTPException(status_code=400, detail=f"Error occurred while parsing file {file.filename}: {str(e)}")
else:
raise HTTPException(status_code=400, detail=f"File {file.filename} is not an Excel file")
return {"files": [file.filename for file in files]}

View File

@@ -1,12 +1,12 @@
from fastapi import FastAPI, Depends from fastapi import FastAPI, Depends
from starlette.requests import Request from starlette.requests import Request
import uvicorn import uvicorn
from app.api.api_v1.routers.kintone import kinton_router
from app.api.api_v1.routers.users import users_router # from app.api.api_v1.routers.users import users_router
from app.api.api_v1.routers.auth import auth_router # from app.api.api_v1.routers.auth import auth_router
from app.core import config from app.core import config
from app.db.session import SessionLocal # from app.db.session import SessionLocal
from app.core.auth import get_current_active_user # from app.core.auth import get_current_active_user
from app.core.celery_app import celery_app from app.core.celery_app import celery_app
from app import tasks from app import tasks
@@ -16,17 +16,17 @@ app = FastAPI(
) )
@app.middleware("http") # @app.middleware("http")
async def db_session_middleware(request: Request, call_next): # async def db_session_middleware(request: Request, call_next):
request.state.db = SessionLocal() # request.state.db = SessionLocal()
response = await call_next(request) # response = await call_next(request)
request.state.db.close() # request.state.db.close()
return response # return response
@app.get("/api/v1") @app.get("/api/v1")
async def root(): async def root():
return {"message": "Hello World"} return {"message": "success"}
@app.get("/api/v1/task") @app.get("/api/v1/task")
@@ -37,13 +37,14 @@ async def example_task():
# Routers # Routers
app.include_router( # app.include_router(
users_router, # users_router,
prefix="/api/v1", # prefix="/api/v1",
tags=["users"], # tags=["users"],
dependencies=[Depends(get_current_active_user)], # dependencies=[Depends(get_current_active_user)],
) # )
app.include_router(auth_router, prefix="/api", tags=["auth"]) # app.include_router(auth_router, prefix="/api", tags=["auth"])
app.include_router(kinton_router,prefix="/api/v1")
if __name__ == "__main__": if __name__ == "__main__":
uvicorn.run("main:app", host="0.0.0.0", reload=True, port=8888) uvicorn.run("main:app", host="0.0.0.0", reload=True, port=8888)

View File

@@ -7,7 +7,7 @@ httpx==0.15.5
ipython==7.31.1 ipython==7.31.1
itsdangerous==1.1.0 itsdangerous==1.1.0
Jinja2==2.11.3 Jinja2==2.11.3
psycopg2 #psycopg2
pytest==6.1.0 pytest==6.1.0
requests==2.24.0 requests==2.24.0
SQLAlchemy==1.3.19 SQLAlchemy==1.3.19
@@ -16,4 +16,6 @@ passlib==1.7.2
bcrypt==3.2.0 bcrypt==3.2.0
sqlalchemy-utils==0.36.8 sqlalchemy-utils==0.36.8
python-multipart==0.0.5 python-multipart==0.0.5
pyjwt==1.7.1 pyjwt==1.7.1
pandas==2.0.3
openpyxl==3.1.2

View File

@@ -1,2 +1,2 @@
KAB_BACKEND_URL="http://localhost:8000/api/" KAB_BACKEND_URL="http://127.0.0.1:8000/api/v1/upload"