Mitch Garnaat

Added a few comments and removed redundant timestamp when printing log events.

...@@ -154,9 +154,11 @@ class Kappa(object): ...@@ -154,9 +154,11 @@ class Kappa(object):
154 def _tail(self, function_name): 154 def _tail(self, function_name):
155 LOG.debug('tailing function: %s', function_name) 155 LOG.debug('tailing function: %s', function_name)
156 log_svc = self.session.create_client('logs', self.region) 156 log_svc = self.session.create_client('logs', self.region)
157 + # kinda kludgy but can't find any way to get log group name
157 log_group_name = '/aws/lambda/%s' % function_name 158 log_group_name = '/aws/lambda/%s' % function_name
158 latest_stream = None 159 latest_stream = None
159 response = log_svc.describe_log_streams(logGroupName=log_group_name) 160 response = log_svc.describe_log_streams(logGroupName=log_group_name)
161 + # The streams are not ordered by time, hence this ugliness
160 for stream in response['logStreams']: 162 for stream in response['logStreams']:
161 if not latest_stream: 163 if not latest_stream:
162 latest_stream = stream 164 latest_stream = stream
...@@ -166,7 +168,7 @@ class Kappa(object): ...@@ -166,7 +168,7 @@ class Kappa(object):
166 logGroupName=log_group_name, 168 logGroupName=log_group_name,
167 logStreamName=latest_stream['logStreamName']) 169 logStreamName=latest_stream['logStreamName'])
168 for log_event in response['events']: 170 for log_event in response['events']:
169 - print('%s: %s' % (log_event['timestamp'], log_event['message'])) 171 + print(log_event['message'])
170 172
171 def add_event_source(self): 173 def add_event_source(self):
172 lambda_svc = self.session.create_client('lambda', self.region) 174 lambda_svc = self.session.create_client('lambda', self.region)
......