Keras 3 API 文档 / 工具 / Python & NumPy 工具

Python & NumPy 工具

[源代码]

set_random_seed 函数

keras.utils.set_random_seed(seed)

设置所有随机种子(Python、NumPy 和后端框架,例如 TF)。

您可以使用此工具使几乎任何 Keras 程序完全确定。 在涉及网络通信(例如参数服务器分发),从而产生额外随机性来源,或者涉及某些不确定的 cuDNN 操作的情况下,会存在一些限制。

调用此工具等效于以下操作

import random
random.seed(seed)

import numpy as np
np.random.seed(seed)

import tensorflow as tf  # Only if TF is installed
tf.random.set_seed(seed)

import torch  # Only if the backend is 'torch'
torch.manual_seed(seed)

请注意,即使您没有使用 TensorFlow 作为后端框架,也会设置 TensorFlow 种子,因为许多工作流程会利用 tf.data 管道(其中包含随机洗牌)。同样,许多工作流程可能会利用 NumPy API。

参数

  • seed: 整数,要使用的随机种子。

[源代码]

split_dataset 函数

keras.utils.split_dataset(
    dataset, left_size=None, right_size=None, shuffle=False, seed=None
)

将数据集分成左半部分和右半部分(例如,训练/测试)。

参数

  • dataset: 一个 tf.data.Dataset、一个 torch.utils.data.Dataset 对象或一个长度相同的数组列表/元组。
  • left_size:如果为浮点数(在范围 [0, 1] 内),则表示要打包到左侧数据集中的数据比例。如果为整数,则表示要打包到左侧数据集中的样本数。如果为 None,则默认为 right_size 的补集。默认为 None
  • right_size:如果为浮点数(在范围 [0, 1] 内),则表示要打包到右侧数据集中的数据比例。如果为整数,则表示要打包到右侧数据集中的样本数。如果为 None,则默认为 left_size 的补集。默认为 None
  • shuffle:布尔值,是否在拆分数据之前对其进行洗牌。
  • seed:用于洗牌的随机种子。

返回值

  • 一个由两个 tf.data.Dataset 对象组成的元组:左侧和右侧拆分。

示例

>>> data = np.random.random(size=(1000, 4))
>>> left_ds, right_ds = keras.utils.split_dataset(data, left_size=0.8)
>>> int(left_ds.cardinality())
800
>>> int(right_ds.cardinality())
200

[源代码]

pack_x_y_sample_weight 函数

keras.utils.pack_x_y_sample_weight(x, y=None, sample_weight=None)

将用户提供的数据打包到一个元组中。

这是一个用于将数据打包成 Model.fit() 使用的元组格式的便捷工具。

示例

>>> x = ops.ones((10, 1))
>>> data = pack_x_y_sample_weight(x)
>>> isinstance(data, ops.Tensor)
True
>>> y = ops.ones((10, 1))
>>> data = pack_x_y_sample_weight(x, y)
>>> isinstance(data, tuple)
True
>>> x, y = data

参数

  • x:要传递给 Model 的特征。
  • y:要传递给 Model 的真实目标。
  • sample_weight:每个元素的样本权重。

返回值

Model.fit() 中使用的格式的元组。


[源代码]

get_file 函数

keras.utils.get_file(
    fname=None,
    origin=None,
    untar=False,
    md5_hash=None,
    file_hash=None,
    cache_subdir="datasets",
    hash_algorithm="auto",
    extract=False,
    archive_format="auto",
    cache_dir=None,
    force_download=False,
)

如果缓存中尚不存在,则从 URL 下载文件。

默认情况下,URL origin 处的文件会下载到缓存目录 ~/.keras,放置在缓存子目录 datasets 中,并给定文件名 fname。因此,文件 example.txt 的最终位置将是 ~/.keras/datasets/example.txt。也可以提取 .tar.tar.gz.tar.bz.zip 格式的文件。

传递哈希值将在下载后验证文件。命令行程序 shasumsha256sum 可以计算哈希值。

示例

path_to_downloaded_file = get_file(
    origin="https://storage.googleapis.com/download.tensorflow.org/example_images/flower_photos.tgz",
    extract=True,
)

参数

  • fname:如果目标是单个文件,这是您希望的文件本地名称。如果为 None,将使用 origin 处的文件名。如果下载和提取目录归档文件,则提供的 fname 将用作提取目录名称(仅当它没有扩展名时)。
  • origin:文件的原始 URL。
  • untar:已弃用,建议使用 extract 参数。布尔值,文件是否为应提取的 tar 归档文件。
  • md5_hash:已弃用,建议使用 file_hash 参数。文件的 md5 哈希值用于文件完整性验证。
  • file_hash:下载后文件的预期哈希字符串。支持 sha256 和 md5 哈希算法。
  • cache_subdir:Keras 缓存目录下的子目录,用于保存文件。如果指定了绝对路径,例如 "/path/to/folder",则文件将保存在该位置。
  • hash_algorithm:选择用于验证文件的哈希算法。选项为 "md5""sha256""auto"。默认的“auto”会检测正在使用的哈希算法。
  • extract:如果为 True,则提取归档文件。仅适用于 tar 或 zip 等压缩归档文件。
  • archive_format:尝试提取文件的归档格式。选项为 "auto""tar""zip"None"tar" 包括 tar、tar.gz 和 tar.bz 文件。默认的 "auto" 对应于 ["tar", "zip"]。None 或空列表将返回未找到匹配项。
  • cache_dir:存储缓存文件的位置,当为 None 时,如果设置了 KERAS_HOME 环境变量,则默认为 $KERAS_HOME,否则默认为 ~/.keras/
  • force_download:如果为 True,则无论缓存状态如何,都会始终重新下载该文件。

