From 3c3173f5425249a588dc8b776de5de66418e538e Mon Sep 17 00:00:00 2001 From: Zach Wolfenbarger Date: Mon, 28 Aug 2023 11:51:13 -0500 Subject: [PATCH] Update and rename eras_forwarder.py --- .../{kinesis-forwarder-staging.py => eras_forwarder.py} | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) rename kinesis-to-http/{kinesis-forwarder-staging.py => eras_forwarder.py} (92%) diff --git a/kinesis-to-http/kinesis-forwarder-staging.py b/kinesis-to-http/eras_forwarder.py similarity index 92% rename from kinesis-to-http/kinesis-forwarder-staging.py rename to kinesis-to-http/eras_forwarder.py index 7e96ad8..90ff196 100644 --- a/kinesis-to-http/kinesis-forwarder-staging.py +++ b/kinesis-to-http/eras_forwarder.py @@ -5,7 +5,7 @@ from requests.auth import HTTPBasicAuth HEADERS = {"Content-Type": "application/json", "Accept": "application/json"} -ENDPOINT = "https://eras-staging.zooniverse.org/kinesis" +ENDPOINT = os.environ["KINESIS_STREAM_ENDPOINT"] def lambda_handler(event, context): payloads = [json.loads(base64.b64decode(record["kinesis"]["data"])) for record in event["Records"]]