caffe2 教程入門(python版)

學(xué)習(xí)思路

1卸耘、先看官方文檔,學(xué)習(xí)如何使用python調(diào)用caffe2包伍俘,包括

  • Basics of Caffe2 - Workspaces, Operators, and Nets
  • Toy Regression
  • Image Pre-Processing
  • Loading Pre-Trained Models
  • MNIST - Create a CNN from Scratch

caffe2官方教程以python語言為主邪锌,指導(dǎo)如何使用python調(diào)用caffe2,文檔依次從最基本caffe中的幾個(gè)重要的類的概念癌瘾、如何使用基礎(chǔ)類搭建一個(gè)小網(wǎng)絡(luò)觅丰、如何數(shù)據(jù)預(yù)處理、如何使用預(yù)訓(xùn)練的模型妨退、如何構(gòu)造復(fù)雜的網(wǎng)絡(luò)來講述caffe2的使用妇萄。初學(xué)者可以先行學(xué)習(xí)官方文檔caffe2-tutorials蜕企,理解caffe2 中的網(wǎng)絡(luò)構(gòu)建、網(wǎng)絡(luò)訓(xùn)練的理念與思路冠句,體會caffe2與caffe在整體構(gòu)造上的不同轻掩。

2、結(jié)合著caffe2源碼看python實(shí)際調(diào)用的c++類

在python中懦底,caffe2這個(gè)包中類與函數(shù)大部分是封裝了源碼文件夾caffe2/caffe2/core下的c++源文件唇牧,如基礎(chǔ)數(shù)據(jù)類Tensor,操作類Operator等聚唐,通過使用python中類的使用丐重,找到對應(yīng)c++源碼中類和函數(shù)的構(gòu)造和實(shí)現(xiàn),可以為使用c++直接構(gòu)建和訓(xùn)練網(wǎng)絡(luò)打下準(zhǔn)備杆查。

以下總結(jié)基于官方文檔和部分網(wǎng)絡(luò)資料扮惦。

基礎(chǔ)知識

首先從我們自己的角度出發(fā)來思考,假設(shè)我們自己需要寫一個(gè)簡單的多層神經(jīng)網(wǎng)絡(luò)并訓(xùn)練亲桦,一般邏輯上我們需要考慮數(shù)據(jù)的定義崖蜜、數(shù)據(jù)的流動(dòng) 、數(shù)據(jù)的更新烙肺。

  • 數(shù)據(jù)如何定義:訓(xùn)練數(shù)據(jù)和網(wǎng)絡(luò)參數(shù)以什么形式存儲
  • 數(shù)據(jù)如何流動(dòng):訓(xùn)練數(shù)據(jù)經(jīng)過哪些運(yùn)算得到輸出纳猪,其實(shí)就是網(wǎng)絡(luò)的定義
  • 數(shù)據(jù)如何更新:使用什么樣的梯度更新方法與參數(shù),其實(shí)就是如何訓(xùn)練

在caffe中桃笙,數(shù)據(jù)儲存在Blob類的實(shí)例當(dāng)中氏堤,在這里,我們可以理解blob就像是numpy中數(shù)組搏明,起的作用就是存儲數(shù)據(jù)鼠锈。輸入的blobs經(jīng)過不同層的往前傳遞,得到輸出的blobs星著,caffe中购笆,我們可以認(rèn)為對數(shù)據(jù)最基本的運(yùn)算單位是layer。每一層的layer定義了不同的計(jì)算方式虚循,數(shù)據(jù)經(jīng)過不同的層同欠,都做了相應(yīng)的運(yùn)算,由這些layers組合到一起網(wǎng)絡(luò)即構(gòu)成了net横缔,net本質(zhì)上是一個(gè)計(jì)算網(wǎng)絡(luò)铺遂。當(dāng)數(shù)據(jù)流動(dòng)的方式構(gòu)建好了,反向傳遞的梯度計(jì)算的方式也確定茎刚,在這個(gè)基礎(chǔ)之上襟锐,caffe中使用solver類來給定梯度更新的規(guī)則,網(wǎng)絡(luò)在solver的控制下膛锭,不斷讓數(shù)據(jù)前傳粮坞,再反傳求梯度蚊荣,再使用梯度更新權(quán)值,循環(huán)往復(fù)莫杈。

所以對應(yīng)著caffe中互例,基礎(chǔ)組成有四類:

  • blob:存儲數(shù)據(jù)和權(quán)值
  • layer:輸入數(shù)據(jù)blob 形式,輸出數(shù)據(jù)blob形式姓迅,層定義了計(jì)算
  • net:由多個(gè)layers組成敲霍,構(gòu)成整體的網(wǎng)絡(luò)
  • solver:定義了訓(xùn)練規(guī)則

再看caffe2中:

在caffe2中,operator是caffe2中的特色丁存,取代了caffe中l(wèi)ayer作為net的基本構(gòu)造單位。如下圖所示柴我,我們可以使用一個(gè)InnerProduct操作運(yùn)輸符號來完成InnerProductLayer的功能解寝。operator的接口定義在caffe2/proto/caffe2.proto,一般來說艘儒,operator接受一串輸入聋伦,產(chǎn)生一串輸出。

operator

由于operator定義很基礎(chǔ)界睁,很抽象觉增,因此caffe2中的權(quán)值初始化、前傳翻斟、反傳逾礁、梯度更新都可以用operator實(shí)現(xiàn),所以solver访惜、layer類在caffe2中都不是必要的嘹履。在caffe2中,對應(yīng)的基礎(chǔ)組成有

  • blob:存儲數(shù)據(jù)
  • operator:輸入blob债热,輸出blob砾嫉,定義了計(jì)算規(guī)則
  • 網(wǎng)絡(luò):net,由多個(gè)operator組合實(shí)現(xiàn)
  • workspace:caffe中沒有窒篱,可以理解成變量的空間焕刮,便于管理網(wǎng)絡(luò)和變量

具體使用和理解如下,先用python:

在使用之前,我們先導(dǎo)入caffe2.core和workspace墙杯,基礎(chǔ)的類和函數(shù)都在其中配并。同時(shí)我們需要導(dǎo)入caffe2.proto來對protobuf文件進(jìn)行必要操作。

# We'll also import a few standard python libraries
from matplotlib import pyplot
import numpy as np
import time

# These are the droids you are looking for.
from caffe2.python import core, workspace
from caffe2.proto import caffe2_pb2
# Let's show all plots inline.
%matplotlib inline

1霍转、workspace

我們可以把workspace理解成matlab中變量存儲區(qū)荐绝,我們可以把定義好的數(shù)據(jù)blob或net放到都在一個(gè)workspace中,也可以用不用的workspace來區(qū)分避消。

下面我們打印一下當(dāng)前workspace中blob情況低滩。Blobs()取出blob召夹,HasBlobs(name)判斷是否有此名字的blob。

print("Current blobs in the workspace: {}".format(workspace.Blobs()))
print("Workspace has blob 'X'? {}".format(workspace.HasBlob("X")))

一開始恕沫,當(dāng)然結(jié)果是啥也沒有监憎。

我們使用FeedBlob來給當(dāng)前workspace添加blob,再打印出來:

X = np.random.randn(2, 3).astype(np.float32)
print("Generated X from numpy:\n{}".format(X))
workspace.FeedBlob("X", X)
Generated X from numpy:
[[-0.56927377 -1.28052795 -0.95808828]
 [-0.44225693 -0.0620895  -0.50509363]]
print("Current blobs in the workspace: {}".format(workspace.Blobs()))
print("Workspace has blob 'X'? {}".format(workspace.HasBlob("X")))
print("Fetched X:\n{}".format(workspace.FetchBlob("X")))
Current blobs in the workspace: [u'X']
Workspace has blob 'X'? True
Fetched X:
[[-0.56927377 -1.28052795 -0.95808828]
 [-0.44225693 -0.0620895  -0.50509363]]

