Add sync_interval to cfg for sync between sqlite and postgres
This commit is contained in:
@@ -123,6 +123,10 @@ class PostgreSQLConfig(BaseModel):
|
|||||||
default=10,
|
default=10,
|
||||||
description="Таймаут подключения (секунды)"
|
description="Таймаут подключения (секунды)"
|
||||||
)
|
)
|
||||||
|
sync_interval: float = Field(
|
||||||
|
default=30.0,
|
||||||
|
description="Интервал синхронизации из SQLite в PostgreSQL (секунды)"
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
class LoggingConfig(BaseModel):
|
class LoggingConfig(BaseModel):
|
||||||
|
|||||||
@@ -84,7 +84,7 @@ class PostgreSQLClient:
|
|||||||
# Флаг для запуска синхронизации после восстановления соединения
|
# Флаг для запуска синхронизации после восстановления соединения
|
||||||
self._needs_sync = True
|
self._needs_sync = True
|
||||||
self._last_sync_time = 0.0
|
self._last_sync_time = 0.0
|
||||||
self._sync_interval = 30.0 # Интервал синхронизации в секундах
|
self._sync_interval = self.config.sync_interval
|
||||||
|
|
||||||
if not POSTGRESQL_AVAILABLE:
|
if not POSTGRESQL_AVAILABLE:
|
||||||
self.logger.error("PostgreSQL client library not available")
|
self.logger.error("PostgreSQL client library not available")
|
||||||
|
|||||||
Reference in New Issue
Block a user