pudl.transform.eia930#

Module to perform data cleaning functions on EIA930 data tables.

Attributes#

logger

Functions#

`_transform_netgen_by_source`(→ pudl.helpers.ParquetData)	Transform the eia930 netgen by source table.
`_transform_hourly_operations`(→ pudl.helpers.ParquetData)	Transform the eia930 hourly operations table.
`core_eia930__hourly_operations_assets`(raw_eia930__balance)	Separate raw_eia930__balance into net generation and demand tables.
`core_eia930__hourly_subregion_demand`(raw_eia930__subregion)	Produce a normalized table of hourly electricity demand by BA subregion.
`core_eia930__hourly_interchange`(raw_eia930__interchange)	Produce a normalized table of hourly interchange by balancing authority.

Module Contents#

pudl.transform.eia930.logger[source]#

pudl.transform.eia930._transform_netgen_by_source(table: duckdb.DuckDBPyRelation, conn: duckdb.DuckDBPyConnection) → pudl.helpers.ParquetData[source]#: Transform the eia930 netgen by source table.

pudl.transform.eia930._transform_hourly_operations(table: duckdb.DuckDBPyRelation, conn: duckdb.DuckDBPyConnection) → pudl.helpers.ParquetData[source]#: Transform the eia930 hourly operations table.

pudl.transform.eia930.core_eia930__hourly_operations_assets(raw_eia930__balance: pudl.helpers.ParquetData)[source]#

Separate raw_eia930__balance into net generation and demand tables.

Energy source starts out in the column names, but is stacked into a categorical column. For structural purposes “interchange” is also treated as an “energy source” and stacked into the same column. For the moment “total” (sum of all energy sources) is also included, because the reported and calculated totals across all energy sources have significant differences which should be further explored.

pudl.transform.eia930.core_eia930__hourly_subregion_demand(raw_eia930__subregion: pudl.helpers.ParquetData)[source]#: Produce a normalized table of hourly electricity demand by BA subregion.

pudl.transform.eia930.core_eia930__hourly_interchange(raw_eia930__interchange: pudl.helpers.ParquetData)[source]#: Produce a normalized table of hourly interchange by balancing authority.