使用 Azure 机器学习数据集来训练模型

适用于：Python SDK azureml v1

本文介绍如何使用 Azure 机器学习数据集来训练机器学习模型。 可以在本地或远程计算目标中使用数据集，而不必考虑连接字符串或数据路径。

• 有关结构化数据，请参阅在机器学习训练脚本中使用数据集。

• 有关非结构化数据，请参阅将文件装载到远程计算目标。

Azure 机器学习数据集提供了与 Azure 机器学习训练功能（如 ScriptRunConfig、HyperDrive 和 Azure 机器学习管道）的无缝集成。

如果尚未准备好为模型训练提供数据，但需要将数据加载到笔记本进行数据浏览，请了解如何浏览数据集中的数据。

若要创建数据集并使用数据集进行训练，需要具有以下各项：

• Azure 订阅。 如果没有 Azure 订阅，请在开始前创建一个试用版订阅。 立即尝试试用版订阅。

• 一个 Azure 机器学习工作区。

• 已安装适用于 Python 的 Azure 机器学习 SDK (>= 1.13.0)，其中包含 azureml-datasets 包。

如果有尚未注册为数据集的结构化数据，请创建一个 TabularDataset，并在训练脚本中直接使用它进行本地或远程实验。

在此示例中，你创建一个未注册的 TabularDataset，并在 ScriptRunConfig 对象中将其指定为脚本参数，以便进行训练。 如果要在工作区中的其他实验中重用此 TabularDataset，请参见如何将数据集注册到工作区。

下面的代码从 Web URL 创建未注册的 TabularDataset。

from azureml.core.dataset import Dataset

web_path ='https://dprepdata.blob.core.windows.net/demo/Titanic.csv'
titanic_ds = Dataset.Tabular.from_delimited_files(path=web_path)

TabularDataset 对象提供将 TabularDataset 中的数据加载到 pandas 或 Spark 数据帧中的功能，以便你可以使用熟悉的数据准备和训练库，且无需离开笔记本。

下面的代码将配置脚本参数 --input-data，你将在配置训练运行时指定该参数（请参阅下一节）。 在将表格数据集作为参数值传入时，Azure ML 会将其解析为该数据集的 ID，然后你可以在训练脚本中使用该 ID 来访问该数据集（无需在脚本中对该数据集的名称或 ID 进行硬编码）。 然后，该脚本使用 to_pandas_dataframe() 方法将该数据集加载到 pandas 数据帧中，以便在训练之前进一步探索数据并做好准备。

如果需要从内存中的 pandas 数据帧将准备好的数据加载到新数据集中，请将这些数据写入到一个本地文件（如 parquet），然后从该文件创建新数据集。 详细了解如何创建数据集。

%%writefile $script_folder/train_titanic.py

import argparse
from azureml.core import Dataset, Run

parser = argparse.ArgumentParser()
parser.add_argument("--input-data", type=str)
args = parser.parse_args()

run = Run.get_context()
ws = run.experiment.workspace

# get the input dataset by ID
dataset = Dataset.get_by_id(ws, id=args.input_data)

# load the TabularDataset to pandas DataFrame
df = dataset.to_pandas_dataframe()

ScriptRunConfig 对象用于配置和提交训练运行。

此代码创建 ScriptRunConfig 对象 src，该对象指定以下内容：

• 脚本的脚本目录。 此目录中的所有文件都上传到群集节点以便执行。
• 训练脚本 train_titanic.py。
• 用于训练的输入数据集 titanic_ds，作为脚本参数。 在将此数据集传递到脚本时，Azure ML 会将其解析为该数据集的相应 ID。
• 该运行的计算目标。
• 该运行的环境。

from azureml.core import ScriptRunConfig

src = ScriptRunConfig(source_directory=script_folder,
                      script='train_titanic.py',
                      # pass dataset as an input with friendly name 'titanic'
                      arguments=['--input-data', titanic_ds.as_named_input('titanic')],
                      compute_target=compute_target,
                      environment=myenv)
                             
# Submit the run configuration for your training run
run = experiment.submit(src)
run.wait_for_completion(show_output=True)                             

如果你有非结构化数据，请创建一个 FileDataset，然后装载或下载数据文件，使它们可在训练中用于远程计算目标。 了解何时使用装载与下载进行远程训练实验。

以下示例，

• 为训练数据创建输入 FileDataset mnist_ds。
• 指定在何处写入训练结果，以及将这些结果作为 FileDataset 进行提升。
• 将输入数据集装载到计算目标。

