Yasuke/moto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Code improvements

Browse Source
This commit is contained in:
Bert Blommers 2019-10-08 14:11:21 +01:00
parent 91b13f998f
commit 2d11e8feb4
1 changed files with 10 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
moto/awslambda/models.py
View File

@ -694,18 +694,15 @@ class LambdaBackend(BaseBackend):
queue.lambda_event_source_mappings[esm.function_arn] = esm queue.lambda_event_source_mappings[esm.function_arn] = esm
return esm return esm
try: for stream in json.loads(dynamodbstreams_backends[self.region_name].list_streams())['Streams']:
stream = json.loads(dynamodbstreams_backends[self.region_name].describe_stream(spec['EventSourceArn'])) if stream['StreamArn'] == spec['EventSourceArn']:
spec.update({'FunctionArn': func.function_arn}) spec.update({'FunctionArn': func.function_arn})
esm = EventSourceMapping(spec) esm = EventSourceMapping(spec)
self._event_source_mappings[esm.uuid] = esm self._event_source_mappings[esm.uuid] = esm
table_name = stream['StreamDescription']['TableName'] table_name = stream['TableName']
table = dynamodb_backends2[self.region_name].get_table(table_name) table = dynamodb_backends2[self.region_name].get_table(table_name)
table.lambda_event_source_mappings[esm.function_arn] = esm table.lambda_event_source_mappings[esm.function_arn] = esm
return esm
return esm
except Exception:
pass # No DynamoDB stream exists
raise RESTError('ResourceNotFoundException', 'Invalid EventSourceArn') raise RESTError('ResourceNotFoundException', 'Invalid EventSourceArn')
def publish_function(self, function_name): def publish_function(self, function_name):
@ -832,7 +829,7 @@ class LambdaBackend(BaseBackend):
'eventName': 'INSERT', 'eventName': 'INSERT',
'eventVersion': item.to_json()['eventVersion'], 'eventVersion': item.to_json()['eventVersion'],
'eventSource': item.to_json()['eventSource'], 'eventSource': item.to_json()['eventSource'],
'awsRegion': 'us-east-1', 'awsRegion': self.region_name,
'dynamodb': item.to_json()['dynamodb'], 'dynamodb': item.to_json()['dynamodb'],
'eventSourceARN': source} for item in items]} 'eventSourceARN': source} for item in items]}
func = self._lambdas.get_arn(function_arn) func = self._lambdas.get_arn(function_arn)