def create_event_source_mapping(params={})
enabled = params.delete('Enabled')
batch_size = params.delete('BatchSize')
event_source_arn = params.delete('EventSourceArn')
function_name = params.delete('FunctionName')
starting_pos = params.delete('StartingPosition')
data = {
'EventSourceArn' => event_source_arn,
'FunctionName' => function_name,
'StartingPosition' => starting_pos
}
data.merge!('BatchSize' => batch_size) if batch_size
data.merge!('Enabled' => enabled) if !enabled.nil?
request({
:method => 'POST',
:path => '/event-source-mappings/',
:expects => 202,
:body => Fog::JSON.encode(data)
}.merge(params))
end