Mercurial > ift6266
annotate baseline/mlp/mlp_nist.py @ 395:f61a04074723
code for amazon MT
author | goldfinger |
---|---|
date | Tue, 27 Apr 2010 13:45:32 -0400 |
parents | 60a4432b8071 |
children | 1509b9bba4cc |
rev | line source |
---|---|
110 | 1 """ |
2 This tutorial introduces the multilayer perceptron using Theano. | |
3 | |
4 A multilayer perceptron is a logistic regressor where | |
5 instead of feeding the input to the logistic regression you insert a | |
6 intermidiate layer, called the hidden layer, that has a nonlinear | |
7 activation function (usually tanh or sigmoid) . One can use many such | |
8 hidden layers making the architecture deep. The tutorial will also tackle | |
9 the problem of MNIST digit classification. | |
10 | |
11 .. math:: | |
12 | |
13 f(x) = G( b^{(2)} + W^{(2)}( s( b^{(1)} + W^{(1)} x))), | |
14 | |
15 References: | |
16 | |
17 - textbooks: "Pattern Recognition and Machine Learning" - | |
18 Christopher M. Bishop, section 5 | |
19 | |
20 TODO: recommended preprocessing, lr ranges, regularization ranges (explain | |
21 to do lr first, then add regularization) | |
22 | |
23 """ | |
24 __docformat__ = 'restructedtext en' | |
25 | |
355
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
26 import sys |
110 | 27 import pdb |
28 import numpy | |
29 import pylab | |
30 import theano | |
31 import theano.tensor as T | |
32 import time | |
33 import theano.tensor.nnet | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
34 import pylearn |
304
1e4bf5a5b46d
added type 2 adaptive learning configurable learning weight + versionning
xaviermuller
parents:
237
diff
changeset
|
35 import theano,pylearn.version,ift6266 |
110 | 36 from pylearn.io import filetensor as ft |
322 | 37 from ift6266 import datasets |
110 | 38 |
39 data_path = '/data/lisa/data/nist/by_class/' | |
40 | |
41 class MLP(object): | |
42 """Multi-Layer Perceptron Class | |
43 | |
44 A multilayer perceptron is a feedforward artificial neural network model | |
45 that has one layer or more of hidden units and nonlinear activations. | |
46 Intermidiate layers usually have as activation function thanh or the | |
47 sigmoid function while the top layer is a softamx layer. | |
48 """ | |
49 | |
50 | |
51 | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
52 def __init__(self, input, n_in, n_hidden, n_out,learning_rate): |
110 | 53 """Initialize the parameters for the multilayer perceptron |
54 | |
55 :param input: symbolic variable that describes the input of the | |
56 architecture (one minibatch) | |
57 | |
58 :param n_in: number of input units, the dimension of the space in | |
59 which the datapoints lie | |
60 | |
61 :param n_hidden: number of hidden units | |
62 | |
63 :param n_out: number of output units, the dimension of the space in | |
64 which the labels lie | |
65 | |
66 """ | |
67 | |
68 # initialize the parameters theta = (W1,b1,W2,b2) ; note that this | |
69 # example contains only one hidden layer, but one can have as many | |
70 # layers as he/she wishes, making the network deeper. The only | |
71 # problem making the network deep this way is during learning, | |
72 # backpropagation being unable to move the network from the starting | |
73 # point towards; this is where pre-training helps, giving a good | |
74 # starting point for backpropagation, but more about this in the | |
75 # other tutorials | |
76 | |
77 # `W1` is initialized with `W1_values` which is uniformely sampled | |
78 # from -6./sqrt(n_in+n_hidden) and 6./sqrt(n_in+n_hidden) | |
79 # the output of uniform if converted using asarray to dtype | |
80 # theano.config.floatX so that the code is runable on GPU | |
81 W1_values = numpy.asarray( numpy.random.uniform( \ | |
82 low = -numpy.sqrt(6./(n_in+n_hidden)), \ | |
83 high = numpy.sqrt(6./(n_in+n_hidden)), \ | |
84 size = (n_in, n_hidden)), dtype = theano.config.floatX) | |
85 # `W2` is initialized with `W2_values` which is uniformely sampled | |
86 # from -6./sqrt(n_hidden+n_out) and 6./sqrt(n_hidden+n_out) | |
87 # the output of uniform if converted using asarray to dtype | |
88 # theano.config.floatX so that the code is runable on GPU | |
89 W2_values = numpy.asarray( numpy.random.uniform( | |
90 low = -numpy.sqrt(6./(n_hidden+n_out)), \ | |
91 high= numpy.sqrt(6./(n_hidden+n_out)),\ | |
92 size= (n_hidden, n_out)), dtype = theano.config.floatX) | |
93 | |
94 self.W1 = theano.shared( value = W1_values ) | |
95 self.b1 = theano.shared( value = numpy.zeros((n_hidden,), | |
96 dtype= theano.config.floatX)) | |
97 self.W2 = theano.shared( value = W2_values ) | |
98 self.b2 = theano.shared( value = numpy.zeros((n_out,), | |
99 dtype= theano.config.floatX)) | |
100 | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
101 #include the learning rate in the classifer so |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
102 #we can modify it on the fly when we want |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
103 lr_value=learning_rate |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
104 self.lr=theano.shared(value=lr_value) |
110 | 105 # symbolic expression computing the values of the hidden layer |
106 self.hidden = T.tanh(T.dot(input, self.W1)+ self.b1) | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
107 |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
108 |
110 | 109 |
110 # symbolic expression computing the values of the top layer | |
111 self.p_y_given_x= T.nnet.softmax(T.dot(self.hidden, self.W2)+self.b2) | |
112 | |
113 # compute prediction as class whose probability is maximal in | |
114 # symbolic form | |
115 self.y_pred = T.argmax( self.p_y_given_x, axis =1) | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
116 self.y_pred_num = T.argmax( self.p_y_given_x[0:9], axis =1) |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
117 |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
118 |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
119 |
110 | 120 |
121 # L1 norm ; one regularization option is to enforce L1 norm to | |
122 # be small | |
123 self.L1 = abs(self.W1).sum() + abs(self.W2).sum() | |
124 | |
125 # square of L2 norm ; one regularization option is to enforce | |
126 # square of L2 norm to be small | |
127 self.L2_sqr = (self.W1**2).sum() + (self.W2**2).sum() | |
128 | |
129 | |
130 | |
131 def negative_log_likelihood(self, y): | |
132 """Return the mean of the negative log-likelihood of the prediction | |
133 of this model under a given target distribution. | |
134 | |
135 .. math:: | |
136 | |
137 \frac{1}{|\mathcal{D}|}\mathcal{L} (\theta=\{W,b\}, \mathcal{D}) = | |
138 \frac{1}{|\mathcal{D}|}\sum_{i=0}^{|\mathcal{D}|} \log(P(Y=y^{(i)}|x^{(i)}, W,b)) \\ | |
139 \ell (\theta=\{W,b\}, \mathcal{D}) | |
140 | |
141 | |
142 :param y: corresponds to a vector that gives for each example the | |
143 :correct label | |
144 """ | |
145 return -T.mean(T.log(self.p_y_given_x)[T.arange(y.shape[0]),y]) | |
146 | |
147 | |
148 | |
149 | |
150 def errors(self, y): | |
151 """Return a float representing the number of errors in the minibatch | |
152 over the total number of examples of the minibatch | |
153 """ | |
154 | |
155 # check if y has same dimension of y_pred | |
156 if y.ndim != self.y_pred.ndim: | |
157 raise TypeError('y should have the same shape as self.y_pred', | |
158 ('y', target.type, 'y_pred', self.y_pred.type)) | |
159 # check if y is of the correct datatype | |
160 if y.dtype.startswith('int'): | |
161 # the T.neq operator returns a vector of 0s and 1s, where 1 | |
162 # represents a mistake in prediction | |
163 return T.mean(T.neq(self.y_pred, y)) | |
164 else: | |
165 raise NotImplementedError() | |
166 | |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
167 def mlp_get_nist_error(model_name='/u/mullerx/ift6266h10_sandbox_db/xvm_final_lr1_p073/8/best_model.npy.npz', |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
168 data_set=0): |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
169 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
170 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
171 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
172 # allocate symbolic variables for the data |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
173 x = T.fmatrix() # the data is presented as rasterized images |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
174 y = T.lvector() # the labels are presented as 1D vector of |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
175 # [long int] labels |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
176 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
177 # load the data set and create an mlp based on the dimensions of the model |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
178 model=numpy.load(model_name) |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
179 W1=model['W1'] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
180 W2=model['W2'] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
181 b1=model['b1'] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
182 b2=model['b2'] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
183 nb_hidden=b1.shape[0] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
184 input_dim=W1.shape[0] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
185 nb_targets=b2.shape[0] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
186 learning_rate=0.1 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
187 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
188 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
189 if data_set==0: |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
190 dataset=datasets.nist_all() |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
191 elif data_set==1: |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
192 dataset=datasets.nist_P07() |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
193 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
194 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
195 classifier = MLP( input=x,\ |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
196 n_in=input_dim,\ |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
197 n_hidden=nb_hidden,\ |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
198 n_out=nb_targets, |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
199 learning_rate=learning_rate) |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
200 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
201 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
202 #overwrite weights with weigths from model |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
203 classifier.W1.value=W1 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
204 classifier.W2.value=W2 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
205 classifier.b1.value=b1 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
206 classifier.b2.value=b2 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
207 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
208 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
209 cost = classifier.negative_log_likelihood(y) \ |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
210 + 0.0 * classifier.L1 \ |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
211 + 0.0 * classifier.L2_sqr |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
212 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
213 # compiling a theano function that computes the mistakes that are made by |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
214 # the model on a minibatch |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
215 test_model = theano.function([x,y], classifier.errors(y)) |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
216 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
217 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
218 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
219 #get the test error |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
220 #use a batch size of 1 so we can get the sub-class error |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
221 #without messing with matrices (will be upgraded later) |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
222 test_score=0 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
223 temp=0 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
224 for xt,yt in dataset.test(20): |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
225 test_score += test_model(xt,yt) |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
226 temp = temp+1 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
227 test_score /= temp |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
228 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
229 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
230 return test_score*100 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
231 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
232 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
233 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
234 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
235 |
110 | 236 |
304
1e4bf5a5b46d
added type 2 adaptive learning configurable learning weight + versionning
xaviermuller
parents:
237
diff
changeset
|
237 def mlp_full_nist( verbose = 1,\ |
145
8ceaaf812891
changed adaptive lr flag from bool to int for jobman issues
XavierMuller
parents:
143
diff
changeset
|
238 adaptive_lr = 0,\ |
322 | 239 data_set=0,\ |
110 | 240 learning_rate=0.01,\ |
241 L1_reg = 0.00,\ | |
242 L2_reg = 0.0001,\ | |
243 nb_max_exemples=1000000,\ | |
244 batch_size=20,\ | |
322 | 245 nb_hidden = 30,\ |
212
e390b0454515
added classic lr time decay and py code to calculate the error based on a saved model
xaviermuller
parents:
169
diff
changeset
|
246 nb_targets = 62, |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
247 tau=1e6,\ |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
248 lr_t2_factor=0.5,\ |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
249 init_model=0,\ |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
250 channel=0): |
110 | 251 |
252 | |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
253 if channel!=0: |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
254 channel.save() |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
255 configuration = [learning_rate,nb_max_exemples,nb_hidden,adaptive_lr] |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
256 |
212
e390b0454515
added classic lr time decay and py code to calculate the error based on a saved model
xaviermuller
parents:
169
diff
changeset
|
257 #save initial learning rate if classical adaptive lr is used |
e390b0454515
added classic lr time decay and py code to calculate the error based on a saved model
xaviermuller
parents:
169
diff
changeset
|
258 initial_lr=learning_rate |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
259 max_div_count=1000 |
323 | 260 |
212
e390b0454515
added classic lr time decay and py code to calculate the error based on a saved model
xaviermuller
parents:
169
diff
changeset
|
261 |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
262 total_validation_error_list = [] |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
263 total_train_error_list = [] |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
264 learning_rate_list=[] |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
265 best_training_error=float('inf'); |
323 | 266 divergence_flag_list=[] |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
267 |
322 | 268 if data_set==0: |
378 | 269 print 'using nist' |
322 | 270 dataset=datasets.nist_all() |
323 | 271 elif data_set==1: |
378 | 272 print 'using p07' |
323 | 273 dataset=datasets.nist_P07() |
349
22efb4968054
added pnist support, will check in code for data set iterator later
xaviermuller
parents:
338
diff
changeset
|
274 elif data_set==2: |
378 | 275 print 'using pnist' |
349
22efb4968054
added pnist support, will check in code for data set iterator later
xaviermuller
parents:
338
diff
changeset
|
276 dataset=datasets.PNIST07() |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
277 |
212
e390b0454515
added classic lr time decay and py code to calculate the error based on a saved model
xaviermuller
parents:
169
diff
changeset
|
278 |
110 | 279 |
280 | |
281 ishape = (32,32) # this is the size of NIST images | |
282 | |
283 # allocate symbolic variables for the data | |
284 x = T.fmatrix() # the data is presented as rasterized images | |
285 y = T.lvector() # the labels are presented as 1D vector of | |
286 # [long int] labels | |
287 | |
322 | 288 |
110 | 289 # construct the logistic regression class |
322 | 290 classifier = MLP( input=x,\ |
110 | 291 n_in=32*32,\ |
292 n_hidden=nb_hidden,\ | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
293 n_out=nb_targets, |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
294 learning_rate=learning_rate) |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
295 |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
296 |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
297 # check if we want to initialise the weights with a previously calculated model |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
298 # dimensions must be consistent between old model and current configuration!!!!!! (nb_hidden and nb_targets) |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
299 if init_model!=0: |
378 | 300 print 'using old model' |
301 print init_model | |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
302 old_model=numpy.load(init_model) |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
303 classifier.W1.value=old_model['W1'] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
304 classifier.W2.value=old_model['W2'] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
305 classifier.b1.value=old_model['b1'] |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
306 classifier.b2.value=old_model['b2'] |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
307 |
110 | 308 |
309 # the cost we minimize during training is the negative log likelihood of | |
310 # the model plus the regularization terms (L1 and L2); cost is expressed | |
311 # here symbolically | |
312 cost = classifier.negative_log_likelihood(y) \ | |
313 + L1_reg * classifier.L1 \ | |
314 + L2_reg * classifier.L2_sqr | |
315 | |
316 # compiling a theano function that computes the mistakes that are made by | |
317 # the model on a minibatch | |
318 test_model = theano.function([x,y], classifier.errors(y)) | |
319 | |
320 # compute the gradient of cost with respect to theta = (W1, b1, W2, b2) | |
321 g_W1 = T.grad(cost, classifier.W1) | |
322 g_b1 = T.grad(cost, classifier.b1) | |
323 g_W2 = T.grad(cost, classifier.W2) | |
324 g_b2 = T.grad(cost, classifier.b2) | |
325 | |
326 # specify how to update the parameters of the model as a dictionary | |
327 updates = \ | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
328 { classifier.W1: classifier.W1 - classifier.lr*g_W1 \ |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
329 , classifier.b1: classifier.b1 - classifier.lr*g_b1 \ |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
330 , classifier.W2: classifier.W2 - classifier.lr*g_W2 \ |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
331 , classifier.b2: classifier.b2 - classifier.lr*g_b2 } |
110 | 332 |
333 # compiling a theano function `train_model` that returns the cost, but in | |
334 # the same time updates the parameter of the model based on the rules | |
335 # defined in `updates` | |
336 train_model = theano.function([x, y], cost, updates = updates ) | |
322 | 337 |
338 | |
339 | |
110 | 340 |
341 | |
342 | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
343 |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
344 |
110 | 345 |
346 #conditions for stopping the adaptation: | |
323 | 347 #1) we have reached nb_max_exemples (this is rounded up to be a multiple of the train size so we always do at least 1 epoch) |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
348 #2) validation error is going up twice in a row(probable overfitting) |
110 | 349 |
350 # This means we no longer stop on slow convergence as low learning rates stopped | |
323 | 351 # too fast but instead we will wait for the valid error going up 3 times in a row |
352 # We save the curb of the validation error so we can always go back to check on it | |
353 # and we save the absolute best model anyway, so we might as well explore | |
354 # a bit when diverging | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
355 |
323 | 356 #approximate number of samples in the nist training set |
322 | 357 #this is just to have a validation frequency |
323 | 358 #roughly proportionnal to the original nist training set |
322 | 359 n_minibatches = 650000/batch_size |
360 | |
361 | |
323 | 362 patience =2*nb_max_exemples/batch_size #in units of minibatch |
110 | 363 validation_frequency = n_minibatches/4 |
364 | |
365 | |
366 | |
367 | |
322 | 368 |
110 | 369 best_validation_loss = float('inf') |
370 best_iter = 0 | |
371 test_score = 0. | |
372 start_time = time.clock() | |
212
e390b0454515
added classic lr time decay and py code to calculate the error based on a saved model
xaviermuller
parents:
169
diff
changeset
|
373 time_n=0 #in unit of exemples |
322 | 374 minibatch_index=0 |
375 epoch=0 | |
376 temp=0 | |
323 | 377 divergence_flag=0 |
322 | 378 |
212
e390b0454515
added classic lr time decay and py code to calculate the error based on a saved model
xaviermuller
parents:
169
diff
changeset
|
379 |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
380 |
355
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
381 |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
382 print 'starting training' |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
383 sys.stdout.flush() |
322 | 384 while(minibatch_index*batch_size<nb_max_exemples): |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
385 |
322 | 386 for x, y in dataset.train(batch_size): |
110 | 387 |
323 | 388 #if we are using the classic learning rate deacay, adjust it before training of current mini-batch |
322 | 389 if adaptive_lr==2: |
390 classifier.lr.value = tau*initial_lr/(tau+time_n) | |
391 | |
392 | |
393 #train model | |
394 cost_ij = train_model(x,y) | |
395 | |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
396 if (minibatch_index) % validation_frequency == 0: |
322 | 397 #save the current learning rate |
398 learning_rate_list.append(classifier.lr.value) | |
323 | 399 divergence_flag_list.append(divergence_flag) |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
400 |
355
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
401 |
322 | 402 |
403 # compute the validation error | |
404 this_validation_loss = 0. | |
405 temp=0 | |
406 for xv,yv in dataset.valid(1): | |
407 # sum up the errors for each minibatch | |
323 | 408 this_validation_loss += test_model(xv,yv) |
322 | 409 temp=temp+1 |
410 # get the average by dividing with the number of minibatches | |
411 this_validation_loss /= temp | |
412 #save the validation loss | |
413 total_validation_error_list.append(this_validation_loss) | |
355
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
414 |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
415 print(('epoch %i, minibatch %i, learning rate %f current validation error %f ') % |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
416 (epoch, minibatch_index+1,classifier.lr.value, |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
417 this_validation_loss*100.)) |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
418 sys.stdout.flush() |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
419 |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
420 #save temp results to check during training |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
421 numpy.savez('temp_results.npy',config=configuration,total_validation_error_list=total_validation_error_list,\ |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
422 learning_rate_list=learning_rate_list, divergence_flag_list=divergence_flag_list) |
322 | 423 |
424 # if we got the best validation score until now | |
425 if this_validation_loss < best_validation_loss: | |
426 # save best validation score and iteration number | |
427 best_validation_loss = this_validation_loss | |
428 best_iter = minibatch_index | |
323 | 429 #reset divergence flag |
430 divergence_flag=0 | |
431 | |
432 #save the best model. Overwrite the current saved best model so | |
433 #we only keep the best | |
434 numpy.savez('best_model.npy', config=configuration, W1=classifier.W1.value, W2=classifier.W2.value, b1=classifier.b1.value,\ | |
435 b2=classifier.b2.value, minibatch_index=minibatch_index) | |
436 | |
322 | 437 # test it on the test set |
438 test_score = 0. | |
439 temp =0 | |
440 for xt,yt in dataset.test(batch_size): | |
441 test_score += test_model(xt,yt) | |
442 temp = temp+1 | |
443 test_score /= temp | |
355
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
444 |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
445 print(('epoch %i, minibatch %i, test error of best ' |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
446 'model %f %%') % |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
447 (epoch, minibatch_index+1, |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
448 test_score*100.)) |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
449 sys.stdout.flush() |
322 | 450 |
451 # if the validation error is going up, we are overfitting (or oscillating) | |
323 | 452 # check if we are allowed to continue and if we will adjust the learning rate |
322 | 453 elif this_validation_loss >= best_validation_loss: |
323 | 454 |
455 | |
456 # In non-classic learning rate decay, we modify the weight only when | |
457 # validation error is going up | |
458 if adaptive_lr==1: | |
459 classifier.lr.value=classifier.lr.value*lr_t2_factor | |
460 | |
461 | |
462 #cap the patience so we are allowed to diverge max_div_count times | |
463 #if we are going up max_div_count in a row, we will stop immediatelty by modifying the patience | |
464 divergence_flag = divergence_flag +1 | |
465 | |
466 | |
322 | 467 #calculate the test error at this point and exit |
468 # test it on the test set | |
469 test_score = 0. | |
470 temp=0 | |
471 for xt,yt in dataset.test(batch_size): | |
472 test_score += test_model(xt,yt) | |
473 temp=temp+1 | |
474 test_score /= temp | |
355
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
475 |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
476 print ' validation error is going up, possibly stopping soon' |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
477 print((' epoch %i, minibatch %i, test error of best ' |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
478 'model %f %%') % |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
479 (epoch, minibatch_index+1, |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
480 test_score*100.)) |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
481 sys.stdout.flush() |
322 | 482 |
483 | |
484 | |
323 | 485 # check early stop condition |
486 if divergence_flag==max_div_count: | |
487 minibatch_index=nb_max_exemples | |
488 print 'we have diverged, early stopping kicks in' | |
489 break | |
490 | |
491 #check if we have seen enough exemples | |
492 #force one epoch at least | |
493 if epoch>0 and minibatch_index*batch_size>nb_max_exemples: | |
322 | 494 break |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
495 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
496 |
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
497 |
322 | 498 |
499 | |
500 time_n= time_n + batch_size | |
323 | 501 minibatch_index = minibatch_index + 1 |
502 | |
503 # we have finished looping through the training set | |
322 | 504 epoch = epoch+1 |
110 | 505 end_time = time.clock() |
355
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
506 |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
507 print(('Optimization complete. Best validation score of %f %% ' |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
508 'obtained at iteration %i, with test performance %f %%') % |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
509 (best_validation_loss * 100., best_iter, test_score*100.)) |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
510 print ('The code ran for %f minutes' % ((end_time-start_time)/60.)) |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
511 print minibatch_index |
76b7182dd32e
added support for pnist in iterator. corrected a print bug in mlp
xaviermuller
parents:
349
diff
changeset
|
512 sys.stdout.flush() |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
513 |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
514 #save the model and the weights |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
515 numpy.savez('model.npy', config=configuration, W1=classifier.W1.value,W2=classifier.W2.value, b1=classifier.b1.value,b2=classifier.b2.value) |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
516 numpy.savez('results.npy',config=configuration,total_train_error_list=total_train_error_list,total_validation_error_list=total_validation_error_list,\ |
323 | 517 learning_rate_list=learning_rate_list, divergence_flag_list=divergence_flag_list) |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
518 |
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
519 return (best_training_error*100.0,best_validation_loss * 100.,test_score*100.,best_iter*batch_size,(end_time-start_time)/60) |
110 | 520 |
521 | |
522 if __name__ == '__main__': | |
523 mlp_full_mnist() | |
524 | |
525 def jobman_mlp_full_nist(state,channel): | |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
526 (train_error,validation_error,test_error,nb_exemples,time)=mlp_full_nist(learning_rate=state.learning_rate,\ |
304
1e4bf5a5b46d
added type 2 adaptive learning configurable learning weight + versionning
xaviermuller
parents:
237
diff
changeset
|
527 nb_max_exemples=state.nb_max_exemples,\ |
1e4bf5a5b46d
added type 2 adaptive learning configurable learning weight + versionning
xaviermuller
parents:
237
diff
changeset
|
528 nb_hidden=state.nb_hidden,\ |
1e4bf5a5b46d
added type 2 adaptive learning configurable learning weight + versionning
xaviermuller
parents:
237
diff
changeset
|
529 adaptive_lr=state.adaptive_lr,\ |
1e4bf5a5b46d
added type 2 adaptive learning configurable learning weight + versionning
xaviermuller
parents:
237
diff
changeset
|
530 tau=state.tau,\ |
1e4bf5a5b46d
added type 2 adaptive learning configurable learning weight + versionning
xaviermuller
parents:
237
diff
changeset
|
531 verbose = state.verbose,\ |
324 | 532 lr_t2_factor=state.lr_t2_factor, |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
533 data_set=state.data_set, |
378 | 534 init_model=state.init_model, |
338
fca22114bb23
added async save, restart from old model and independant error calculation based on Arnaud's iterator
xaviermuller
parents:
324
diff
changeset
|
535 channel=channel) |
143
f341a4efb44a
added adaptive lr, weight file save, traine error and error curves
XavierMuller
parents:
110
diff
changeset
|
536 state.train_error=train_error |
110 | 537 state.validation_error=validation_error |
538 state.test_error=test_error | |
539 state.nb_exemples=nb_exemples | |
540 state.time=time | |
304
1e4bf5a5b46d
added type 2 adaptive learning configurable learning weight + versionning
xaviermuller
parents:
237
diff
changeset
|
541 pylearn.version.record_versions(state,[theano,ift6266,pylearn]) |
110 | 542 return channel.COMPLETE |
543 | |
544 |