返回值

下载文件的路径。

⚠️ 关于恶意下载的警告 ⚠️

从 Internet 下载任何内容都存在风险。如果您不信任来源,请永远不要下载文件/归档文件。我们建议您指定 file_hash 参数(如果已知源文件的哈希值)以确保您获取的文件是您期望的文件。


[源代码]

Progbar

keras.utils.Progbar(
    target, width=20, verbose=1, interval=0.05, stateful_metrics=None, unit_name="step"
)

显示进度条。

参数

  • target:预期的总步骤数,如果未知,则为 None。
  • width:屏幕上的进度条宽度。
  • verbose:详细模式,0(静默)、1(详细)、2(半详细)
  • stateful_metrics:应该随时间平均的指标的字符串名称的可迭代对象。此列表中的指标将按原样显示。所有其他指标将在显示之前由进度条进行平均。
  • interval:最小可视进度更新间隔(以秒为单位)。
  • unit_name:步骤计数的显示名称(通常为“step”或“sample”)。

[源代码]

PyDataset

keras.utils.PyDataset(workers=1, use_multiprocessing=False, max_queue_size=10)

用于使用 Python 代码定义并行数据集的基类。

每个 PyDataset 都必须实现 __getitem__()__len__() 方法。 如果您想在 epoch 之间修改数据集,您还可以实现 on_epoch_end()on_epoch_begin,以便在每个 epoch 的开始时调用。 __getitem__() 方法应返回一个完整的批次(而不是单个样本),而 __len__ 方法应返回数据集中的批次数(而不是样本数)。

参数

  • workers:在多线程或多处理中使用的 worker 数量。
  • use_multiprocessing:是否使用 Python 多处理进行并行处理。将此设置为 True 意味着您的数据集将在多个分叉进程中复制。这对于从并行处理中获得计算级别(而不是 I/O 级别)的优势是必要的。但是,只有当您的数据集可以安全地进行 pickle 时,才能将其设置为 True
  • max_queue_size:在多线程或多进程设置中迭代数据集时,要在队列中保留的最大批次数量。 减少此值可减少数据集的 CPU 内存消耗。默认为 10。

注意

  • PyDataset 是一种更安全的多处理方式。此结构保证模型每个 epoch 只在每个样本上训练一次,这在使用 Python 生成器的情况下并非如此。
  • 参数 workersuse_multiprocessingmax_queue_size 用于配置 fit() 如何使用并行处理来迭代数据集。它们不是由 PyDataset 类直接使用的。当您手动迭代 PyDataset 时,不会应用并行处理。

示例

from skimage.io import imread
from skimage.transform import resize
import numpy as np
import math

# Here, `x_set` is list of path to the images
# and `y_set` are the associated classes.

class CIFAR10PyDataset(keras.utils.PyDataset):

    def __init__(self, x_set, y_set, batch_size, **kwargs):
        super().__init__(**kwargs)
        self.x, self.y = x_set, y_set
        self.batch_size = batch_size

    def __len__(self):
        # Return number of batches.
        return math.ceil(len(self.x) / self.batch_size)

    def __getitem__(self, idx):
        # Return x, y for batch idx.
        low = idx * self.batch_size
        # Cap upper bound at array length; the last batch may be smaller
        # if the total number of items is not a multiple of batch size.
        high = min(low + self.batch_size, len(self.x))
        batch_x = self.x[low:high]
        batch_y = self.y[low:high]

        return np.array([
            resize(imread(file_name), (200, 200))
               for file_name in batch_x]), np.array(batch_y)

[源代码]

to_categorical 函数

keras.utils.to_categorical(x, num_classes=None)

将类向量(整数)转换为二进制类矩阵。

例如,与 categorical_crossentropy 一起使用。

参数

  • x:要转换为矩阵的类值(从 0 到 num_classes - 1 的整数)的类数组。
  • num_classes:总类数。如果为 None,则推断为 max(x) + 1。默认为 None

返回值

输入作为 NumPy 数组的二进制矩阵表示。类轴放在最后。

示例

>>> a = keras.utils.to_categorical([0, 1, 2, 3], num_classes=4)
>>> print(a)
[[1. 0. 0. 0.]
 [0. 1. 0. 0.]
 [0. 0. 1. 0.]
 [0. 0. 0. 1.]]
>>> b = np.array([.9, .04, .03, .03,
...               .3, .45, .15, .13,
...               .04, .01, .94, .05,
...               .12, .21, .5, .17],
...               shape=[4, 4])
>>> loss = keras.ops.categorical_crossentropy(a, b)
>>> print(np.around(loss, 5))
[0.10536 0.82807 0.1011  1.77196]
>>> loss = keras.ops.categorical_crossentropy(a, a)
>>> print(np.around(loss, 5))
[0. 0. 0. 0.]

[源代码]

normalize 函数

keras.utils.normalize(x, axis=-1, order=2)

规范化一个数组。

如果输入是 NumPy 数组,则将返回 NumPy 数组。 如果它是后端张量,则将返回后端张量。

参数

  • x:要规范化的数组。
  • axis:规范化的轴。
  • order:规范化顺序(例如,L2 范数的 order=2)。

返回值

数组的规范化副本。