stoffelmauro
/
ConsultancyProject_2_ETL
1
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

strict=False hinzugefügt wie in der Fehlermeldung vorgeschlagen

main
mmaurostoffel 2025-01-12 11:20:39 +01:00
parent 99a112df24
commit f114eb7f5a
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
etl/src/data/etl_property_capacities.py
View File

@ -35,5 +35,4 @@ def property_capacities(id: int):
max_capacity_perc = 100 / max_capacity max_capacity_perc = 100 / max_capacity
result['capacities'].append(round(max_capacity_perc * row['sum'], 2)) result['capacities'].append(round(max_capacity_perc * row['sum'], 2))
result['capacities'].reverse() result['capacities'].reverse()
return result return result

2
etl/src/data/etl_region_capacities.py
View File

@ -33,7 +33,7 @@ def region_capacities(id: int):
gridData.append([row['ScrapeDate'], sum_hor, calDF.width]) gridData.append([row['ScrapeDate'], sum_hor, calDF.width])
# Create Aggregates of values # Create Aggregates of values
df = pl.DataFrame(gridData) df = pl.DataFrame(gridData, strict=False)
df_count = df.group_by("column_0").agg(pl.col("column_1").count()) df_count = df.group_by("column_0").agg(pl.col("column_1").count())
df_sum = df.group_by("column_0").agg(pl.col("column_1").sum()) df_sum = df.group_by("column_0").agg(pl.col("column_1").sum())
df_numDays = df.group_by("column_0").agg(pl.col("column_2").max()) df_numDays = df.group_by("column_0").agg(pl.col("column_2").max())