# File lib/fog/aws/requests/kinesis/put_record.rb, line 38
        def put_record(options={})
          stream_name = options.delete("StreamName")

          unless stream = data[:kinesis_streams].detect{ |s| s["StreamName"] == stream_name }
            raise Fog::AWS::Kinesis::ResourceNotFound.new("Stream #{stream_name} under account #{@account_id} not found.")
          end

          sequence_number = next_sequence_number
          data = options.delete("Data")
          partition_key = options.delete("PartitionKey")

          sample_method = RUBY_VERSION == "1.8.7" ? :choice : :sample
          shard_id = stream["Shards"].send(sample_method)["ShardId"]
          shard = stream["Shards"].detect{ |shard| shard["ShardId"] == shard_id }
          # store the records on the shard(s)
          shard["Records"] << {
            "SequenceNumber" => sequence_number,
            "Data" => data,
            "PartitionKey" => partition_key
          }

          response = Excon::Response.new
          response.status = 200
          response.body = {
            "SequenceNumber" => sequence_number,
            "ShardId" => shard_id
          }
          response
        end