更新が頻繁な文書を扱う ── 索引の鮮度をどう保つか

def reconcile_index(index_client, source_client, dry_run: bool = True):    """索引と元の文書一覧を突き合わせ、消えたものを索引から除く。"""    indexed_ids = set(index_client.list_all_ids())    source_ids = set(source_client.list_all_ids())
    to_delete = indexed_ids - source_ids       # 索引にあるが元に無い    to_add = source_ids - indexed_ids          # 元にあるが索引に無い
    print(f"  索引 {len(indexed_ids):,} 件 / 元 {len(source_ids):,} 件")    print(f"  削除すべき: {len(to_delete):,} 件")    print(f"  追加すべき: {len(to_add):,} 件")
    # 大量に消える場合は、元の取得が失敗している可能性を疑う    if to_delete and len(to_delete) > len(indexed_ids) * 0.1:        print("  ※ 削除対象が1割を超えています。元の取得を確認してください")        if dry_run is False:            raise RuntimeError("安全のため中断しました")
    if dry_run:        print("  （確認のみ。実行するには dry_run=False）")        return {"to_delete": to_delete, "to_add": to_add}
    for doc_id in to_delete:        index_client.delete(doc_id)    return {"deleted": len(to_delete), "to_add": to_add}

from datetime import datetime, timedelta, timezone

def check_freshness(index_client, source_client, threshold_hours=24):    """索引が元より古くなっている文書を見つける。"""    stale = []    now = datetime.now(timezone.utc)
    for doc in source_client.list_documents():        indexed = index_client.get_metadata(doc["id"])        if indexed is None:            stale.append((doc["id"], "索引に存在しない", None))            continue
        lag = doc["updated_at"] - indexed["indexed_at"]        if lag > timedelta(hours=threshold_hours):            stale.append((doc["id"], "索引が古い", lag))
    print(f"  確認 {source_client.count():,} 件 / 古い {len(stale):,} 件")    for doc_id, reason, lag in stale[:10]:        lag_str = f"{lag.total_seconds() / 3600:.1f}時間" if lag else "-"        print(f"    {doc_id}: {reason}（遅れ {lag_str}）")
    return stale