DELTA_TTF in terraform

Author: JamesW1-NHS

delta_backend/src/delta.py

@@ -17,6 +17,7 @@
 failure_queue_url = os.environ["AWS_SQS_QUEUE_URL"]
 delta_table_name = os.environ["DELTA_TABLE_NAME"]
 delta_source = os.environ["SOURCE"]
+delta_ttl = os.environ["DELTA_TTL"]
 region_name = "eu-west-2"
 logging.basicConfig()
 logger = logging.getLogger()
@@ -73,7 +74,7 @@ def get_imms_id(primary_key: str) -> str:
 
 def get_creation_and_expiry_times(creation_timestamp: float) -> (str, int):
     creation_datetime = datetime.fromtimestamp(creation_timestamp, UTC)
-    expiry_datetime = creation_datetime + timedelta(days=30)
+    expiry_datetime = creation_datetime + timedelta(days=int(delta_ttl))
     expiry_timestamp = int(expiry_datetime.timestamp())
     return creation_datetime.isoformat(), expiry_timestamp
 

terraform/delta.tf

@@ -138,6 +138,7 @@ resource "aws_lambda_function" "delta_sync_lambda" {
   environment {
     variables = {
       DELTA_TABLE_NAME     = aws_dynamodb_table.delta-dynamodb-table.name
+      DELTA_TTL            = 30
       AWS_SQS_QUEUE_URL    = aws_sqs_queue.dlq.id
       SOURCE               = "IEDS"
       SPLUNK_FIREHOSE_NAME = module.splunk.firehose_stream_name