def main()

in social-media/create-lambda-function.py [0:0]


def main():
    # Create execution role
    create_role(lambda_execution_role, lambda_trust_policy, lambda_execution_policy)
    # Create Amazon Kinesis Stream
    create_stream(kinesis_stream)
    # Create Amazon SNS Topic
    print('Creating Amazon SNS topic: ' + sns_topic)
    sns.create_topic(sns_topic)
    # Create and upload AWS Lambda function
    create_lambda_function(lambda_function_name)
    # Create realtime endpoint for the ml model
    ml.create_realtime_endpoint(config.AWS['mlModelId'])
    # Wait for kinesis
    pause_until_kinesis_active()
    # Wait for 5 seconds
    sleep(5)
    # Connect Kinesis with Lambda
    add_kinesis_as_source_to_lambda()
    print('Kinesis stream is active now. You can start calling it.')