junte/survey-extraction
1
0
Fork 0
mirror of https://github.com/Hestia-Homes/survey-extraction.git synced 2026-06-08 11:17:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

kevin changed stone water

Browse source
This commit is contained in:
Jun-te Kim 2025-09-22 09:26:30 +00:00
parent 7a36202a80
commit 54a4d5761a
2 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
deployment/lambda/walthamforest_etl/docker/app.py
View file

@ -235,6 +235,7 @@ def handler(event, context):
for house in houses:
print(house["UPRN"])
json_uri = upload_json_to_s3(house, generate_file_uri(house["UPRN"]))
# read data for flats
assets = process_complex("Chingford Rd 236-256 Properties")
simple = process_complex("CHINGFORD ROAD 236-254 Asset Bl", "BLOCK_CODE")
@ -247,8 +248,11 @@ def handler(event, context):
house.update({"UPRN": uprn_mapping[pseudo_name.upper()]})
with open("flat.json", "w") as f:
json.dump(houses[0], f, indent=2, ensure_ascii=False, default=_json_default)
for house in flats:
print(house["UPRN"])
json_uri = upload_json_to_s3(house, generate_file_uri(house["UPRN"]))
# with open("flat.json", "w") as f:
# json.dump(houses[0], f, indent=2, ensure_ascii=False, default=_json_default)

4
etl/month_end_automation_wave_2_no_4.py
View file

@ -173,7 +173,7 @@ filtered_dfs.append(_)
# POST EPC
post_epc = df[
df["post epc"].str.lower().isin(["completed & uploaded"])
df["post epc/epr"].str.lower().isin(["completed & uploaded"])
].copy()
post_epc["job_type"] = "POST EPC"
filtered_dfs.append(post_epc)
@ -181,7 +181,7 @@ filtered_dfs.append(post_epc)
# POST EPR
post_epr = df[
df["post epc"].str.lower().isin(["post epr completed"])
df["post epc/epr"].str.lower().isin(["post epr completed"])
].copy()
post_epr["job_type"] = "POST EPR"
filtered_dfs.append(post_epr)