自定义调试信息

Linux Ascend GPU CPU 模型调优 中级 高级

查看源文件    查看notebook    在线运行

概述

本文介绍如何使用MindSpore提供的CallbackmetricsPrint算子、日志打印等自定义能力,帮助用户快速调试训练网络。

Callback介绍

Callback是回调函数的意思,但它其实不是一个函数而是一个类,用户可以使用回调函数来观察训练过程中网络内部的状态和相关信息,或在特定时期执行特定动作。 例如监控loss、保存模型参数、动态调整参数、提前终止训练任务等。

MindSpore的Callback能力

MindSpore提供Callback能力,支持用户在训练/推理的特定阶段,插入自定义的操作。包括:

  • MindSpore框架提供的ModelCheckpointLossMonitorSummaryCollectorCallback类。

  • MindSpore支持用户自定义Callback

使用方法:在model.train方法中传入Callback对象,它可以是一个Callback列表,例:

ckpt_cb = ModelCheckpoint()
loss_cb = LossMonitor()
summary_cb = SummaryCollector(summary_dir='./summary_dir')
model.train(epoch, dataset, callbacks=[ckpt_cb, loss_cb, summary_cb])

ModelCheckpoint可以保存模型参数,以便进行再训练或推理。
LossMonitor可以在日志中输出loss,方便用户查看,同时它还会监控训练过程中的loss值变化情况,当loss值为NanInf时终止训练。
SummaryCollector 可以把训练过程中的信息存储到文件中,以便后续可视化展示。
在训练过程中,Callback列表会按照定义的顺序执行Callback函数。因此在定义过程中,需考虑Callback之间的依赖关系。

自定义Callback

用户可以基于Callback基类,根据自身的需求,实现自定义Callback

Callback基类定义如下所示:

class Callback():
    """Callback base class"""
    def begin(self, run_context):
        """Called once before the network executing."""
        pass

    def epoch_begin(self, run_context):
        """Called before each epoch beginning."""
        pass

    def epoch_end(self, run_context):
        """Called after each epoch finished."""
        pass

    def step_begin(self, run_context):
        """Called before each step beginning."""
        pass

    def step_end(self, run_context):
        """Called after each step finished."""
        pass

    def end(self, run_context):
        """Called once after network training."""
        pass

Callback可以把训练过程中的重要信息记录下来,通过一个字典类型变量cb_params传递给Callback对象, 用户可以在各个自定义的Callback中获取到相关属性,执行自定义操作。也可以自定义其他变量传递给cb_params对象。

cb_params中的主要属性包括:

  • loss_fn:损失函数

  • optimizer:优化器

  • train_dataset:训练的数据集

  • cur_epoch_num:当前的epoch数

  • cur_step_num:当前的step数

  • batch_num:一个epoch中step的数量

用户可以继承Callback基类自定义Callback对象。

下面通过两个例子,进一步了解自定义Callback的用法。

  • 在规定时间内终止训练。

    class StopAtTime(Callback):
        def __init__(self, run_time):
            super(StopAtTime, self).__init__()
            self.run_time = run_time*60
    
        def begin(self, run_context):
            cb_params = run_context.original_args()
            cb_params.init_time = time.time()
    
        def step_end(self, run_context):
            cb_params = run_context.original_args()
            epoch_num = cb_params.cur_epoch_num
            step_num = cb_params.cur_step_num
            loss = cb_params.net_outputs
            cur_time = time.time()
            if (cur_time - cb_params.init_time) > self.run_time:
                print("epoch: ", epoch_num, " step: ", step_num, " loss: ", loss)
                run_context.request_stop()
    

    实现逻辑为:通过run_context.original_args方法可以获取到cb_params字典,字典里会包含前文描述的主要属性信息。 同时可以对字典内的值进行修改和添加,上述用例中,在begin中定义一个init_time对象传递给cb_params字典。 在每次step_end会做出判断,当训练时间大于设置的时间阈值时,会向run_context传递终止训练的信号,提前终止训练,并打印当前的epochsteploss的值。

  • 保存训练过程中精度最高的checkpoint文件。

    class SaveCallback(Callback):
        def __init__(self, eval_model, ds_eval):
            super(SaveCallback, self).__init__()
            self.model = eval_model
            self.ds_eval = ds_eval
            self.acc = 0
    
        def step_end(self, run_context):
            cb_params = run_context.original_args()
            result = self.model.eval(self.ds_eval)
            if result['accuracy'] > self.acc:
                self.acc = result['accuracy']
                file_name = str(self.acc) + ".ckpt"
                save_checkpoint(save_obj=cb_params.train_network, ckpt_file_name=file_name)
                print("Save the maximum accuracy checkpoint,the accuracy is", self.acc)
    

    具体实现逻辑为:定义一个Callback对象,初始化对象接收model对象和ds_eval(验证数据集)。在step_end阶段验证模型的精度,当精度为当前最高时,自动触发保存checkpoint方法,保存当前的参数。