當(dāng)然婶溯,我們也用多個(gè)名字定義多個(gè)workspace鲸阔,并且可以切換工作空間。我們可以使用currentworkspace()在訪問當(dāng)前工作空間迄委,使用switchworkspace(name)來切換工作空間褐筛。

print("Current workspace: {}".format(workspace.CurrentWorkspace()))
print("Current blobs in the workspace: {}".format(workspace.Blobs()))

# Switch the workspace. The second argument "True" means creating
# the workspace if it is missing.
workspace.SwitchWorkspace("gutentag", True)

# Let's print the current workspace. Note that there is nothing in the
# workspace yet.
print("Current workspace: {}".format(workspace.CurrentWorkspace()))
print("Current blobs in the workspace: {}".format(workspace.Blobs()))
Current workspace: default
Current blobs in the workspace: ['X']
Current workspace: gutentag
Current blobs in the workspace: []

總結(jié)一下,在這里workspace功能類似于matlab中的工作區(qū)叙身,變量存儲在其中渔扎,我們可以通過工作區(qū)去訪問在工作區(qū)中net和blob。

2信轿、Operators

通常我們在python中晃痴,可以使用core.CreateOperator來直接創(chuàng)造,也可以使用core.Net來訪問創(chuàng)建operator,還可以使用modelHelper來訪問創(chuàng)建operators财忽。在這里我們使用core.CreateOperator來簡單理解operator倘核,在實(shí)際情況下,我們創(chuàng)建網(wǎng)絡(luò)的時(shí)候即彪,不會直接創(chuàng)建每個(gè)operator紧唱,這樣太麻煩,一般使用modelhelper來幫忙我們創(chuàng)建網(wǎng)絡(luò)祖凫。

# Create an operator.
op = core.CreateOperator(
    "Relu", # The type of operator that we want to run
    ["X"], # A list of input blobs by their names
    ["Y"], # A list of output blobs by their names
)
# and we are done!

上面的代碼創(chuàng)建了一個(gè)Relu運(yùn)算符琼蚯,在這里需要知道,在python中創(chuàng)建一個(gè)operator惠况,只是定義了一個(gè)operator遭庶,其實(shí)并沒有運(yùn)行這個(gè)operator。在上面代碼中創(chuàng)建的op稠屠,實(shí)際上是一個(gè)protobuf對象峦睡。

print("Type of the created op is: {}".format(type(op)))
print("Content:\n")
print(str(op))
Type of the created op is: <class 'caffe2.proto.caffe2_pb2.OperatorDef'>
Content:

input: "X"
output: "Y"
name: ""
type: "Relu"

在創(chuàng)造op之后,我們在當(dāng)前的工作區(qū)中添加輸入X权埠,然后使用RunOperatorOnce運(yùn)行這個(gè)operator榨了。運(yùn)行之后,我們對比下得到的結(jié)果攘蔽。

workspace.FeedBlob("X", np.random.randn(2, 3).astype(np.float32))
workspace.RunOperatorOnce(op)
print("Current blobs in the workspace: {}\n".format(workspace.Blobs()))
print("X:\n{}\n".format(workspace.FetchBlob("X")))
print("Y:\n{}\n".format(workspace.FetchBlob("Y")))
print("Expected:\n{}\n".format(np.maximum(workspace.FetchBlob("X"), 0)))
Current blobs in the workspace: ['X', 'Y']

X:
[[ 1.03125858  1.0038228   0.0066975 ]
 [ 1.33142471  1.80271244 -0.54222912]]

Y:
[[ 1.03125858  1.0038228   0.0066975 ]
 [ 1.33142471  1.80271244  0.        ]]

Expected:
[[ 1.03125858  1.0038228   0.0066975 ]
 [ 1.33142471  1.80271244  0.        ]]

此外龙屉,operator相對于layer更為抽象。operator不僅僅可以替代layer類,還可以接受無參數(shù)的輸入來輸出數(shù)據(jù)转捕,從而用來生成數(shù)據(jù)作岖,常用來初始化權(quán)值。下面這一段就可以用來初始化權(quán)值五芝。

op = core.CreateOperator(
    "GaussianFill",
    [], # GaussianFill does not need any parameters.
    ["W"],
    shape=[100, 100], # shape argument as a list of ints.
    mean=1.0,  # mean as a single float
    std=1.0, # std as a single float
)
print("Content of op:\n")
print(str(op))
Content of op:

output: "W"
name: ""
type: "GaussianFill"
arg {
  name: "std"
  f: 1.0
}
arg {
  name: "shape"
  ints: 100
  ints: 100
}
arg {
  name: "mean"
  f: 1.0
}
workspace.RunOperatorOnce(op)
temp = workspace.FetchBlob("Z")
pyplot.hist(temp.flatten(), bins=50)
pyplot.title("Distribution of Z")

3痘儡、Nets

Nets是一系列operator的集合,從本質(zhì)上枢步,是由operator構(gòu)成的計(jì)算圖沉删。Caffe2中core.net 封裝了源碼中 NetDef 類。我們舉個(gè)栗子醉途,創(chuàng)建網(wǎng)絡(luò)來實(shí)現(xiàn)以下的公式矾瑰。

X = np.random.randn(2, 3)
W = np.random.randn(5, 3)
b = np.ones(5)
Y = X * W^T + b

首先創(chuàng)建網(wǎng)絡(luò):

net = core.Net("my_first_net")
print("Current network proto:\n\n{}".format(net.Proto()))
Current network proto:

name: "my_first_net"

首先使用生成權(quán)值和輸入,在這里结蟋,使用core.net來訪問創(chuàng)建:

X = net.GaussianFill([], ["X"], mean=0.0, std=1.0, shape=[2, 3], run_once=0)
print("New network proto:\n\n{}".format(net.Proto()))
W = net.GaussianFill([], ["W"], mean=0.0, std=1.0, shape=[5, 3], run_once=0)
b = net.ConstantFill([], ["b"], shape=[5,], value=1.0, run_once=0)

生成輸出:

Y = net.FC([X, W, b], ["Y"])

我們打印下當(dāng)前的網(wǎng)絡(luò):

print("Current network proto:\n\n{}".format(net.Proto()))
Current network proto:

name: "my_first_net"
op {
  output: "X"
  name: ""
  type: "GaussianFill"
  arg {
    name: "std"
    f: 1.0
  }
  arg {
    name: "run_once"
    i: 0
  }
  arg {
    name: "shape"
    ints: 2
    ints: 3
  }
  arg {
    name: "mean"
    f: 0.0
  }
}
op {
  output: "W"
  name: ""
  type: "GaussianFill"
  arg {
    name: "std"
    f: 1.0
  }
  arg {
    name: "run_once"
    i: 0
  }
  arg {
    name: "shape"
    ints: 5
    ints: 3
  }
  arg {
    name: "mean"
    f: 0.0
  }
}
op {
  output: "b"
  name: ""
  type: "ConstantFill"
  arg {
    name: "run_once"
    i: 0
  }
  arg {
    name: "shape"
    ints: 5
  }
  arg {
    name: "value"
    f: 1.0
  }
}
op {
  input: "X"
  input: "W"
  input: "b"
  output: "Y"
  name: ""
  type: "FC"
}

在這里脯倚,我們可以畫出來定義的網(wǎng)絡(luò):

from caffe2.python import net_drawer
from IPython import display
graph = net_drawer.GetPydotGraph(net, rankdir="LR")
display.Image(graph.create_png(), width=800)

和operator類似,在這里我們只定義了一個(gè)net嵌屎,但是并沒有運(yùn)行net的計(jì)算。當(dāng)我們在python運(yùn)行網(wǎng)絡(luò)時(shí)恍涂,實(shí)際上在c++層面做了兩件事情:

  • 由protobuf定義初始化c++ 的net對象
  • 調(diào)用初始化了的net的run函數(shù)

