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.')