publicdata/j40-cejst-2
1
0
Fork 0
mirror of https://github.com/DOI-DO/j40-cejst-2.git synced 2025-08-03 09:24:19 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

updating with tract area

Browse source
This commit is contained in:
Emma Nechamkin 2022-10-13 12:20:21 -04:00
commit 74bf4979f8
2 changed files with 17 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

12
data/data-pipeline/data_pipeline/etl/sources/geocorr_alternatives/etl.py
View file

@ -49,6 +49,7 @@ class GeoCorrAlternativesETL(ExtractTransformLoad):
ZIP_CODE_INPUT_FIELD = "ZCTA5CE20"
AREA_JOINED_FIELD = "area_joined"
AREA_ZIP_FIELD = "area_zip"
TRACT_AREA = "area_tract"
def __init__(self):
self.COLUMNS_TO_KEEP = [
@ -118,4 +119,15 @@ class GeoCorrAlternativesETL(ExtractTransformLoad):
joined_gdf[self.AREA_JOINED_FIELD] / joined_gdf[self.AREA_ZIP_FIELD]
)
# Calculating "size of tract" that is relevant, e.g., the sum of all overlapping
# area between the tract and the zip
joined_gdf[self.TRACT_AREA] = joined_gdf.groupby(
field_names.GEOID_TRACT_FIELD
)[self.AREA_JOINED_FIELD].transform(sum)
# Calculating share of tract in the zipcode (ordered at tract, zip level)
joined_gdf[field_names.PERCENT_OF_TRACT_IN_ZIP] = (
joined_gdf[self.AREA_JOINED_FIELD] / joined_gdf[self.TRACT_AREA]
)
self.output_df = joined_gdf