Function load_collection

src/couchdb/loader.py:279–294

Load one collection's data into a database named after the key. Returns (db, n).

(key, source, drop=True, base_dir=None)

# Public entry point
# --------------------------------------------------------------------------- #
def load_collection(key, source, drop=True, base_dir=None) -> tuple:
    """Load one collection's data into a database named after the key. Returns (db, n)."""
    cfg = collection_config(key)
    transform = _transform_for(key)
    docs = [
        _normalise(d, key, cfg, transform)
        for d in _collect_docs(key, source, cfg, base_dir)
    ]
    db = key
    if docs:
        _ensure_db(db, drop=drop)
        if cfg.get("design_doc"):
            _install_design(db, cfg["design_doc"])
        _bulk_insert(db, docs)
        _create_indexes(db, cfg.get("indexes"))
    return db, len(docs)