Update and rename eras_forwarder.py

zooniverse · Aug 28, 2023 · 3c3173f · 3c3173f
1 parent 77b4f66
commit 3c3173f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kinesis-to-http/kinesis-forwarder-staging.py → kinesis-to-http/eras_forwarder.py b/kinesis-to-http/kinesis-forwarder-staging.py → 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"]]