有关笔记本示例，请参阅如何使用数据输入和输出配置训练运行。

以下示例从 Web URL 创建未注册的 FileDataset mnist_data。 此 FileDataset 是训练运行的输入数据。

从其他来源详细了解如何创建数据集。

from azureml.core.dataset import Dataset

web_paths = [
            'http://yann.lecun.com/exdb/mnist/train-images-idx3-ubyte.gz',
            'http://yann.lecun.com/exdb/mnist/train-labels-idx1-ubyte.gz',
            'http://yann.lecun.com/exdb/mnist/t10k-images-idx3-ubyte.gz',
            'http://yann.lecun.com/exdb/mnist/t10k-labels-idx1-ubyte.gz'
            ]

mnist_ds = Dataset.File.from_files(path = web_paths)

可以使用 OutputFileDatasetConfig 对象指定在何处写入训练结果。

OutputFileDatasetConfig 对象使你可以：

• 将运行的输出装载或上传到指定的云存储。
• 以 FileDataset 的形式将输出保存到支持的存储类型：
  • Azure blob
  • Azure 文件共享
  • Azure Data Lake Storage 第 1 代和第 2 代
• 跟踪训练运行之间的数据世系。

下面的代码指定训练结果应以 FileDataset 的形式保存在默认 blob 数据存储 def_blob_store 的 outputdataset 文件夹中。

from azureml.core import Workspace
from azureml.data import OutputFileDatasetConfig

ws = Workspace.from_config()

def_blob_store = ws.get_default_datastore()
output = OutputFileDatasetConfig(destination=(def_blob_store, 'sample/outputdataset'))

建议在装载时通过 ScriptRunConfig 构造函数的 arguments 参数将该数据集作为参数传递。 这样，你就可以通过参数在训练脚本中获取数据路径（装入点）。 这样，便能够在任何云平台上使用相同的训练脚本进行本地调试和远程训练。

下面的示例创建一个 ScriptRunConfig，它通过 arguments 传入 FileDataset。 提交运行后，由数据集 mnist_ds 引用的数据文件会装载到计算目标，而训练结果会保存到默认数据存储中的指定 outputdataset 文件夹。

from azureml.core import ScriptRunConfig

input_data= mnist_ds.as_named_input('input').as_mount()# the dataset will be mounted on the remote compute 

src = ScriptRunConfig(source_directory=script_folder,
                      script='dummy_train.py',
                      arguments=[input_data, output],
                      compute_target=compute_target,
                      environment=myenv)

# Submit the run configuration for your training run
run = experiment.submit(src)
run.wait_for_completion(show_output=True)

下面的脚本通过 ScriptRunConfig 进行提交。 它将 mnist_ds 数据集读取为输入，并将该文件写入默认 blob 数据存储 def_blob_store 中的 outputdataset 文件夹。

%%writefile $source_directory/dummy_train.py

# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License.
import sys
import os

print("*********************************************************")
print("Hello Azure ML!")

mounted_input_path = sys.argv[1]
mounted_output_path = sys.argv[2]

print("Argument 1: %s" % mounted_input_path)
print("Argument 2: %s" % mounted_output_path)
    
with open(mounted_input_path, 'r') as f:
    content = f.read()
    with open(os.path.join(mounted_output_path, 'output.csv'), 'w') as fw:
        fw.write(content)

对于从 Azure Blob 存储、Azure 文件存储、Azure Files, Azure Data Lake Storage Gen2、Azure SQL 数据库和 Azure Database for PostgreSQL 创建的数据集，可以装载或下载任何格式的文件。

装载数据集时，请将数据集引用的文件附加到目录（装入点），并使其在计算目标上可用。 基于 Linux 的计算支持装载，这些计算包括 Azure 机器学习计算、虚拟机和 HDInsight。 如果数据大小超出计算磁盘大小，则无法下载。 对于此方案，我们建议装载，因为在处理时只会加载脚本使用的数据文件。

下载数据集时，数据集引用的所有文件都将下载到计算目标。 所有计算类型都支持下载。 如果脚本处理数据集引用的所有文件，并且计算磁盘可以容纳整个数据集，则建议下载，以避免从存储服务流式传输数据的开销。 有关多节点下载，请参阅如何避免限制。

以下代码将 dataset 装载到 mounted_path 的临时目录

import tempfile
mounted_path = tempfile.mkdtemp()

# mount dataset onto the mounted_path of a Linux-based compute
mount_context = dataset.mount(mounted_path)

mount_context.start()

