in sam-app/lambda_functions/sfExecuteAWSService.py [0:0]
def lambda_handler(event, context):
logger.info("event: %s" % json.dumps(event))
method = event["method"]
params = event["params"]
try:
result = ""
if method == "connect_create_instance":
result = connect_create_instance(**params)
elif method == "kinesis_create_stream":
result = kinesis_create_stream(**params)
elif method == "s3_create_bucket":
result = s3_create_bucket(**params)
elif method == "kinesis_describe_stream":
result = kinesis_describe_stream(**params)
elif method == "connect_associate_instance_storage_config":
result = connect_associate_instance_storage_config(**params)
elif method == "connect_associate_approved_origin":
result = connect_associate_approved_origin(**params)
elif method == "retrieve_lambda_parameters":
result = retrieve_lambda_parameters(**params)
elif method == "setup_audio_recording":
result = setup_audio_recording(**params)
elif method == "get_aws_region":
result = get_aws_region()
elif method == "generate_audio_recording_url":
result = generate_audio_recording_url(params)
else:
raise Exception("Invalid method: " + method)
return {
"success": True,
"body": json.dumps(result)
}
except Exception as e:
logger.error("error: %s" % e)
return {
"success": False,
"body": str(e)
}
return