init

python/main.py

@@ -1,17 +1,17 @@
 from fastapi import FastAPI
-from contextlib import asynccontextmanager
-from mqtt_client import client, mqtt_connect, mqtt_disconnect
-from logger import get_log
+from pydantic import BaseModel
+from pygments.lexer import default
 
-_log = get_log()
 
-@asynccontextmanager
-async def lifspan(app: FastAPI):
-    """
-    Application startup and shutdown events.
-    """
-    _log.info("Starting MQTT client...")
-    await mqtt_connect()
-    yield
-    _log.info("Stopping MQTT client...")
-    await mqtt_disconnect()
+class Item(BaseModel):
+    name: str
+    description: str = None
+    price: float
+    tax: float = None
+
+app = FastAPI()
+
+@app.get("/sensors/{sensor_id}")
+async def read_sensor(sensor_id: str):
+    sensor_message = {}
+    return {"sensor_id": sensor_id, "message": sensor_message}