api_train_v2.py 2.0 KB
Newer Older
Y
Yu Yang 已提交
1
import numpy
Q
qiaolongfei 已提交
2 3
import paddle.v2 as paddle

Y
Yu Yang 已提交
4 5 6 7 8 9 10 11 12 13 14
import mnist_util


def train_reader():
    train_file = './data/raw_data/train'
    generator = mnist_util.read_from_mnist(train_file)
    for item in generator:
        yield item


def main():
Y
Yu Yang 已提交
15
    paddle.init(use_gpu=False, trainer_count=1)
Q
qiaolongfei 已提交
16 17

    # define network topology
Q
qiaolongfei 已提交
18 19
    images = paddle.layer.data(name='pixel', type=paddle.data.dense_vector(784))
    label = paddle.layer.data(name='label', type=paddle.data.integer_value(10))
Q
qiaolongfei 已提交
20 21 22 23 24 25 26
    hidden1 = paddle.layer.fc(input=images, size=200)
    hidden2 = paddle.layer.fc(input=hidden1, size=200)
    inference = paddle.layer.fc(input=hidden2,
                                size=10,
                                act=paddle.activation.Softmax())
    cost = paddle.layer.classification_cost(input=inference, label=label)

Q
qiaolongfei 已提交
27
    parameters = paddle.parameters.create(cost)
Y
Yu Yang 已提交
28
    for param_name in parameters.keys():
Y
Yu Yang 已提交
29
        array = parameters.get(param_name)
Y
Yu Yang 已提交
30
        array[:] = numpy.random.uniform(low=-1.0, high=1.0, size=array.shape)
Y
Yu Yang 已提交
31
        parameters.set(parameter_name=param_name, value=array)
Y
Yu Yang 已提交
32

Q
qiaolongfei 已提交
33
    adam_optimizer = paddle.optimizer.Adam(learning_rate=0.01)
Y
Yu Yang 已提交
34 35

    def event_handler(event):
Y
Yu Yang 已提交
36
        if isinstance(event, paddle.event.EndIteration):
Q
qiaolongfei 已提交
37
            para = parameters.get('___fc_2__.w0')
Y
Yu Yang 已提交
38 39
            print "Pass %d, Batch %d, Cost %f, Weight Mean Of Fc 2 is %f" % (
                event.pass_id, event.batch_id, event.cost, para.mean())
Y
Yu Yang 已提交
40

Y
Yu Yang 已提交
41 42
        else:
            pass
43

Y
Yu Yang 已提交
44
    trainer = paddle.trainer.SGD(update_equation=adam_optimizer)
Y
Yu Yang 已提交
45 46

    trainer.train(train_data_reader=train_reader,
Q
qiaolongfei 已提交
47
                  topology=cost,
Y
Yu Yang 已提交
48
                  parameters=parameters,
Y
Yu Yang 已提交
49 50 51 52
                  event_handler=event_handler,
                  batch_size=32,  # batch size should be refactor in Data reader
                  data_types={  # data_types will be removed, It should be in
                      # network topology
Q
qiaolongfei 已提交
53 54
                      'pixel': images.type,
                      'label': label.type
Y
Yu Yang 已提交
55 56 57 58 59
                  })


if __name__ == '__main__':
    main()