[athena] fixing logger format string and using lambda alias for invoc…

…ation (#810)
airbnb · Aug 21, 2018 · 5811030 · 5811030
1 parent b0612e5
commit 5811030
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/stream_alert/athena_partition_refresh/main.py b/stream_alert/athena_partition_refresh/main.py
@@ -175,7 +175,7 @@ def run(self, event):
             )
 
         for sqs_rec in event['Records']:
-            LOGGER.debug('Processing event with message ID \'%s\' and SentTimestamp %d',
+            LOGGER.debug('Processing event with message ID \'%s\' and SentTimestamp %s',
                          sqs_rec['messageId'],
                          sqs_rec['attributes']['SentTimestamp'])
 

diff --git a/terraform/modules/tf_stream_alert_athena/main.tf b/terraform/modules/tf_stream_alert_athena/main.tf
@@ -99,7 +99,7 @@ resource "aws_sqs_queue_policy" "streamalert_athena_data_bucket_notifications" {
 
 resource "aws_lambda_event_source_mapping" "streamalert_athena_sqs_event_source" {
   event_source_arn = "${aws_sqs_queue.streamalert_athena_data_bucket_notifications.arn}"
-  function_name    = "${aws_lambda_function.athena_partition_refresh.arn}"
+  function_name    = "${aws_lambda_function.athena_partition_refresh.arn}:${aws_lambda_alias.athena_partition_refresh_production.name}"
 }
 
 // S3 Bucekt Notificaiton: Configure S3 to notify Lambda