图像分类网络结构搜索-快速开始

该教程以图像分类模型MobileNetV2为例,说明如何在cifar10数据集上快速使用网络结构搜索接口。 该示例包含以下步骤:

  1. 导入依赖
  2. 初始化SANAS搜索实例
  3. 构建网络
  4. 定义输入数据函数
  5. 定义训练函数
  6. 定义评估函数
  7. 启动搜索实验 7.1 获取模型结构 7.2 构造program 7.3 定义输入数据 7.4 训练模型 7.5 评估模型 7.6 回传当前模型的得分
  8. 完整示例

以下章节依次介绍每个步骤的内容。

1. 导入依赖

请确认已正确安装Paddle,导入需要的依赖包。

import paddle
import paddle.fluid as fluid
import paddleslim as slim
import numpy as np

2. 初始化SANAS搜索实例

sanas = slim.nas.SANAS(configs=[('MobileNetV2Space')], server_addr=("", 8337), save_checkpoint=None)

3. 构建网络

根据传入的网络结构构造训练program和测试program。

def build_program(archs):
    train_program = fluid.Program()
    startup_program = fluid.Program()
    with fluid.program_guard(train_program, startup_program):
        data = fluid.data(name='data', shape=[None, 3, 32, 32], dtype='float32')
        label = fluid.data(name='label', shape=[None, 1], dtype='int64')
        output = archs(data)
        output = fluid.layers.fc(input=output, size=10)

        softmax_out = fluid.layers.softmax(input=output, use_cudnn=False)
        cost = fluid.layers.cross_entropy(input=softmax_out, label=label)
        avg_cost = fluid.layers.mean(cost)
        acc_top1 = fluid.layers.accuracy(input=softmax_out, label=label, k=1)
        acc_top5 = fluid.layers.accuracy(input=softmax_out, label=label, k=5)
        test_program = fluid.default_main_program().clone(for_test=True)
            
        optimizer = fluid.optimizer.Adam(learning_rate=0.1)
        optimizer.minimize(avg_cost)

        place = fluid.CPUPlace()
        exe = fluid.Executor(place)
        exe.run(startup_program)
    return exe, train_program, test_program, (data, label), avg_cost, acc_top1, acc_top5

4. 定义输入数据函数

使用的数据集为cifar10,paddle框架中paddle.dataset.cifar包括了cifar数据集的下载和读取,代码如下:

def input_data(inputs):
    train_reader = paddle.batch(paddle.reader.shuffle(paddle.dataset.cifar.train10(cycle=False), buf_size=1024),batch_size=256)
    train_feeder = fluid.DataFeeder(inputs, fluid.CPUPlace())
    eval_reader = paddle.batch(paddle.dataset.cifar.test10(cycle=False), batch_size=256)
    eval_feeder = fluid.DataFeeder(inputs, fluid.CPUPlace())
    return train_reader, train_feeder, eval_reader, eval_feeder

5. 定义训练函数

根据训练program和训练数据进行训练。

def start_train(program, data_reader, data_feeder): 
    outputs = [avg_cost.name, acc_top1.name, acc_top5.name]
    for data in data_reader():
        batch_reward = exe.run(program, feed=data_feeder.feed(data), fetch_list = outputs)
        print("TRAIN: loss: {}, acc1: {}, acc5:{}".format(batch_reward[0], batch_reward[1], batch_reward[2]))

6. 定义评估函数

根据评估program和评估数据进行评估。

def start_eval(program, data_reader, data_feeder):
    reward = []
    outputs = [avg_cost.name, acc_top1.name, acc_top5.name]
    for data in data_reader():
        batch_reward = exe.run(program, feed=data_feeder.feed(data), fetch_list = outputs)
        reward_avg = np.mean(np.array(batch_reward), axis=1)
        reward.append(reward_avg)
        print("TEST: loss: {}, acc1: {}, acc5:{}".format(batch_reward[0], batch_reward[1], batch_reward[2]))
    finally_reward = np.mean(np.array(reward), axis=0)
    print("FINAL TEST: avg_cost: {}, acc1: {}, acc5: {}".format(finally_reward[0], finally_reward[1], finally_reward[2]))
    return finally_reward

7. 启动搜索实验

以下步骤拆解说明了如何获得当前模型结构以及获得当前模型结构之后应该有的步骤,如果想要看如何启动搜索实验的完整示例可以看步骤9。

7.1 获取模型结构

调用next_archs()函数获取到下一个模型结构。

archs = sanas.next_archs()[0]

7.2 构造program

调用步骤3中的函数,根据4.1中的模型结构构造相应的program。

exe, train_program, eval_program, inputs, avg_cost, acc_top1, acc_top5 = build_program(archs)

7.3 定义输入数据

train_reader, train_feeder, eval_reader, eval_feeder = input_data(inputs)

7.4 训练模型

根据上面得到的训练program和评估数据启动训练。

start_train(train_program, train_reader, train_feeder)

7.5 评估模型

根据上面得到的评估program和评估数据启动评估。

finally_reward = start_eval(eval_program, eval_reader, eval_feeder)

7.6 回传当前模型的得分

sanas.reward(float(finally_reward[1]))

8. 完整示例

以下是一个完整的搜索实验示例,示例中使用FLOPs作为约束条件,搜索实验一共搜索3个step,表示搜索到3个满足条件的模型结构进行训练,每搜索到一个网络结构训练7个epoch。

for step in range(3):
    archs = sanas.next_archs()[0]
    exe, train_program, eval_progarm, inputs, avg_cost, acc_top1, acc_top5 = build_program(archs)
    train_reader, train_feeder, eval_reader, eval_feeder = input_data(inputs)

    current_flops = slim.analysis.flops(train_program)
    if current_flops > 321208544:
        continue
    
    for epoch in range(7):
        start_train(train_program, train_reader, train_feeder)

    finally_reward = start_eval(eval_program, eval_reader, eval_feeder)

    sanas.reward(float(finally_reward[1]))