def lambda_handler()

in lambda-functions/kfpLambdaCustomMSKConfig.py [0:0]

• 16 lines of code
• 3 McCabe index (conditional complexity)

def lambda_handler(event, context):
    kafka = boto3.client("kafka")
    physical_id = "None"
    random_id = ''.join(random.choices(string.ascii_uppercase + string.digits, k=5))
    revision = 1
    if event["RequestType"] == "Create":
        config = kafka.create_configuration(Name=event["LogicalResourceId"] + "-" + random_id,
                                            ServerProperties=SERVER_PROPERTIES)
        physical_id = config["Arn"]
        revision = config["LatestRevision"]["Revision"]
    elif event["RequestType"] == "Delete":
        kafka.delete_configuration(Arn=event["PhysicalResourceId"])

    send(event, context, SUCCESS, {
        "Revision": revision,
        "Arn": physical_id
    }, physical_id)