From 0d8a7f5cb7d6c7f3d4c877a9601c0d7610dcddc2 Mon Sep 17 00:00:00 2001 From: Jiang Date: Mon, 9 Mar 2026 18:10:14 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9B=AE=E5=BD=95=E9=87=8D=E5=91=BD=E5=90=8D?= =?UTF-8?q?=EF=BC=9Atimescaledb/schemas/=20=E2=86=92=20timescaledb/reposit?= =?UTF-8?q?ories/?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/infra/db/timescaledb/composite_queries.py | 6 +++--- app/infra/db/timescaledb/internal_queries.py | 6 +++--- app/infra/db/timescaledb/repositories/__init__.py | 0 .../db/timescaledb/{schemas => repositories}/realtime.py | 0 app/infra/db/timescaledb/{schemas => repositories}/scada.py | 0 .../db/timescaledb/{schemas => repositories}/scheme.py | 0 app/infra/db/timescaledb/router.py | 6 +++--- 7 files changed, 9 insertions(+), 9 deletions(-) create mode 100644 app/infra/db/timescaledb/repositories/__init__.py rename app/infra/db/timescaledb/{schemas => repositories}/realtime.py (100%) rename app/infra/db/timescaledb/{schemas => repositories}/scada.py (100%) rename app/infra/db/timescaledb/{schemas => repositories}/scheme.py (100%) diff --git a/app/infra/db/timescaledb/composite_queries.py b/app/infra/db/timescaledb/composite_queries.py index bfcee73..dcf6294 100644 --- a/app/infra/db/timescaledb/composite_queries.py +++ b/app/infra/db/timescaledb/composite_queries.py @@ -10,9 +10,9 @@ from app.algorithms.health.analyzer import PipelineHealthAnalyzer from app.infra.db.postgresql.internal_queries import InternalQueries from app.infra.db.postgresql.scada_info import ScadaRepository as PostgreScadaRepository -from app.infra.db.timescaledb.schemas.realtime import RealtimeRepository -from app.infra.db.timescaledb.schemas.scheme import SchemeRepository -from app.infra.db.timescaledb.schemas.scada import ScadaRepository +from app.infra.db.timescaledb.repositories.realtime import RealtimeRepository +from app.infra.db.timescaledb.repositories.scheme import SchemeRepository +from app.infra.db.timescaledb.repositories.scada import ScadaRepository class CompositeQueries: diff --git a/app/infra/db/timescaledb/internal_queries.py b/app/infra/db/timescaledb/internal_queries.py index ee12d1e..8c508ba 100644 --- a/app/infra/db/timescaledb/internal_queries.py +++ b/app/infra/db/timescaledb/internal_queries.py @@ -6,10 +6,10 @@ import psycopg from psycopg import sql from psycopg.rows import dict_row import time -from app.infra.db.timescaledb.schemas.scheme import SchemeRepository -from app.infra.db.timescaledb.schemas.realtime import RealtimeRepository +from app.infra.db.timescaledb.repositories.scheme import SchemeRepository +from app.infra.db.timescaledb.repositories.realtime import RealtimeRepository import app.infra.db.timescaledb.timescaledb_info as timescaledb_info -from app.infra.db.timescaledb.schemas.scada import ScadaRepository +from app.infra.db.timescaledb.repositories.scada import ScadaRepository class InternalStorage: diff --git a/app/infra/db/timescaledb/repositories/__init__.py b/app/infra/db/timescaledb/repositories/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/app/infra/db/timescaledb/schemas/realtime.py b/app/infra/db/timescaledb/repositories/realtime.py similarity index 100% rename from app/infra/db/timescaledb/schemas/realtime.py rename to app/infra/db/timescaledb/repositories/realtime.py diff --git a/app/infra/db/timescaledb/schemas/scada.py b/app/infra/db/timescaledb/repositories/scada.py similarity index 100% rename from app/infra/db/timescaledb/schemas/scada.py rename to app/infra/db/timescaledb/repositories/scada.py diff --git a/app/infra/db/timescaledb/schemas/scheme.py b/app/infra/db/timescaledb/repositories/scheme.py similarity index 100% rename from app/infra/db/timescaledb/schemas/scheme.py rename to app/infra/db/timescaledb/repositories/scheme.py diff --git a/app/infra/db/timescaledb/router.py b/app/infra/db/timescaledb/router.py index 74b4ec4..f7e80d7 100644 --- a/app/infra/db/timescaledb/router.py +++ b/app/infra/db/timescaledb/router.py @@ -3,9 +3,9 @@ from typing import List from datetime import datetime from psycopg import AsyncConnection -from .schemas.realtime import RealtimeRepository -from .schemas.scheme import SchemeRepository -from .schemas.scada import ScadaRepository +from .repositories.realtime import RealtimeRepository +from .repositories.scheme import SchemeRepository +from .repositories.scada import ScadaRepository from .composite_queries import CompositeQueries from app.auth.project_dependencies import ( get_project_pg_connection,