Compare commits

..

5 Commits

Author SHA1 Message Date
6d0d742feb Merge pull request 'fix' (#12) from master into prod
Reviewed-on: #12
2024-11-24 21:06:18 +03:00
acc9a15a0a Merge pull request 'master' (#10) from master into prod
Reviewed-on: #10
2024-11-24 18:21:28 +03:00
b3037b357e Merge pull request 'fix' (#7) from master into prod
Reviewed-on: #7
2024-11-24 12:13:06 +03:00
5a263f169e Merge pull request 'fix' (#5) from master into prod
Reviewed-on: #5
2024-11-24 11:54:52 +03:00
43c6aad665 Merge pull request 'master' (#3) from master into prod
Reviewed-on: #3
2024-11-24 11:32:12 +03:00
9 changed files with 3 additions and 54 deletions

View File

@@ -6,7 +6,6 @@ services:
image: mathwave/sprint-repo:configurator
networks:
- configurator-development
- monitoring
environment:
MONGO_HOST: "mongo.develop.sprinthub.ru"
MONGO_PASSWORD: $MONGO_PASSWORD_DEV
@@ -21,5 +20,3 @@ services:
networks:
configurator-development:
external: true
monitoring:
external: true

View File

@@ -6,7 +6,6 @@ services:
image: mathwave/sprint-repo:configurator
networks:
- configurator
- monitoring
environment:
MONGO_HOST: "mongo.sprinthub.ru"
MONGO_PASSWORD: $MONGO_PASSWORD_PROD
@@ -21,5 +20,3 @@ services:
networks:
configurator:
external: true
monitoring:
external: true

View File

@@ -1,14 +0,0 @@
import datetime
import zoneinfo
from fastapi import Request, Response
from starlette.middleware.base import BaseHTTPMiddleware
from app.utils.monitoring import monitoring
class MetricsMiddleware(BaseHTTPMiddleware):
async def dispatch(self, request: Request, call_next):
start = datetime.datetime.now(zoneinfo.ZoneInfo("Europe/Moscow"))
response: Response = await call_next(request)
end = datetime.datetime.now(zoneinfo.ZoneInfo("Europe/Moscow"))
monitoring.send_metric(start, end, request.url.path, response.status_code, request.method)
return response

View File

@@ -1,4 +1,3 @@
import bson
import fastapi
import pydantic
@@ -38,14 +37,14 @@ async def post(body: RequestPostBody):
@router.put('/api/v1/experiments', status_code=fastapi.status.HTTP_202_ACCEPTED, responses={404: {'description': 'Not found'}})
async def put(body: RequestPutBody):
changed = await experiments.update(id=bson.ObjectId(body.id), enabled=body.enabled, condition=body.condition)
changed = await experiments.update(id=body.id, enabled=body.enabled, condition=body.condition)
if not changed:
raise fastapi.HTTPException(404)
@router.delete('/api/v1/experiments', status_code=fastapi.status.HTTP_202_ACCEPTED, responses={404: {'description': 'Not found'}})
async def delete(body: RequestDeleteBody):
changed = await experiments.delete(id=bson.ObjectId(body.id))
changed = await experiments.delete(id=body.id)
if not changed:
raise fastapi.HTTPException(404)

View File

@@ -20,7 +20,7 @@ class PlatformStaff(pydantic.BaseModel):
class ResponseBody(pydantic.BaseModel):
configs: dict[str, dict|list]
configs: dict[str, dict]
experiments: dict[str, ExperimentData]
platform_staff: PlatformStaff

View File

@@ -1,24 +0,0 @@
from concurrent.futures import ThreadPoolExecutor
import datetime
import requests
class Monitroing:
def __init__(self):
self.executor = ThreadPoolExecutor(max_workers=1)
def send_metric(self, start: datetime.datetime, end: datetime.datetime, endpoint: str, status_code: int, method: str):
def send():
requests.post(f'http://monitoring:1237/api/v1/metrics/endpoint', json={
'timestamp': start.strftime("%Y-%m-%dT%H:%M:%S") + "Z",
'service': 'configurator',
'endpoint': endpoint,
'status_code': status_code,
'response_time': (end - start).microseconds // 1000,
'method': method,
})
self.executor.submit(send)
monitoring = Monitroing()

View File

@@ -1,7 +1,6 @@
import fastapi
import uvicorn
from app.middlewares.metrics import MetricsMiddleware
from app.routers import experiments
from app.routers import configs
from app.routers import staff
@@ -11,7 +10,6 @@ from app.storage import mongo
app = fastapi.FastAPI()
app.add_middleware(MetricsMiddleware)
app.include_router(experiments.router)
app.include_router(configs.router)

View File

@@ -1,8 +1,6 @@
annotated-types==0.7.0
anyio==4.6.2.post1
APScheduler==3.10.4
certifi==2025.6.15
charset-normalizer==3.4.2
click==8.1.7
dnspython==2.7.0
fastapi==0.115.4
@@ -14,11 +12,9 @@ pydantic_core==2.23.4
pymongo==4.9.2
pytz==2024.2
redis==5.2.0
requests==2.32.4
six==1.16.0
sniffio==1.3.1
starlette==0.41.2
typing_extensions==4.12.2
tzlocal==5.2
urllib3==2.4.0
uvicorn==0.32.0