MindSpore metrics功能介绍

当训练结束后,可以使用metrics评估训练结果的好坏。

MindSpore提供了多种metrics评估指标,如:accuracylossprecisionrecallF1

用户可以定义一个metrics字典对象,里面包含多种指标,传递给model对象,通过model.eval来验证训练的效果。

metrics = {
    'accuracy': nn.Accuracy(),
    'loss': nn.Loss(),
    'precision': nn.Precision(),
    'recall': nn.Recall(),
    'f1_score': nn.F1()
}
model = Model(network=net, loss_fn=net_loss, optimizer=net_opt, metrics=metrics)
result = model.eval(ds_eval)

model.eval方法会返回一个字典,里面是传入metrics的指标和结果。

在eval过程中也可以使用Callback功能,用户可以调用相关API或自定义Callback方法实现想要的功能。

用户也可以定义自己的metrics类,通过继承Metric基类,并重写clearupdateeval三个方法即可实现。

Accuracy算子举例说明其内部实现原理:

Accuracy继承了EvaluationBase基类,重写了上述三个方法。

  • clear方法会把类中相关计算参数初始化。

  • update方法接受预测值和标签值,更新Accuracy内部变量。

  • eval方法会计算相关指标,返回计算结果。

调用Accuracyeval方法,即可得到计算结果。

通过如下代码可以更清楚了解到Accuracy是如何运行的:

x = Tensor(np.array([[0.2, 0.5], [0.3, 0.1], [0.9, 0.6]]))
y = Tensor(np.array([1, 0, 1]))
metric = Accuracy()
metric.clear()
metric.update(x, y)
accuracy = metric.eval()
print('Accuracy is ', accuracy)

输出:

Accuracy is 0.6667

Print算子功能介绍

MindSpore的自研Print算子可以将用户输入的Tensor或字符串信息打印出来,支持多字符串输入,多Tensor输入和字符串与Tensor的混合输入,输入参数以逗号隔开。目前Print算子仅支持在Ascend环境下使用。

Print算子使用方法与其他算子相同,在网络中的__init__声明算子并在construct进行调用,具体使用实例及输出结果如下:

import numpy as np
from mindspore import Tensor
import mindspore.ops as ops
import mindspore.nn as nn
import mindspore.context as context

context.set_context(mode=context.GRAPH_MODE)

class PrintDemo(nn.Cell):
    def __init__(self):
        super(PrintDemo, self).__init__()
        self.print = ops.Print()

    def construct(self, x, y):
        self.print('print Tensor x and Tensor y:', x, y)
        return x

x = Tensor(np.ones([2, 1]).astype(np.int32))
y = Tensor(np.ones([2, 2]).astype(np.int32))
net = PrintDemo()
output = net(x, y)

输出:

print Tensor x and Tensor y:
Tensor(shape=[2, 1], dtype=Int32, value=
[[1]
 [1]])
Tensor(shape=[2, 2], dtype=Int32, value=
[[1 1]
 [1 1]])

数据Dump功能介绍

训练网络时,若训练结果和预期有偏差,可以通过数据Dump功能保存算子的输入输出进行调试。详细Dump功能介绍参考Dump功能说明

同步Dump功能使用方法

同步Dump功能使用参考同步Dump操作步骤

异步Dump功能使用方法

异步Dump功能使用参考异步Dump操作步骤

Running Data Recorder

Running Data Recorder(RDR)是MindSpore提供训练程序运行时记录数据的功能。要记录的数据将会在MindSpore中进行预设,运行训练脚本时,如果MindSpore出现了运行异常,则会自动地导出MindSpore中预先记录的数据以辅助定位运行异常的原因。不同的运行异常将会导出不同的数据,比如出现Run task error异常,将会导出计算图、图执行顺序、内存分配等信息以辅助定位异常的原因。

并非所有运行异常都会导出数据,目前仅支持部分异常导出数据。

使用方法

通过配置文件配置RDR

  1. 创建配置文件mindspore_config.json

    {
        "rdr": {
            "enable": true,
            "path": "/home/mindspore/rdr"
        }
    }
    

    enable: 控制RDR功能是否开启 path: 设置RDR保存数据的路径。当前必须为绝对路径。

  2. 通过 context 配置RDR。

    context.set_context(env_config_path="./mindspore_config.json")
    

通过环境变量配置RDR

通过export MS_RDR_ENABLE=1来开启RDR, 然后设置RDR文件导出路径: export MS_RDR_PATH=/absolute/path.

用户设置的配置文件优先级高于环境变量。

异常处理

