taolib.testing.data_sync.services.metrics_service#

同步指标服务。

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

Attributes#

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

返回:

失败统计字典