在python中有兩種方法來運(yùn)行一個(gè)net:

  • 方法1:使用workspace.RunNetOnce,初始化網(wǎng)絡(luò)宝惰,運(yùn)行網(wǎng)絡(luò),然后銷毀網(wǎng)絡(luò)再沧。
  • 方法2:先使用workspace.CreateNet初始化網(wǎng)絡(luò)尼夺,然后使用workspace.RunNet來運(yùn)行網(wǎng)絡(luò)

方法一:

workspace.ResetWorkspace()
print("Current blobs in the workspace: {}".format(workspace.Blobs()))
workspace.RunNetOnce(net)
print("Blobs in the workspace after execution: {}".format(workspace.Blobs()))
# Let's dump the contents of the blobs
for name in workspace.Blobs():
    print("{}:\n{}".format(name, workspace.FetchBlob(name)))
Current blobs in the workspace: []
Blobs in the workspace after execution: ['W', 'X', 'Y', 'b']
W:
[[-0.29295802  0.02897477 -1.25667715]
 [-1.82299471  0.92877913  0.33613944]
 [-0.64382178 -0.68545657 -0.44015241]
 [ 1.10232282  1.38060772 -2.29121733]
 [-0.55766547  1.97437167  0.39324901]]
X:
[[-0.47522315 -0.40166432  0.7179445 ]
 [-0.8363331  -0.82451206  1.54286408]]
Y:
[[ 0.22535783  1.73460138  1.2652775  -1.72335696  0.7543118 ]
 [-0.71776152  2.27745867  1.42452145 -4.59527397  0.4452306 ]]
b:
[ 1.  1.  1.  1.  1.]

方法二:

workspace.ResetWorkspace()
print("Current blobs in the workspace: {}".format(workspace.Blobs()))
workspace.CreateNet(net)
workspace.RunNet(net.Proto().name)
print("Blobs in the workspace after execution: {}".format(workspace.Blobs()))
for name in workspace.Blobs():
    print("{}:\n{}".format(name, workspace.FetchBlob(name)))

Current blobs in the workspace: []
Blobs in the workspace after execution: ['W', 'X', 'Y', 'b']
W:
[[-0.29295802  0.02897477 -1.25667715]
 [-1.82299471  0.92877913  0.33613944]
 [-0.64382178 -0.68545657 -0.44015241]
 [ 1.10232282  1.38060772 -2.29121733]
 [-0.55766547  1.97437167  0.39324901]]
X:
[[-0.47522315 -0.40166432  0.7179445 ]
 [-0.8363331  -0.82451206  1.54286408]]
Y:
[[ 0.22535783  1.73460138  1.2652775  -1.72335696  0.7543118 ]
 [-0.71776152  2.27745867  1.42452145 -4.59527397  0.4452306 ]]
b:
[ 1.  1.  1.  1.  1.]

在這里,大家可能比較疑惑為什么會有兩種運(yùn)行網(wǎng)絡(luò)的方式程拭,在之后的實(shí)際應(yīng)用中绘梦,大家就會慢慢理解捶枢,在這里,暫時(shí)記住有這樣兩種運(yùn)行網(wǎng)絡(luò)的方式即可拐邪。

總結(jié)一下,在caffe2中

  • workspace是工作空間隘截,在worspace中扎阶,可以存儲網(wǎng)絡(luò)結(jié)構(gòu)類Net和數(shù)據(jù)存儲類Blob.
  • 輸入數(shù)據(jù)、權(quán)值婶芭、輸出數(shù)據(jù)都存儲在Blob中
  • Operator類用來定義來數(shù)據(jù)如何計(jì)算东臀,由多個(gè)operators構(gòu)成Net,operator的作用強(qiáng)大
  • Net類是由operator構(gòu)成的整體犀农。

應(yīng)用舉例

在基礎(chǔ)知識中惰赋,我們理解了workspace,operator呵哨,net等基本的概念赁濒,在這里我們結(jié)合caffe2的官方文檔簡單舉出幾個(gè)例子轨奄。

栗子1-回歸的小栗子

第一個(gè)栗子幫助大家理解caffe2框架網(wǎng)絡(luò)構(gòu)建、參數(shù)初始化流部、訓(xùn)練戚绕、圖等的一些關(guān)于整體框架的理念。

假設(shè)我們要做訓(xùn)練一個(gè)簡單的網(wǎng)絡(luò)枝冀,擬合下面這樣的一個(gè)回歸函數(shù):

y = wx + b
其中:w=[2.0, 1.5]  b=0.5

一般訓(xùn)練數(shù)據(jù)是從外部讀進(jìn)來舞丛,在這里訓(xùn)練數(shù)據(jù)我們直接用caffe2中的operator生成,我們在后面的栗子中有會舉例說明如何從外部讀入數(shù)據(jù)果漾。

首先導(dǎo)入必要的包:

from caffe2.python import core, cnn, net_drawer, workspace, visualize
import numpy as np
from IPython import display
from matplotlib import pyplot

在這里球切,首先我們需要建立兩個(gè)網(wǎng)絡(luò)圖:

  • 一個(gè)用來生成訓(xùn)練數(shù)據(jù)、初始化權(quán)值的網(wǎng)絡(luò)圖
  • 一個(gè)用來用來訓(xùn)練绒障,更新剃度的網(wǎng)絡(luò)圖

這里caffe2的思路和caffe不太一樣吨凑,在caffe中,我們在訓(xùn)練網(wǎng)絡(luò)中定義好了參數(shù)的初始化方式户辱,網(wǎng)絡(luò)加載時(shí)鸵钝,程序會根據(jù)網(wǎng)絡(luò)定義,自動(dòng)初始化權(quán)值庐镐,我們只需要對這個(gè)網(wǎng)絡(luò)恩商,使用solver不斷的前傳和反傳,更新參數(shù)即可必逆。在caffe2中怠堪,我們要把所有網(wǎng)絡(luò)的搭建、初始化名眉、梯度生成粟矿、梯度更新都使用operator這樣一個(gè)方式來實(shí)現(xiàn),所有的數(shù)據(jù)的生成损拢、流動(dòng)都要在圖中反映出來陌粹。這樣,那么初始化這一部分我就需要一些operators來實(shí)現(xiàn)探橱,這些operators組成的net申屹,我們把它單獨(dú)拿出來,稱它為用于初始化的網(wǎng)絡(luò)隧膏。我們可以結(jié)合著代碼來理解哗讥。

首先,我們創(chuàng)建一個(gè)生成訓(xùn)練數(shù)據(jù)和初始化權(quán)值的網(wǎng)絡(luò)胞枕。

init_net = core.Net("init")
# The ground truth parameters.
W_gt = init_net.GivenTensorFill(
    [], "W_gt", shape=[1, 2], values=[2.0, 1.5])
B_gt = init_net.GivenTensorFill([], "B_gt", shape=[1], values=[0.5])
# Constant value ONE is used in weighted sum when updating parameters.
ONE = init_net.ConstantFill([], "ONE", shape=[1], value=1.)
# ITER is the iterator count.
ITER = init_net.ConstantFill([], "ITER", shape=[1], value=0, dtype=core.DataType.INT32)

# For the parameters to be learned: we randomly initialize weight
# from [-1, 1] and init bias with 0.0.
W = init_net.UniformFill([], "W", shape=[1, 2], min=-1., max=1.)
B = init_net.ConstantFill([], "B", shape=[1], value=0.0)
print('Created init net.')

接下來杆煞,我們定義一個(gè)用來訓(xùn)練的網(wǎng)絡(luò)。

train_net = core.Net("train")
# First, we generate random samples of X and create the ground truth.
X = train_net.GaussianFill([], "X", shape=[64, 2], mean=0.0, std=1.0, run_once=0)
Y_gt = X.FC([W_gt, B_gt], "Y_gt")
# We add Gaussian noise to the ground truth
noise = train_net.GaussianFill([], "noise", shape=[64, 1], mean=0.0, std=1.0, run_once=0)
Y_noise = Y_gt.Add(noise, "Y_noise")
# Note that we do not need to propagate the gradients back through Y_noise,
# so we mark StopGradient to notify the auto differentiating algorithm
# to ignore this path.
Y_noise = Y_noise.StopGradient([], "Y_noise")

