def create_subscriptions(config, profile_name):
if '<STR_LIT>' in config.subscription.keys():<EOL><INDENT>data = config.subscription['<STR_LIT>']<EOL>function_name = config.name<EOL>stream_name = data['<STR_LIT>']<EOL>batch_size = data['<STR_LIT>']<EOL>starting_position = data['<STR_LIT>']<EOL>starting_position_ts = None<EOL>if starting_position == '<STR_LIT>':<EOL><INDENT>ts = data.get('<STR_LIT>')<EOL>starting_position_ts = datetime.strptime(ts, '<STR_LIT>')<EOL><DEDENT>s = KinesisSubscriber(config, profile_name,<EOL>function_name, stream_name, batch_size,<EOL>starting_position,<EOL>starting_position_ts=starting_position_ts)<EOL>s.subscribe()<EOL><DEDENT>
Adds supported subscriptions