import os
print(os.listdir(mounted_path))
print (mounted_path)

可以在本地以及在 Azure 机器学习计算等计算群集上远程访问已注册的数据集。 若要跨试验访问已注册的数据集，请使用以下代码来访问工作区并获取在以前提交的运行中使用过的数据集。 默认情况下，Dataset 类中的 get_by_name() 方法返回已注册到工作区的数据集的最新版本。

%%writefile $script_folder/train.py

from azureml.core import Dataset, Run

run = Run.get_context()
workspace = run.experiment.workspace

dataset_name = 'titanic_ds'

# Get a dataset by name
titanic_ds = Dataset.get_by_name(workspace=workspace, name=dataset_name)

# Load a TabularDataset into pandas DataFrame
df = titanic_ds.to_pandas_dataframe()

Azure Blob 存储具有比 Azure 文件共享更快的吞吐速度，并将扩展到大量并行启动的作业。 出于此原因，我们建议配置运行以使用 Blob 存储来传输源代码文件。

下面的代码示例在运行配置中指定用于源代码传输的 Blob 数据存储。

# workspaceblobstore is the default blob storage
src.run_config.source_directory_data_store = "workspaceblobstore" 

• 有关其他数据集示例和概念，请参阅数据集笔记本。
• 请参阅如何在 ML 管道中参数化数据集。

数据集初始化失败：“等待装入点准备完毕”已超时：

• 如果你没有任何出站网络安全组规则并且正在使用 azureml-sdk>=1.12.0，请将 azureml-dataset-runtime 及其依赖项更新为特定次要版本的最新版本，而如果你正在运行中使用该版本，请重新创建环境，以便获得具有修补程序的最新补丁。
• 如果使用的是 azureml-sdk<1.12.0，请升级到最新版本。
• 如果具有出站 NSG 规则，请确保存在允许服务标记 AzureResourceMonitor 的所有流量的出站规则。

数据集初始化失败：StreamAccessException 是由 ThrottlingException 引起的

对于多节点文件下载，所有节点可能会尝试从 Azure 存储服务下载文件数据集中的所有文件，这会导致限制错误。 若要避免限制，请首先将环境变量 AZUREML_DOWNLOAD_CONCURRENCY 设置为 CPU 核心数除以节点数的 8 倍值。 设置此环境变量的值可能需要一些试验，因此上述指南是一个起点。

以下示例假定有 32 个核心和 4 个节点。

from azureml.core.environment import Environment 
myenv = Environment(name="myenv")
myenv.environment_variables = {"AZUREML_DOWNLOAD_CONCURRENCY":64}

无法将项目文件上传到 AzureFile 中的工作目录，因为该存储已过载：

• 如果对其他工作负荷（例如数据传输）使用文件共享，则我们建议使用 Blob，以便可以自由使用文件共享来提交运行。

• 另一种选择是在两个不同的工作区之间拆分工作负载。

ConfigException：由于缺少凭据，无法创建到 AzureFileService 的连接。 需要将帐户密钥或 SAS 令牌链接到默认的工作区 Blob 存储。

若要确保存储访问凭据链接到工作区以及关联的文件数据存储，请完成以下步骤：

1. 在 Azure 门户中导航到工作区。
2. 在工作区“概述”页上选择存储链接。
3. 在存储页上，选择左侧菜单中的“访问密钥”。
4. 复制密钥。
5. 导航到工作区的 Azure 机器学习工作室。
6. 在工作室中，选择要为其提供身份验证凭据的文件数据存储。
7. 选择“更新身份验证”。
8. 粘贴前面步骤中的密钥。
9. 选择“保存”。

TypeError：FileNotFound:无此类文件或目录： 如果文件不在提供的文件路径中，则会出现此错误。 需确保引用文件的方式与在计算目标上将数据集装载到的位置相一致。 为确保确定性状态，我们建议在将数据集装载到计算目标时使用抽象路径。 例如，在以下代码中，我们将数据集装载到计算目标文件系统的根目录 /tmp 下。

# Note the leading / in '/tmp/dataset'
script_params = {
    '--data-folder': dset.as_named_input('dogscats_train').as_mount('/tmp/dataset'),
} 

如果不包含前导正斜杠“/”，则需要为计算目标上的工作目录添加前缀（例如 /mnt/batch/.../tmp/dataset），以指示要将数据集装载到的位置。

• 使用 TabularDataset 自动训练机器学习模型。

• 使用 FileDataset 训练图像分类模型。

• 通过管道使用数据集进行训练。