def send()

in lambdas/custom_resources/CTE_CrossAccountCloudFormation/src/cfnresponse.py [0:0]

• 28 lines of code
• 7 McCabe index (conditional complexity)

def send(event, context, responseStatus, responseData, physicalResourceId=function_name, noEcho=False, reason=None):
    errors = [v for k, v in responseData.items() if 'ERROR' in k]
    if errors:
        reason = f'[CloudWatch Log Stream: {context.log_stream_name}] {errors}'

    responseUrl = event['ResponseURL']

    print(responseUrl)

    responseBody = {
        'Status': responseStatus,
        'Reason': reason or "See the details in CloudWatch Log Stream: {}".format(context.log_stream_name),
        'PhysicalResourceId': physicalResourceId or context.log_stream_name,
        'StackId': event['StackId'],
        'RequestId': event['RequestId'],
        'LogicalResourceId': event['LogicalResourceId'],
        'NoEcho': noEcho,
        'Data': responseData
    }

    json_responseBody = json.dumps(responseBody)

    print("Response body:")
    print(json_responseBody)

    headers = {
        'content-type' : '',
        'content-length' : str(len(json_responseBody))
    }

    try:
        response = http.request('PUT', responseUrl, headers=headers, body=json_responseBody)
        print("Status code:", response.status)


    except Exception as e:

        print("send(..) failed executing http.request(..):", e)