def put_record(options={})
body = {
"Data" => options.delete("Data"),
"ExplicitHashKey" => options.delete("ExplicitHashKey"),
"PartitionKey" => options.delete("PartitionKey"),
"SequenceNumberForOrdering" => options.delete("SequenceNumberForOrdering"),
"StreamName" => options.delete("StreamName")
}.reject{ |_,v| v.nil? }
response = request({
'X-Amz-Target' => "Kinesis_#{@version}.PutRecord",
:body => body,
}.merge(options))
response.body = Fog::JSON.decode(response.body) unless response.body.nil?
response
end