# Now, for the normal linear regression prediction, this is all we need.
Y_pred = X.FC([W, B], "Y_pred")

# The loss function is computed by a squared L2 distance, and then averaged
# over all items in the minibatch.
dist = train_net.SquaredL2Distance([Y_noise, Y_pred], "dist")
loss = dist.AveragedLoss([], ["loss"])

我們來畫出我們定義的訓(xùn)練網(wǎng)絡(luò)的圖:

graph = net_drawer.GetPydotGraph(train_net.Proto().op, "train", rankdir="LR")
display.Image(graph.create_png(), width=800)

在這里,通過上面的圖决乎,我們可以看到init_net部分生成了訓(xùn)練數(shù)據(jù)队询、初始化的權(quán)值W,以及用來生成計(jì)算過程中需要的常數(shù)矩陣构诚,而train_net構(gòu)建了前向計(jì)算過程蚌斩。

但是我們還沒有定義如何反向傳導(dǎo),和很多其他的深度學(xué)習(xí)框架類似范嘱,caffe2支持自動(dòng)梯度推導(dǎo)送膳,自動(dòng)生成產(chǎn)生梯度的operator。

接下來丑蛤,我們給train_net加上梯度運(yùn)算:

# Get gradients for all the computations above.
gradient_map = train_net.AddGradientOperators([loss])
graph = net_drawer.GetPydotGraph(train_net.Proto().op, "train", rankdir="LR")
display.Image(graph.create_png(), width=800)

可以看到叠聋,網(wǎng)絡(luò)后半部分進(jìn)行了求梯度運(yùn)算,輸出了各學(xué)習(xí)參數(shù)的梯度值受裹,當(dāng)我們得到這些梯度值后碌补,我們再獲得當(dāng)前訓(xùn)練的學(xué)習(xí)率,我們就可以使用梯度下降方法更新參數(shù)棉饶。

接下來厦章,我們在train_net加上SGD更新的部分:

# Increment the iteration by one.
train_net.Iter(ITER, ITER)
# Compute the learning rate that corresponds to the iteration.
LR = train_net.LearningRate(ITER, "LR", base_lr=-0.1,
                            policy="step", stepsize=20, gamma=0.9)

# Weighted sum
train_net.WeightedSum([W, ONE, gradient_map[W], LR], W)
train_net.WeightedSum([B, ONE, gradient_map[B], LR], B)

# Let's show the graph again.
graph = net_drawer.GetPydotGraph(train_net.Proto().op, "train", rankdir="LR")
display.Image(graph.create_png(), width=800)

到這里,整個(gè)模型的參數(shù)初始化照藻、前傳闷袒、反傳、梯度更新全都使用operator定義好了岩梳。這個(gè)就是caffe2中使用operator的威力晃择,它使得caffe2較caffe具有不可比擬的靈活性冀值。在這里注意,我們只是定義了網(wǎng)絡(luò)宫屠,還沒有運(yùn)行網(wǎng)絡(luò)列疗,下面讓我們來運(yùn)行它們:

workspace.RunNetOnce(init_net)
workspace.CreateNet(train_net)
print("Before training, W is: {}".format(workspace.FetchBlob("W")))
print("Before training, B is: {}".format(workspace.FetchBlob("B")))
True
Before training, W is: [[-0.77634162 -0.88467366]]
Before training, B is: [ 0.]
#run the train net 100 times 
for i in range(100):
    workspace.RunNet(train_net.Proto().name)
    
print("After training, W is: {}".format(workspace.FetchBlob("W")))
print("After training, B is: {}".format(workspace.FetchBlob("B")))
print("Ground truth W is: {}".format(workspace.FetchBlob("W_gt")))
print("Ground truth B is: {}".format(workspace.FetchBlob("B_gt")))

在這里,我們需要注意一點(diǎn)浪蹂,我們使用了RunNetOnce和RunNet兩種不同的方式來運(yùn)行網(wǎng)絡(luò)抵栈,還記得兩種運(yùn)行網(wǎng)絡(luò)的方式么?

  • 方法1:使用workspace.RunNetOnce,這個(gè)函數(shù)會初始化網(wǎng)絡(luò)坤次,運(yùn)行網(wǎng)絡(luò)古劲,然后銷毀網(wǎng)絡(luò)。
  • 方法2:先使用workspace.CreateNet初始化網(wǎng)絡(luò)缰猴,然后使用workspace.RunNet來運(yùn)行網(wǎng)絡(luò)

一開始我也不明白為什么要有兩種方式運(yùn)行網(wǎng)絡(luò)产艾,現(xiàn)在結(jié)合init_net和train_net來看,就非常明白了。RunNetOnce用來運(yùn)行生成權(quán)值和數(shù)據(jù)的網(wǎng)絡(luò)闷堡,常用于初始化隘膘,這樣的網(wǎng)絡(luò)一次生成完,權(quán)值輸出或數(shù)據(jù)就存在當(dāng)前的workspace中杠览,網(wǎng)絡(luò)本身就沒有存在的必要了弯菊,就直接銷毀,而RunNet可以用來重復(fù)訓(xùn)練網(wǎng)絡(luò)踱阿,一開始使用CreateNet管钳,不斷迭代調(diào)用RunNet就可以不斷運(yùn)行網(wǎng)絡(luò)更新參數(shù)了。

以下是訓(xùn)練結(jié)果:

After training, W is: [[ 1.95769441  1.47348857]]
After training, B is: [ 0.45236012]
Ground truth W is: [[ 2.   1.5]]
Ground truth B is: [ 0.5]

扫茅,總結(jié)一下:

  • caffe2中使用operator完成初始化參數(shù)蹋嵌、前傳、反傳葫隙、梯度更新
  • caffe2中一個(gè)模型通常包含一個(gè)初始化網(wǎng)絡(luò)栽烂,一個(gè)訓(xùn)練網(wǎng)絡(luò)

最后,還要說明一點(diǎn)恋脚,這個(gè)例子中腺办,我們直接使用operator來構(gòu)建網(wǎng)絡(luò)。對于常見的深度網(wǎng)絡(luò)糟描,直接用operator構(gòu)建會步驟會非常繁瑣怀喉,所以caffe2中為了簡化網(wǎng)絡(luò)的搭建,又封裝了model_helper類來幫助我們方便地搭建網(wǎng)絡(luò)船响,譬如對于卷積神經(jīng)網(wǎng)絡(luò)中的常見的層躬拢,我們就可以直接使用model_helper來構(gòu)建。在之后的栗子中也有說明见间。

栗子二-圖像預(yù)處理

眾所周知聊闯,網(wǎng)絡(luò)中訓(xùn)練需要做一系列的數(shù)據(jù)預(yù)處理,在這里米诉,caffe和caffe2中處理的方式一樣菱蔬。都需要經(jīng)過XXX等步。因?yàn)闆]有什么區(qū)別史侣,在這里就不舉了拴泌,直接參考官方教程Image Pre-Processing,解釋非常清楚惊橱。給個(gè)贊蚪腐。

栗子三-加載預(yù)訓(xùn)練模型

首先,我們使用一個(gè)caffe2中定義的下載模塊去下載一個(gè)預(yù)訓(xùn)練好的模型李皇,命令行中輸入如下的命令會下載squeezenet這個(gè)預(yù)訓(xùn)練模型:

python -m caffe2.python.models.download -i squeezenet

當(dāng)下載完成時(shí)削茁,在caffe2/python/model底下有一個(gè)squeezenet文件宙枷,文件夾底下有兩個(gè)文件init_net.pb,predict_net.pb分別保存了權(quán)值和網(wǎng)絡(luò)定義。

