taolib.testing.data_sync.repository.failure_repo

同步失败记录 Repository。

提供 FailureRecord 的 MongoDB 持久化操作。

Classes

FailureRecordRepository

同步失败记录 Repository。

Module Contents

class taolib.testing.data_sync.repository.failure_repo.FailureRecordRepository(collection: motor.motor_asyncio.AsyncIOMotorCollection)

Bases: taolib.testing._base.repository.AsyncRepository[taolib.testing.data_sync.models.failure.FailureRecordDocument]

同步失败记录 Repository。

async bulk_create(records: list[dict]) → int

批量创建失败记录。

参数:

records -- 失败记录数据列表

返回:

创建的记录数量

async find_by_log(log_id: str, skip: int = 0, limit: int = 100) → list[taolib.testing.data_sync.models.failure.FailureRecordDocument]

查找指定日志的失败记录。

参数:

• log_id -- 日志 ID

• skip -- 跳过记录数

• limit -- 限制记录数

返回:

失败记录文档列表

async count_by_job(job_id: str) → int

统计指定作业的失败数量。

参数:

job_id -- 作业 ID

返回:

失败记录数量

async create_indexes() → None

创建索引。