taolib.testing.data_sync.services.metrics_service

同步指标服务。

提供聚合统计和监控数据查询。

Attributes

logger

Classes

MetricsService

同步指标服务。

Module Contents

taolib.testing.data_sync.services.metrics_service.logger

class taolib.testing.data_sync.services.metrics_service.MetricsService(log_repo: taolib.testing.data_sync.repository.log_repo.SyncLogRepository, failure_repo: taolib.testing.data_sync.repository.failure_repo.FailureRecordRepository, checkpoint_repo: taolib.testing.data_sync.repository.checkpoint_repo.CheckpointRepository | None = None)

同步指标服务。

_log_repo

_failure_repo

_checkpoint_repo = None

async get_job_summary(job_id: str) → dict[str, Any]

获取作业摘要。

参数:

job_id -- 作业 ID

返回:

作业摘要字典

async get_global_summary() → dict[str, Any]

获取全局摘要。

返回:

全局摘要字典

async get_failure_summary(job_id: str) → dict[str, Any]

获取失败统计。

参数:

job_id -- 作业 ID

返回:

失败统计字典