在python中我們使用caffe2的workspace來存放這個(gè)模型的網(wǎng)絡(luò)定義和權(quán)重茧跋,并且把它們加載到blob慰丛、init_net和predict_net。我們需要使用一個(gè)workspace.Predictor來接收兩個(gè)protobuf瘾杭,然后剩下的就可以交給caffe2了诅病。

所以一般加載預(yù)測模型只需要幾步:

1、讀入protobuf文件

 with open("init_net.pb") as f:
     init_net = f.read()
 with open("predict_net.pb") as f:
     predict_net = f.read()      

2粥烁、使用workspace中的Predictor來加載從protobuf中取到的blobs:

 p = workspace.Predictor(init_net, predict_net)

3贤笆、運(yùn)行網(wǎng)絡(luò),得到結(jié)果:

 results = p.run([img])

需要注意的這里的img是預(yù)處理過的圖像讨阻。

以下是官方文檔下的一個(gè)完整的栗子:

首先配置一下問文件路徑等芥永,導(dǎo)入常用包:

# where you installed caffe2. Probably '~/caffe2' or '~/src/caffe2'.
CAFFE2_ROOT = "~/caffe2"
# assumes being a subdirectory of caffe2
CAFFE_MODELS = "~/caffe2/caffe2/python/models"
# if you have a mean file, place it in the same dir as the model

%matplotlib inline
from caffe2.proto import caffe2_pb2
import numpy as np
import skimage.io
import skimage.transform
from matplotlib import pyplot
import os
from caffe2.python import core, workspace
import urllib2
print("Required modules imported.")
IMAGE_LOCATION =  "https://cdn.pixabay.com/photo/2015/02/10/21/28/flower-631765_1280.jpg"

# What model are we using? You should have already converted or downloaded one.
# format below is the model's:
# folder, INIT_NET, predict_net, mean, input image size
# you can switch the comments on MODEL to try out different model conversions
MODEL = 'squeezenet', 'init_net.pb', 'predict_net.pb', 'ilsvrc_2012_mean.npy', 227

# codes - these help decypher the output and source from a list from AlexNet's object codes to provide an result like "tabby cat" or "lemon" depending on what's in the picture you submit to the neural network.
# The list of output codes for the AlexNet models (also squeezenet)
codes =  "https://gist.githubusercontent.com/aaronmarkham/cd3a6b6ac071eca6f7b4a6e40e6038aa/raw/9edb4038a37da6b5a44c3b5bc52e448ff09bfe5b/alexnet_codes"
print "Config set!"

定義數(shù)據(jù)預(yù)處理的函數(shù):

def crop_center(img,cropx,cropy):
    y,x,c = img.shape
    startx = x//2-(cropx//2)
    starty = y//2-(cropy//2)    
    return img[starty:starty+cropy,startx:startx+cropx]

def rescale(img, input_height, input_width):
    print("Original image shape:" + str(img.shape) + " and remember it should be in H, W, C!")
    print("Model's input shape is %dx%d") % (input_height, input_width)
    aspect = img.shape[1]/float(img.shape[0])
    print("Orginal aspect ratio: " + str(aspect))
    if(aspect>1):
        # landscape orientation - wide image
        res = int(aspect * input_height)
        imgScaled = skimage.transform.resize(img, (input_width, res))
    if(aspect<1):
        # portrait orientation - tall image
        res = int(input_width/aspect)
        imgScaled = skimage.transform.resize(img, (res, input_height))
    if(aspect == 1):
        imgScaled = skimage.transform.resize(img, (input_width, input_height))
    pyplot.figure()
    pyplot.imshow(imgScaled)
    pyplot.axis('on')
    pyplot.title('Rescaled image')
    print("New image shape:" + str(imgScaled.shape) + " in HWC")
    return imgScaled
print "Functions set."

# set paths and variables from model choice and prep image
CAFFE2_ROOT = os.path.expanduser(CAFFE2_ROOT)
CAFFE_MODELS = os.path.expanduser(CAFFE_MODELS)

# mean can be 128 or custom based on the model
# gives better results to remove the colors found in all of the training images
MEAN_FILE = os.path.join(CAFFE_MODELS, MODEL[0], MODEL[3])
if not os.path.exists(MEAN_FILE):
    mean = 128
else:
    mean = np.load(MEAN_FILE).mean(1).mean(1)
    mean = mean[:, np.newaxis, np.newaxis]
print "mean was set to: ", mean

# some models were trained with different image sizes, this helps you calibrate your image
INPUT_IMAGE_SIZE = MODEL[4]

# make sure all of the files are around...
if not os.path.exists(CAFFE2_ROOT):
    print("Houston, you may have a problem.")
INIT_NET = os.path.join(CAFFE_MODELS, MODEL[0], MODEL[1])
print 'INIT_NET = ', INIT_NET
PREDICT_NET = os.path.join(CAFFE_MODELS, MODEL[0], MODEL[2])
print 'PREDICT_NET = ', PREDICT_NET
if not os.path.exists(INIT_NET):
    print(INIT_NET + " not found!")
else:
    print "Found ", INIT_NET, "...Now looking for", PREDICT_NET
    if not os.path.exists(PREDICT_NET):
        print "Caffe model file, " + PREDICT_NET + " was not found!"
    else:
        print "All needed files found! Loading the model in the next block."

# load and transform image
img = skimage.img_as_float(skimage.io.imread(IMAGE_LOCATION)).astype(np.float32)
img = rescale(img, INPUT_IMAGE_SIZE, INPUT_IMAGE_SIZE)
img = crop_center(img, INPUT_IMAGE_SIZE, INPUT_IMAGE_SIZE)
print "After crop: " , img.shape
pyplot.figure()
pyplot.imshow(img)
pyplot.axis('on')
pyplot.title('Cropped')

# switch to CHW
img = img.swapaxes(1, 2).swapaxes(0, 1)
pyplot.figure()
for i in range(3):
    # For some reason, pyplot subplot follows Matlab's indexing
    # convention (starting with 1). Well, we'll just follow it...
    pyplot.subplot(1, 3, i+1)
    pyplot.imshow(img[i])
    pyplot.axis('off')
    pyplot.title('RGB channel %d' % (i+1))

# switch to BGR
img = img[(2, 1, 0), :, :]

# remove mean for better results
img = img * 255 - mean

# add batch size
img = img[np.newaxis, :, :, :].astype(np.float32)
print "NCHW: ", img.shape

運(yùn)行一下,輸出結(jié)果:

Functions set.
mean was set to:  128
INIT_NET =  /home/aaron/models/squeezenet/init_net.pb
PREDICT_NET =  /home/aaron/models/squeezenet/predict_net.pb
Found  /home/aaron/models/squeezenet/init_net.pb ...Now looking for /home/aaron/models/squeezenet/predict_net.pb
All needed files found! Loading the model in the next block.
Original image shape:(751, 1280, 3) and remember it should be in H, W, C!
Model's input shape is 227x227
Orginal aspect ratio: 1.70439414115
New image shape:(227, 386, 3) in HWC
After crop:  (227, 227, 3)
NCHW:  (1, 3, 227, 227)
image output
image output
image output

當(dāng)圖像經(jīng)過處理之后钝吮,就可以按照前面的安排加載和運(yùn)行網(wǎng)絡(luò)埋涧。

# initialize the neural net

with open(INIT_NET) as f:
    init_net = f.read()
with open(PREDICT_NET) as f:
    predict_net = f.read()

p = workspace.Predictor(init_net, predict_net)

# run the net and return prediction
results = p.run([img])

# turn it into something we can play with and examine which is in a multi-dimensional array
results = np.asarray(results)
print "results shape: ", results.shape
results shape:  (1, 1, 1000, 1, 1)

這里輸出來了1000個(gè)值,表示這張圖片分別對應(yīng)1000類的概率奇瘦。我們可以取出來其中概率最高的值棘催,來找到它對應(yīng)的標(biāo)簽:

