kde_cpi.data.loader module¶

Async PostgreSQL integration for CPI datasets.

class kde_cpi.data.loader.CpiDatabaseLoader(dsn=None, schema='public', connection_kwargs=NOTHING)[source]¶

Persist CPI datasets into PostgreSQL using asyncpg primitives.

Parameters:

async bulk_load(dataset, *, truncate=True)[source]¶

Copy the full dataset into PostgreSQL, optionally truncating first.

Return type:

None

Parameters:

async close()[source]¶

Close the open connection, if any.

async connect(**overrides)[source]¶

Establish (or reuse) the async connection.

async ensure_schema()[source]¶

Create the CPI tables if they do not already exist.

async fetch_dataset()[source]¶

Reconstruct a Dataset from the current database contents.

async merge_dataset(dataset)[source]¶

Synchronize metadata and upsert observations in place.

async sync_metadata(dataset)[source]¶

Upsert mapping tables and series definitions without touching observations.

async upsert_observations(observations)[source]¶

Upsert one or more observation rows.