假如在Ascend 910上使用MindSpore进行训练,训练出现了Run task error异常。

这时我们到/home/mindspore/rdr目录中,可以看到有几个文件出现在该目录中,每一个文件都代表着一种数据。比如 hwopt_d_before_graph_0.ir 该文件为计算图文件。可以使用文本工具打开该文件,用以查看计算图,分析计算图是否符合预期。

内存复用

内存复用功能(Mem Reuse)是让不同的Tensor共用同样的一部分内存,以降低内存开销,支撑更大的网络,关闭后每个Tensor有自己独立的内存空间,Tensor间无共享内存。 MindSpore内存复用功能默认开启,可以通过以下方式手动控制该功能的关闭和开启。

使用方法

  1. 创建配置文件mindspore_config.json

    {
        "sys": {
            "mem_reuse": true
        }
    }
    

    mem_reuse: 控制内存复用功能是否开启,当设置为true时,控制内存复用功能开启,为false时,内存复用功能关闭。

  2. 通过 context 配置内存复用功能。

    context.set_context(env_config_path="./mindspore_config.json")
    

日志相关的环境变量和配置

MindSpore采用glog来输出日志,常用的几个环境变量如下:

  • GLOG_v

    该环境变量控制日志的级别。
    该环境变量默认值为2,即WARNING级别,对应关系如下:0-DEBUG、1-INFO、2-WARNING、3-ERROR。

  • GLOG_logtostderr

    该环境变量控制日志的输出方式。
    该环境变量的值设置为1时,日志输出到屏幕;值设置为0时,日志输出到文件。默认值为1。

  • GLOG_log_dir

    该环境变量指定日志输出的路径。
    GLOG_logtostderr的值为0,则必须设置此变量。
    若指定了GLOG_log_dirGLOG_logtostderr的值为1时,则日志输出到屏幕,不输出到文件。
    C++和Python的日志会被输出到不同的文件中,C++日志的文件名遵从GLOG日志文件的命名规则,这里是mindspore.机器名.用户名.log.日志级别.时间戳.进程ID,Python日志的文件名为mindspore.log.进程ID

  • MS_SUBMODULE_LOG_v

    该环境变量指定MindSpore C++各子模块的日志级别。
    该环境变量赋值方式为:MS_SUBMODULE_LOG_v="{SubModule1:LogLevel1,SubModule2:LogLevel2,...}"
    其中被指定子模块的日志级别将覆盖GLOG_v在此模块内的设置,此处子模块的日志级别LogLevelGLOG_v的日志级别含义相同,MindSpore子模块的划分如下表。
    例如可以通过GLOG_v=1 MS_SUBMODULE_LOG_v="{PARSER:2,ANALYZER:2}"PARSERANALYZER模块的日志级别设为WARNING,其他模块的日志级别设为INFO。

  • GLOG_stderrthreshold

    日志模块在将日志输出到文件的同时也会将日志打印到屏幕,该环境变量用于控制此种场景下打印到屏幕的日志级别。 该环境变量默认值为2,即WARNING级别,对应关系如下:0-DEBUG、1-INFO、2-WARNING、3-ERROR。

MindSpore子模块按照目录划分如下:

Source Files

Sub Module Name

mindspore/ccsrc/backend/kernel_compiler

KERNEL

mindspore/ccsrc/backend/optimizer

PRE_ACT

mindspore/ccsrc/backend/session

SESSION

mindspore/ccsrc/common

COMMON

mindspore/ccsrc/debug

DEBUG

mindspore/ccsrc/frontend/operator

ANALYZER

mindspore/ccsrc/frontend/optimizer

OPTIMIZER

mindspore/ccsrc/frontend/parallel

PARALLEL

mindspore/ccsrc/minddata/dataset

MD

mindspore/ccsrc/minddata/mindrecord

MD

mindspore/ccsrc/pipeline/jit/*.cc

PIPELINE

mindspore/ccsrc/pipeline/jit/parse

PARSER

mindspore/ccsrc/pipeline/jit/static_analysis

ANALYZER

mindspore/ccsrc/pipeline/pynative

PYNATIVE

mindspore/ccsrc/profiler

PROFILER

mindspore/ccsrc/pybind_api

COMMON

mindspore/ccsrc/runtime/device

DEVICE

mindspore/ccsrc/transform/graph_ir

GE_ADPT

mindspore/ccsrc/transform/express_ir

EXPRESS

mindspore/ccsrc/utils

UTILS

mindspore/ccsrc/vm

VM

mindspore/ccsrc

ME

mindspore/core/gvar

COMMON

mindspore/core/

CORE

glog不支持日志文件的绕接,如果需要控制日志文件对磁盘空间的占用,可选用操作系统提供的日志文件管理工具,例如:Linux的logrotate。