# the rest of this is digging through the results

results = np.delete(results, 1)
index = 0
highest = 0
arr = np.empty((0,2), dtype=object)
arr[:,0] = int(10)
arr[:,1:] = float(10)
for i, r in enumerate(results):
    # imagenet index begins with 1!
    i=i+1
    arr = np.append(arr, np.array([[i,r]]), axis=0)
    if (r > highest):
        highest = r
        index = i

print index, " :: ", highest

# lookup the code and return the result
# top 3 results
# sorted(arr, key=lambda x: x[1], reverse=True)[:3]

# now we can grab the code list
response = urllib2.urlopen(codes)

# and lookup our result from the list
for line in response:
    code, result = line.partition(":")[::2]
    if (code.strip() == str(index)):
        print result.strip()[1:-2]
985  ::  0.979059
daisy

栗子四-創(chuàng)建一個(gè)CNN模型

1、模型耳标、幫助函數(shù)醇坝、brew

在前面我們已經(jīng)基本介紹了在python中關(guān)于caffe2中基本的操作。

這個(gè)例子中次坡,我們來簡單搭建一個(gè)CNN模型呼猪。在這個(gè)需要說明一點(diǎn):

  • 在caffe中,我們通常說一個(gè)模型砸琅,其實(shí)就是一個(gè)網(wǎng)絡(luò)郑叠,一個(gè)Net
  • 而在caffe2中,我們通常使用modelHelper來代表一個(gè)model明棍,而這個(gè)model包含多個(gè)Net,就像我們前面看到的寇僧,我們會使用一個(gè)初始化網(wǎng)絡(luò)init_net摊腋,還有有一個(gè)訓(xùn)練網(wǎng)絡(luò)net,這兩個(gè)網(wǎng)絡(luò)圖都是model的一部分嘁傀。

這一點(diǎn)需要大家區(qū)分開兴蒸,不然容易疑惑。舉例细办,如果我們要構(gòu)造一個(gè)模型橙凳,只有一個(gè)FC層蕾殴,在這里使用modelHelper來表示一個(gè)model,使用operators來構(gòu)造網(wǎng)絡(luò)岛啸,一般model有一個(gè)param_init_net和一個(gè)net钓觉。分別用于模型初始化和訓(xùn)練:

model = model_helper.ModelHelper(name="train")
# initialize your weight
weight = model.param_init_net.XavierFill(
    [],
    blob_out + '_w',
    shape=[dim_out, dim_in],
    **kwargs, # maybe indicating weight should be on GPU here
)
# initialize your bias
bias = model.param_init_net.ConstantFill(
    [],
    blob_out + '_b',
    shape=[dim_out, ],
    **kwargs,
)
# finally building FC
model.net.FC([blob_in, weights, bias], blob_out, **kwargs)

前面,我們說過在日常搭建網(wǎng)絡(luò)的時(shí)候呢坚踩,我們通常不是完全使用operator搭建網(wǎng)絡(luò)荡灾,因?yàn)槭褂眠@種方式,每個(gè)參數(shù)都需要我們手動(dòng)初始化瞬铸,以及每個(gè)operator都需要構(gòu)造批幌,太過于繁瑣。我們想著嗓节,對于常用層荧缘,能不能把構(gòu)造它的operators都封裝起來,封裝成一個(gè)函數(shù)拦宣,我們構(gòu)造時(shí)只需給這個(gè)函數(shù)要提供必要的參數(shù)截粗,函數(shù)中的代碼就能幫助我們完成層初始化和operator的構(gòu)建。

在caffe2中恢着,為了便于開發(fā)者搭建網(wǎng)絡(luò)桐愉,caffe2在python/helpers中提供了許多help函數(shù),像上面例子中的FC層掰派,使用python/helpers/fc.py來構(gòu)造从诲,非常簡單就一行代碼:

fcLayer = fc(model, blob_in, blob_out, **kwargs) # returns a blob reference

這里面help函數(shù)能夠幫助我們將權(quán)值初始化和計(jì)算網(wǎng)絡(luò)自動(dòng)分開到兩個(gè)網(wǎng)絡(luò),這樣一來就簡單多了靡羡。caffe2為了更方便調(diào)用和管理系洛,把這些幫助函數(shù)集合到一起,放在brew這個(gè)包里面略步∶璩叮可以通過導(dǎo)入brew這個(gè)包來調(diào)用這些幫助函數(shù)。像上面的fc層的實(shí)現(xiàn)就可以使用:

from caffe2.python import brew
brew.fc(model, blob_in, blob_out, ...)

我們使用brew構(gòu)造網(wǎng)絡(luò)就十分簡單趟薄,下面的代碼就構(gòu)造了一個(gè)LeNet模型:

from caffe2.python import brew

def AddLeNetModel(model, data):
    conv1 = brew.conv(model, data, 'conv1', 1, 20, 5)
    pool1 = brew.max_pool(model, conv1, 'pool1', kernel=2, stride=2)
    conv2 = brew.conv(model, pool1, 'conv2', 20, 50, 5)
    pool2 = brew.max_pool(model, conv2, 'pool2', kernel=2, stride=2)
    fc3 = brew.fc(model, pool2, 'fc3', 50 * 4 * 4, 500)
    fc3 = brew.relu(model, fc3, fc3)
    pred = brew.fc(model, fc3, 'pred', 500, 10)
    softmax = brew.softmax(model, pred, 'softmax')

caffe2 使用brew提供很多構(gòu)造網(wǎng)絡(luò)的幫助函數(shù)绽诚,大大簡化了我們構(gòu)建網(wǎng)絡(luò)的過程。但實(shí)際上杭煎,這些只是封裝的結(jié)果恩够,網(wǎng)絡(luò)構(gòu)造的原理和之前說的使用operators構(gòu)建的原理是一樣的。

2羡铲、創(chuàng)建一個(gè)CNN模型用于MNIST手寫體數(shù)據(jù)集

首先蜂桶,導(dǎo)入必要的包:

%matplotlib inline
from matplotlib import pyplot
import numpy as np
import os
import shutil


from caffe2.python import core, model_helper, net_drawer, workspace, visualize, brew

# If you would like to see some really detailed initializations,
# you can change --caffe2_log_level=0 to --caffe2_log_level=-1
core.GlobalInit(['caffe2', '--caffe2_log_level=0'])
print("Necessities imported!")

下載MNIST dataset,并且把數(shù)據(jù)集轉(zhuǎn)成leveldb:

./make_mnist_db --channel_first --db leveldb --image_file ~/Downloads/train-images-idx3-ubyte --label_file ~/Downloads/train-labels-idx1-ubyte --output_file ~/caffe2_notebooks/tutorial_data/mnist/mnist-train-nchw-leveldb

./make_mnist_db --channel_first --db leveldb --image_file ~/Downloads/t10k-images-idx3-ubyte --label_file ~/Downloads/t10k-labels-idx1-ubyte --output_file ~/caffe2_notebooks/tutorial_data/mnist/mnist-test-nchw-leveldb

# This section preps your image and test set in a leveldb
current_folder = os.path.join(os.path.expanduser('~'), 'caffe2_notebooks')

data_folder = os.path.join(current_folder, 'tutorial_data', 'mnist')
root_folder = os.path.join(current_folder, 'tutorial_files', 'tutorial_mnist')
image_file_train = os.path.join(data_folder, "train-images-idx3-ubyte")
label_file_train = os.path.join(data_folder, "train-labels-idx1-ubyte")
image_file_test = os.path.join(data_folder, "t10k-images-idx3-ubyte")
label_file_test = os.path.join(data_folder, "t10k-labels-idx1-ubyte")

# Get the dataset if it is missing
def DownloadDataset(url, path):
    import requests, zipfile, StringIO
    print "Downloading... ", url, " to ", path
    r = requests.get(url, stream=True)
    z = zipfile.ZipFile(StringIO.StringIO(r.content))
    z.extractall(path)

