From 88b6737809121d4564f048603b7e484877400c2c Mon Sep 17 00:00:00 2001 From: Will Freeman Date: Tue, 24 Dec 2024 11:03:28 -0800 Subject: [PATCH] use slash as delimiter to match url scheme, drop Lambda memory --- serverless/alpr_clusters/src/alpr_clusters.py | 4 ++-- terraform/modules/alpr_clusters/main.tf | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/serverless/alpr_clusters/src/alpr_clusters.py b/serverless/alpr_clusters/src/alpr_clusters.py index b020ab2..28a5572 100644 --- a/serverless/alpr_clusters/src/alpr_clusters.py +++ b/serverless/alpr_clusters/src/alpr_clusters.py @@ -98,7 +98,7 @@ def segment_regions(nodes: Any, tile_size_degrees: int) -> dict[Any]: lat, lon = node["lat"], node["lon"] tile_lat = int(np.floor(lat / tile_size_degrees)) * tile_size_degrees tile_lon = int(np.floor(lon / tile_size_degrees)) * tile_size_degrees - tile_dict[f"{tile_lat},{tile_lon}"].append(node) + tile_dict[f"{tile_lat}/{tile_lon}"].append(node) print("Region segmentation complete.") return tile_dict @@ -145,7 +145,7 @@ def lambda_handler(event, context): with ThreadPoolExecutor(max_workers=10) as executor: futures = [] for latlng_string, elements in regions_dict.items(): - lat, lon = latlng_string.split(",") + lat, lon = latlng_string.split("/") key = f"regions/{lat}/{lon}.json" body = json.dumps(elements) futures.append(executor.submit(upload_json_to_s3, bucket_new, key, body)) diff --git a/terraform/modules/alpr_clusters/main.tf b/terraform/modules/alpr_clusters/main.tf index 45d7fa5..fc3e989 100644 --- a/terraform/modules/alpr_clusters/main.tf +++ b/terraform/modules/alpr_clusters/main.tf @@ -53,7 +53,7 @@ resource "aws_lambda_function" "overpass_lambda" { package_type = "Image" image_uri = "${aws_ecr_repository.lambda_repository.repository_url}:latest" timeout = 180 - memory_size = 1024 + memory_size = 512 environment { variables = { UPDATE_RATE_MINS = var.rate