bjoern/pypsa-eur
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

retrieve electricity demand: make online version snakemake params

Browse Source
This commit is contained in:
Fabian 2023-08-16 11:47:27 +02:00
parent 9cd449cf3c
commit 32eb114b61
3 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
rules/retrieve.smk
View File

@ -156,6 +156,8 @@ if config["enable"]["retrieve"] and (
if config["enable"]["retrieve"]: if config["enable"]["retrieve"]:
rule retrieve_electricity_demand: rule retrieve_electricity_demand:
params:
versions=["2019-06-05", "2020-10-06"],
output: output:
"data/load_raw.csv", "data/load_raw.csv",
log: log:

4
scripts/build_industrial_distribution_key.py
View File

@ -116,7 +116,7 @@ def build_nodal_distribution_key(hotmaps, regions, countries):
if not facilities.empty: if not facilities.empty:
emissions = facilities["Emissions_ETS_2014"].fillna( emissions = facilities["Emissions_ETS_2014"].fillna(
hotmaps["Emissions_EPRTR_2014"] hotmaps["Emissions_EPRTR_2014"].dropna()
) )
if emissions.sum() == 0: if emissions.sum() == 0:
key = pd.Series(1 / len(facilities), facilities.index) key = pd.Series(1 / len(facilities), facilities.index)
@ -140,7 +140,7 @@ if __name__ == "__main__":
snakemake = mock_snakemake( snakemake = mock_snakemake(
"build_industrial_distribution_key", "build_industrial_distribution_key",
simpl="", simpl="",
clusters=48, clusters=128,
) )
logging.basicConfig(level=snakemake.config["logging"]["level"]) logging.basicConfig(level=snakemake.config["logging"]["level"])

4
scripts/retrieve_electricity_demand.py
View File

@ -27,11 +27,11 @@ if __name__ == "__main__":
configure_logging(snakemake) configure_logging(snakemake)
set_scenario_config(snakemake) set_scenario_config(snakemake)
versions = ["2019-06-05", "2020-10-06"]
url = "https://data.open-power-system-data.org/time_series/{version}/time_series_60min_singleindex.csv" url = "https://data.open-power-system-data.org/time_series/{version}/time_series_60min_singleindex.csv"
df1, df2 = [ df1, df2 = [
pd.read_csv(url.format(version=version), index_col=0) for version in versions pd.read_csv(url.format(version=version), index_col=0)
for version in snakemake.params.versions
] ]
res = pd.concat([df1, df2[df2.index > df1.index[-1]]], join="inner") res = pd.concat([df1, df2[df2.index > df1.index[-1]]], join="inner")
res.to_csv(snakemake.output[0]) res.to_csv(snakemake.output[0])