def GenerateDB(image, label, name):
    name = os.path.join(data_folder, name)
    print 'DB: ', name
    if not os.path.exists(name):
        syscall = "/usr/local/bin/make_mnist_db --channel_first --db leveldb --image_file " + image + " --label_file " + label + " --output_file " + name
        # print "Creating database with: ", syscall
        os.system(syscall)
    else:
        print "Database exists already. Delete the folder if you have issues/corrupted DB, then rerun this."
        if os.path.exists(os.path.join(name, "LOCK")):
            # print "Deleting the pre-existing lock file"
            os.remove(os.path.join(name, "LOCK"))

            if not os.path.exists(data_folder):
                os.makedirs(data_folder)
            if not os.path.exists(label_file_train):
                DownloadDataset("https://download.caffe2.ai/datasets/mnist/mnist.zip", data_folder)

            if os.path.exists(root_folder):
                print("Looks like you ran this before, so we need to cleanup those old files...")
                shutil.rmtree(root_folder)

            os.makedirs(root_folder)
            workspace.ResetWorkspace(root_folder)

            # (Re)generate the leveldb database (known to get corrupted...)
            GenerateDB(image_file_train, label_file_train, "mnist-train-nchw-leveldb")
            GenerateDB(image_file_test, label_file_test, "mnist-test-nchw-leveldb")


            print("training data folder:" + data_folder)
            print("workspace root folder:" + root_folder)

在這里,我們使用modelHelper來代表我們的模型也切,使用brew和operators來搭建模型扑媚,modelHelper包含了兩個(gè)net腰湾,包括param_init_net和net,分別代表初始化網(wǎng)絡(luò)和主訓(xùn)練網(wǎng)絡(luò)疆股。

我們來一步一步分塊構(gòu)造模型:

(1)輸入部分(AddInput function)
(2)網(wǎng)絡(luò)計(jì)算部分(AddLeNetModel function)
(3)網(wǎng)絡(luò)訓(xùn)練部分,添加梯度運(yùn)算费坊,更新等(AddTrainingOperators function)
(4)記錄統(tǒng)計(jì)部分,打印一些統(tǒng)計(jì)數(shù)據(jù)來觀察(AddBookkeepingOperators function)

(1)輸入部分(AddInput function)

AddInput會從DB加載data押桃,AddInput加載完成之后葵萎,和得到data 和label:

- data with shape `(batch_size, num_channels, width, height)`
    - in this case `[batch_size, 1, 28, 28]` of data type *uint8*
- label with shape `[batch_size]` of data type *int*
def AddInput(model, batch_size, db, db_type):
    # load the data
    data_uint8, label = model.TensorProtosDBInput(
        [], ["data_uint8", "label"], batch_size=batch_size,
        db=db, db_type=db_type)
    # cast the data to float
    data = model.Cast(data_uint8, "data", to=core.DataType.FLOAT)
    # scale data from [0,255] down to [0,1]
    data = model.Scale(data, data, scale=float(1./256))
    # don't need the gradient for the backward pass
    data = model.StopGradient(data, data)
    return data, label

在這里簡單解釋一下AddInput中的一些操作,首先將data轉(zhuǎn)換成float類型唱凯,這樣做是因?yàn)槲覀冎饕龈↑c(diǎn)運(yùn)算羡忘。為了保證計(jì)算穩(wěn)定,我們將圖像從[0,255]縮放到[0,1]磕昼,并且這里做的事占位運(yùn)算卷雕,不需要保存未縮放之前的值。當(dāng)計(jì)算反向過程中票从,這一部分不需要計(jì)算梯度漫雕,我們使用StopGradient來禁止梯度反傳,這樣自動(dòng)生成梯度時(shí)峰鄙,這個(gè)operator和它之前的operator就不會變了浸间。

def AddInput(model, batch_size, db, db_type):
    # load the data
    data_uint8, label = model.TensorProtosDBInput(
        [], ["data_uint8", "label"], batch_size=batch_size,
        db=db, db_type=db_type)
    # cast the data to float
    data = model.Cast(data_uint8, "data", to=core.DataType.FLOAT)
    # scale data from [0,255] down to [0,1]
    data = model.Scale(data, data, scale=float(1./256))
    # don't need the gradient for the backward pass
    data = model.StopGradient(data, data)
    return data, label

在這個(gè)基礎(chǔ)上,就是加入網(wǎng)絡(luò)AddLenetModel吟榴,同時(shí)加入一個(gè)AddAccuracy來追蹤模型的準(zhǔn)確率:

def AddLeNetModel(model, data):
    # Image size: 28 x 28 -> 24 x 24
    conv1 = brew.conv(model, data, 'conv1', dim_in=1, dim_out=20, kernel=5)
    # Image size: 24 x 24 -> 12 x 12
    pool1 = brew.max_pool(model, conv1, 'pool1', kernel=2, stride=2)
    # Image size: 12 x 12 -> 8 x 8
    conv2 = brew.conv(model, pool1, 'conv2', dim_in=20, dim_out=50, kernel=5)
    # Image size: 8 x 8 -> 4 x 4
    pool2 = brew.max_pool(model, conv2, 'pool2', kernel=2, stride=2)
    # 50 * 4 * 4 stands for dim_out from previous layer multiplied by the image size
    fc3 = brew.fc(model, pool2, 'fc3', dim_in=50 * 4 * 4, dim_out=500)
    fc3 = brew.relu(model, fc3, fc3)
    pred = brew.fc(model, fc3, 'pred', 500, 10)
    softmax = brew.softmax(model, pred, 'softmax')
    return softmax

def AddAccuracy(model, softmax, label):
    accuracy = model.Accuracy([softmax, label], "accuracy")
    return accuracy

接下來魁蒜,我們將加入梯度生成和更新,這部分由AddTrainingOperators實(shí)現(xiàn)吩翻,梯度生成和更新和之前例子中的原理一樣兜看。

def AddTrainingOperators(model, softmax, label):

# something very important happens here
xent = model.LabelCrossEntropy([softmax, label], 'xent')
# compute the expected loss
loss = model.AveragedLoss(xent, "loss")
# track the accuracy of the model
AddAccuracy(model, softmax, label)
# use the average loss we just computed to add gradient operators to the model
model.AddGradientOperators([loss])
# do a simple stochastic gradient descent
ITER = model.Iter("iter")
# set the learning rate schedule
LR = model.LearningRate(
    ITER, "LR", base_lr=-0.1, policy="step", stepsize=1, gamma=0.999 )
# ONE is a constant value that is used in the gradient update. We only need
# to create it once, so it is explicitly placed in param_init_net.
ONE = model.param_init_net.ConstantFill([], "ONE", shape=[1], value=1.0)
# Now, for each parameter, we do the gradient updates.
for param in model.params:
    # Note how we get the gradient of each parameter - ModelHelper keeps
    # track of that.
    param_grad = model.param_to_grad[param]
    # The update is a simple weighted sum: param = param + param_grad * LR
    model.WeightedSum([param, ONE, param_grad, LR], param)
# let's checkpoint every 20 iterations, which should probably be fine.
# you may need to delete tutorial_files/tutorial-mnist to re-run the tutorial
model.Checkpoint([ITER] + model.params, [],
               db="mnist_lenet_checkpoint_%05d.leveldb",
               db_type="leveldb", every=20)

接下來,我們使用AddBookkeepingOperations來打印一些統(tǒng)計(jì)數(shù)據(jù)供我們之后觀察狭瞎,這一部分不影響訓(xùn)練部分细移,只是統(tǒng)計(jì),打印日志熊锭。

