taolib.testing.data_sync.models.log

同步日志数据模型。

定义 SyncLog 的 4-tier Pydantic 模型（执行记录）。

Classes

SyncMetrics	同步指标。
SyncLogBase	同步日志基础字段。
SyncLogCreate	创建同步日志的输入模型。
SyncLogResponse	同步日志的 API 响应模型。
SyncLogDocument	同步日志的 MongoDB 文档模型。

Module Contents

class taolib.testing.data_sync.models.log.SyncMetrics

Bases: pydantic.BaseModel

同步指标。

total_extracted: int = 0

total_transformed: int = 0

total_loaded: int = 0

total_skipped: int = 0

total_failed: int = 0

bytes_transferred: int = 0

class taolib.testing.data_sync.models.log.SyncLogBase

Bases: pydantic.BaseModel

同步日志基础字段。

job_id: str

job_name: str

status: taolib.testing.data_sync.models.enums.SyncStatus

mode: taolib.testing.data_sync.models.enums.SyncMode

started_at: datetime.datetime

finished_at: datetime.datetime | None = None

duration_seconds: float | None = None

source_database: str

target_database: str

collections_synced: list[str]

metrics: SyncMetrics

error_message: str | None = None

checkpoint_snapshot: dict[str, Any] | None = None

class taolib.testing.data_sync.models.log.SyncLogCreate

Bases: SyncLogBase

创建同步日志的输入模型。

class taolib.testing.data_sync.models.log.SyncLogResponse

Bases: SyncLogBase

同步日志的 API 响应模型。

id: str

model_config

class taolib.testing.data_sync.models.log.SyncLogDocument

Bases: SyncLogBase

同步日志的 MongoDB 文档模型。

id: str

model_config

to_response() → SyncLogResponse

转换为 API 响应。