def AddBookkeepingOperators(model):
    # Print basically prints out the content of the blob. to_file=1 routes the
    # printed output to a file. The file is going to be stored under
    #     root_folder/[blob name]
    model.Print('accuracy', [], to_file=1)
    model.Print('loss', [], to_file=1)
    # Summarizes the parameters. Different from Print, Summarize gives some
    # statistics of the parameter, such as mean, std, min and max.
    for param in model.params:
        model.Summarize(param, [], to_file=1)
        model.Summarize(model.param_to_grad[param], [], to_file=1)
    # Now, if we really want to be verbose, we can summarize EVERY blob
    # that the model produces; it is probably not a good idea, because that
    # is going to take time - summarization do not come for free. For this
    # demo, we will only show how to summarize the parameters and their
    # gradients.
print("Bookkeeping function created")

在這里弧轧,我們一共做了四件事:

(1)輸入部分(AddInput function)
(2)網(wǎng)絡(luò)計(jì)算部分(AddLeNetModel function)
(3)網(wǎng)絡(luò)訓(xùn)練部分,添加梯度運(yùn)算,更新等(AddTrainingOperators function)
(4)記錄統(tǒng)計(jì)部分碗殷,打印一些統(tǒng)計(jì)數(shù)據(jù)來觀察(AddBookkeepingOperators function)

基本的操作我們都定義好了劣针,接下來調(diào)用定義模型,在這里亿扁,它定義了一個(gè)訓(xùn)練模型,用于訓(xùn)練鸟廓,一個(gè)部署模型从祝,用于部署:

arg_scope = {"order": "NCHW"}
train_model = model_helper.ModelHelper(name="mnist_train", arg_scope=arg_scope)
data, label = AddInput(
    train_model, batch_size=64,
    db=os.path.join(data_folder, 'mnist-train-nchw-leveldb'),
    db_type='leveldb')
softmax = AddLeNetModel(train_model, data)
AddTrainingOperators(train_model, softmax, label)
AddBookkeepingOperators(train_model)

# Testing model. We will set the batch size to 100, so that the testing
# pass is 100 iterations (10,000 images in total).
# For the testing model, we need the data input part, the main LeNetModel
# part, and an accuracy part. Note that init_params is set False because
# we will be using the parameters obtained from the train model.
test_model = model_helper.ModelHelper(
    name="mnist_test", arg_scope=arg_scope, init_params=False)
data, label = AddInput(
    test_model, batch_size=100,
    db=os.path.join(data_folder, 'mnist-test-nchw-leveldb'),
    db_type='leveldb')
softmax = AddLeNetModel(test_model, data)
AddAccuracy(test_model, softmax, label)

# Deployment model. We simply need the main LeNetModel part.
deploy_model = model_helper.ModelHelper(
    name="mnist_deploy", arg_scope=arg_scope, init_params=False)
AddLeNetModel(deploy_model, "data")
# You may wonder what happens with the param_init_net part of the deploy_model.
# No, we will not use them, since during deployment time we will not randomly
# initialize the parameters, but load the parameters from the db.

運(yùn)行網(wǎng)絡(luò)襟己,打印loss曲線:

# The parameter initialization network only needs to be run once.
workspace.RunNetOnce(train_model.param_init_net)
# creating the network
workspace.CreateNet(train_model.net)
# set the number of iterations and track the accuracy & loss
total_iters = 200
accuracy = np.zeros(total_iters)
loss = np.zeros(total_iters)
# Now, we will manually run the network for 200 iterations.
for i in range(total_iters):
    workspace.RunNet(train_model.net.Proto().name)
    accuracy[i] = workspace.FetchBlob('accuracy')
    loss[i] = workspace.FetchBlob('loss')
# After the execution is done, let's plot the values.
pyplot.plot(loss, 'b')
pyplot.plot(accuracy, 'r')
pyplot.legend(('Loss', 'Accuracy'), loc='upper right')

我們也可以輸出來預(yù)測:

# Let's look at some of the data.
pyplot.figure()
data = workspace.FetchBlob('data')
_ = visualize.NCHW.ShowMultiple(data)
pyplot.figure()
softmax = workspace.FetchBlob('softmax')
_ = pyplot.plot(softmax[0], 'ro')
pyplot.title('Prediction for the first image')

記得我們也定義了一個(gè)test_model,我們可以運(yùn)行它得到測試集準(zhǔn)確率牍陌,雖然test_model的權(quán)值由train_model來加載擎浴,但是測試數(shù)據(jù)輸入還需要運(yùn)行param_init_net。

# run a test pass on the test net
workspace.RunNetOnce(test_model.param_init_net)
workspace.CreateNet(test_model.net)
test_accuracy = np.zeros(100)
for i in range(100):
    workspace.RunNet(test_model.net.Proto().name)
    test_accuracy[i] = workspace.FetchBlob('accuracy')
# After the execution is done, let's plot the values.
pyplot.plot(test_accuracy, 'r')
pyplot.title('Acuracy over test batches.')
print('test_accuracy: %f' % test_accuracy.mean())
test_accuracy: 0.946700

這樣毒涧,我們就簡單的完成了模型的搭建贮预、訓(xùn)練、部署契讲。

這個(gè)教程是caffe2的python接口教程仿吞。教程例子基本都是官方提供的,只是加了些自己的理解思路捡偏,也簡單對比了caffe唤冈,可能有疏忽和理解錯(cuò)的地方,敬請指正银伟。

2017.07.07 cskenken

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末你虹,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子彤避,更是在濱河造成了極大的恐慌傅物,老刑警劉巖,帶你破解...
    沈念sama閱讀 219,490評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件琉预,死亡現(xiàn)場離奇詭異董饰,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī)模孩,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,581評論 3 395
  • 文/潘曉璐 我一進(jìn)店門尖阔,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人榨咐,你說我怎么就攤上這事介却。” “怎么了块茁?”我有些...
    開封第一講書人閱讀 165,830評論 0 356
  • 文/不壞的土叔 我叫張陵齿坷,是天一觀的道長。 經(jīng)常有香客問我数焊,道長永淌,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,957評論 1 295
  • 正文 為了忘掉前任佩耳,我火速辦了婚禮遂蛀,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘干厚。我一直安慰自己李滴,他們只是感情好螃宙,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,974評論 6 393
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著所坯,像睡著了一般谆扎。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上芹助,一...
    開封第一講書人閱讀 51,754評論 1 307
  • 那天堂湖,我揣著相機(jī)與錄音,去河邊找鬼状土。 笑死无蜂,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的声诸。 我是一名探鬼主播酱讶,決...
    沈念sama閱讀 40,464評論 3 420
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼彼乌!你這毒婦竟也來了泻肯?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 39,357評論 0 276
  • 序言:老撾萬榮一對情侶失蹤慰照,失蹤者是張志新(化名)和其女友劉穎灶挟,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體毒租,經(jīng)...
    沈念sama閱讀 45,847評論 1 317
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡稚铣,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,995評論 3 338
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了墅垮。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片惕医。...
    茶點(diǎn)故事閱讀 40,137評論 1 351
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖算色,靈堂內(nèi)的尸體忽然破棺而出抬伺,到底是詐尸還是另有隱情,我是刑警寧澤灾梦,帶...
    沈念sama閱讀 35,819評論 5 346
  • 正文 年R本政府宣布峡钓,位于F島的核電站,受9級特大地震影響若河,放射性物質(zhì)發(fā)生泄漏能岩。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,482評論 3 331
  • 文/蒙蒙 一萧福、第九天 我趴在偏房一處隱蔽的房頂上張望拉鹃。 院中可真熱鬧,春花似錦、人聲如沸膏燕。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,023評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽煌寇。三九已至,卻和暖如春逾雄,著一層夾襖步出監(jiān)牢的瞬間阀溶,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,149評論 1 272
  • 我被黑心中介騙來泰國打工鸦泳, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留银锻,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 48,409評論 3 373
  • 正文 我出身青樓做鹰,卻偏偏與公主長得像击纬,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個(gè)殘疾皇子钾麸,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,086評論 2 355

推薦閱讀更多精彩內(nèi)容