forked from mindspore-Ecosystem/mindspore
961 lines
46 KiB
ReStructuredText
961 lines
46 KiB
ReStructuredText
.. py:method:: apply(apply_func)
|
||
|
||
对数据集对象执行给定操作函数。
|
||
|
||
**参数：**
|
||
|
||
`apply_func` (function)：数据集处理函数，要求该函数的输入是一个 `Dataset` 对象，返回的是处理后的 `Dataset` 对象。
|
||
|
||
**返回：**
|
||
|
||
执行了给定操作函数的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是任意数据集对象的实例
|
||
>>>
|
||
>>> # 声明一个名为apply_func函数，对数据集对象执行batch操作，并返回值处理后的Dataset对象
|
||
>>> # 注意apply_func函数的输入参数data需要为 `Dataset` 对象
|
||
>>> def apply_func(data):
|
||
... data = data.batch(2)
|
||
... return data
|
||
>>>
|
||
>>> # 通过apply操作调用apply_func函数，得到处理后的数据集对象
|
||
>>> dataset = dataset.apply(apply_func)
|
||
|
||
**异常：**
|
||
|
||
- **TypeError：** `apply_func` 的类型不是函数。
|
||
- **TypeError：** `apply_func` 未返回Dataset对象。
|
||
|
||
.. py:method:: batch(batch_size, drop_remainder=False, num_parallel_workers=None, per_batch_map=None, input_columns=None, output_columns=None, column_order=None, pad_info=None, python_multiprocessing=False)
|
||
|
||
将数据集中连续 `batch_size` 条数据合并为一个批处理数据。
|
||
|
||
`batch` 操作要求每列中的数据具有相同的shape。如果指定了参数 `per_batch_map` ，该参数将作用于批处理后的数据。
|
||
|
||
.. note::
|
||
执行 `repeat` 和 `batch` 操作的先后顺序，会影响批处理数据的数量及 `per_batch_map` 的结果。建议在 `batch` 操作完成后执行 `repeat` 操作。
|
||
|
||
**参数：**
|
||
|
||
- **batch_size** (Union[int, Callable]) - 指定每个批处理数据包含的数据条目。
|
||
如果 `batch_size` 为整型，则直接表示每个批处理数据大小；
|
||
如果为可调用对象，则可以通过自定义行为动态指定每个批处理数据大小，要求该可调用对象接收一个参数BatchInfo，返回一个整形代表批处理大小，用法请参考样例（3）。
|
||
- **drop_remainder** (bool, 可选) - 当最后一个批处理数据包含的数据条目小于 `batch_size` 时，是否将该批处理丢弃，不传递给下一个操作。默认值：False，不丢弃。
|
||
- **num_parallel_workers** (int, 可选) - 指定 `batch `操作的并发进程数/线程数（由参数 `python_multiprocessing` 决定当前为多进程模式或多线程模式）。
|
||
默认值：None，使用mindspore.dataset.config中配置的线程数。
|
||
- **per_batch_map** (callable, 可选) - 可调用对象，以(list[Tensor], list[Tensor], ..., BatchInfo)作为输入参数，处理后返回(list[Tensor], list[Tensor],...)作为新的数据列。
|
||
输入参数中每个list[Tensor]代表给定数据列中的一批Tensor，list[Tensor]的个数应与 `input_columns` 中传入列名的数量相匹配，
|
||
在返回的(list[Tensor], list[Tensor], ...)中，list[Tensor]的个数应与输入相同，如果输出列数与输入列数不一致，则需要指定 `output_columns`。
|
||
该可调用对象的最后一个输入参数始终是BatchInfo，用于获取数据集的信息，用法参考样例（2）。
|
||
- **input_columns** (Union[str, list[str]], 可选)：指定 `batch` 操作的输入数据列。
|
||
如果 `per_batch_map` 不为None，列表中列名的个数应与 `per_batch_map` 中包含的列数匹配。默认值：None，不指定。
|
||
- **output_columns** (Union[str, list[str]], 可选) - 指定 `batch` 操作的输出数据列。如果输入数据列与输入数据列的长度不相等，则必须指定此参数。
|
||
此列表中列名的数量必须与 `per_batch_map` 方法的返回值数量相匹配。默认值：None，输出列将与输入列具有相同的名称。
|
||
- **column_order** (Union[str, list[str]], 可选) - 指定传递到下一个数据集操作的数据列顺序。
|
||
如果 `input_column` 长度不等于 `output_column` 长度，则此参数必须指定。
|
||
注意：列名不限定在 `input_columns` 和 `output_columns` 中指定的列，也可以是上一个操作输出的未被处理的数据列，详细可参阅使用样例（4）。默认值：None，按照原输入顺序排列。
|
||
- **pad_info** (dict, 可选) - 对给定数据列进行填充。通过传入dict来指定列信息与填充信息，例如 `pad_info={"col1":([224,224],0)}` ，
|
||
则将列名为"col1"的数据列扩充到shape为[224,224]的Tensor，缺失的值使用0填充。默认值：None，不填充。
|
||
- **python_multiprocessing** (bool, 可选) - 启动Python多进程模式并行执行 `per_batch_map` 。如果 `per_batch_map` 的计算量很大，此选项可能会很有用。默认值：False，不启用多进程。
|
||
|
||
**返回：**
|
||
|
||
Dataset， `batch` 操作后的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # 1）创建一个数据集对象，每100条数据合并成一个批处理数据
|
||
>>> # 如果最后一个批次数据小于给定的批次大小（batch_size)，则丢弃这个批次
|
||
>>> dataset = dataset.batch(100, True)
|
||
>>>
|
||
>>> # 2）根据批次编号调整图像大小，如果是第5批，则图像大小调整为(5^2, 5^2) = (25, 25)
|
||
>>> def np_resize(col, BatchInfo):
|
||
... output = col.copy()
|
||
... s = (BatchInfo.get_batch_num() + 1) ** 2
|
||
... index = 0
|
||
... for c in col:
|
||
... img = Image.fromarray(c.astype('uint8')).convert('RGB')
|
||
... img = img.resize((s, s), Image.ANTIALIAS)
|
||
... output[index] = np.array(img)
|
||
... index += 1
|
||
... return (output,)
|
||
>>> dataset = dataset.batch(batch_size=8, input_columns=["image"], per_batch_map=np_resize)
|
||
>>>
|
||
>>> # 3）创建一个数据集对象，动态指定批处理大小
|
||
>>> # 定义一个批处理函数，每次将batch_size加一
|
||
>>> def add_one(BatchInfo):
|
||
... return BatchInfo.get_batch_num() + 1
|
||
>>> dataset = dataset.batch(batch_size=add_one, drop_remainder=True)
|
||
>>>
|
||
>>> # 4）创建一个数据集对象，并执行batch数据，指定column_order更换数据列顺序
|
||
>>> # 假设数据集对象的数据列原顺序是["image", "label"]
|
||
>>> dataset = dataset.batch(32, column_order=["label", "image"])
|
||
|
||
.. py:method:: bucket_batch_by_length(column_names, bucket_boundaries, bucket_batch_sizes, element_length_function=None, pad_info=None, pad_to_bucket_boundary=False, drop_remainder=False)
|
||
|
||
根据数据的长度进行分桶，每个桶将在数据填满的时候进行填充和批处理操作。
|
||
|
||
对数据集中的每一条数据进行长度计算，根据该条数据的长度计算结果和每个分桶的范围将该数据归类到特定的桶里面。
|
||
当某个分桶中数据条数达到指定的大小 `bucket_batch_sizes` 时，将根据 `pad_info` 的信息对分桶进行填充，再进行批处理。
|
||
|
||
**参数：**
|
||
|
||
- **column_names** (list[str]) - 传递给参数 `element_length_function` 的数据列，用于计算数据的长度。
|
||
- **bucket_boundaries** (list[int]) - 指定各个分桶的上边界值，列表的数值必须严格递增。
|
||
如果有n个边界，则会创建n+1个桶，分配后桶的边界如下：[0, bucket_boundaries[0])，[bucket_boundaries[i], bucket_boundaries[i+1])，[bucket_boundaries[n-1], inf)，其中，0<i<n-1。
|
||
- **bucket_batch_sizes** (list[int]) - 指定每个分桶的批数据大小，必须包含 `len(bucket_boundaries)+1` 个元素。
|
||
- **element_length_function** (Callable, 可选) - 长度计算函数。要求接收 `len(column_names)` 个输入参数，并返回一个整数代表该条数据的长度。
|
||
如果未指定该参数，则参数 `column_names` 的长度必须为1，此时该列数据的shape[0]值将被当做数据长度。默认值：None，不指定。
|
||
- **pad_info** (dict, 可选) - 对指定数据列进行填充。通过传入dict来指定列信息与填充信息，要求dict的键是要填充的数据列名，dict的值是包含2个元素的元组。
|
||
元组中第1个元素表示要扩展至的目标shape，第2个元素表示要填充的值。
|
||
如果某一个数据列未指定将要填充后的shape和填充值，则该列中的每条数据都将填充至该批次中最长数据的长度，且填充值为0。
|
||
注意，`pad_info` 中任何填充shape为None的列，其每条数据长度都将被填充为当前批处理中最数据的长度，除非指定 `pad_to_bucket_boundary` 为True。默认值：None，不填充。
|
||
- **pad_to_bucket_boundary** (bool, 可选) - 如果为True，则 `pad_info` 中填充shape为None的列，会被填充至由参数 `bucket_batch_sizes` 指定的对应分桶长度-1的长度。
|
||
如果有任何数据落入最后一个分桶中，则将报错。默认值：False。
|
||
- **drop_remainder** (bool, 可选) - 当每个分桶中的最后一个批处理数据数据条目小于 `bucket_batch_sizes` 时，是否丢弃该批处理数据。默认值：False，不丢弃。
|
||
|
||
**返回：**
|
||
|
||
Dataset，按长度进行分桶和批处理操作后的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # 创建一个数据集对象，其中给定条数的数据会被组成一个批次数据
|
||
>>> # 如果最后一个批次数据小于给定的批次大小（batch_size)，则丢弃这个批次
|
||
>>> import numpy as np
|
||
>>> def generate_2_columns(n):
|
||
... for i in range(n):
|
||
... yield (np.array([i]), np.array([j for j in range(i + 1)]))
|
||
>>>
|
||
>>> column_names = ["col1", "col2"]
|
||
>>> dataset = ds.GeneratorDataset(generate_2_columns(8), column_names)
|
||
>>> bucket_boundaries = [5, 10]
|
||
>>> bucket_batch_sizes = [2, 1, 1]
|
||
>>> element_length_function = (lambda col1, col2: max(len(col1), len(col2)))
|
||
>>> # 将对列名为"col2"的列进行填充，填充后的shape为[bucket_boundaries[i]]，其中i是当前正在批处理的桶的索引
|
||
>>> pad_info = {"col2": ([None], -1)}
|
||
>>> pad_to_bucket_boundary = True
|
||
>>> dataset = dataset.bucket_batch_by_length(column_names, bucket_boundaries,
|
||
... bucket_batch_sizes,
|
||
... element_length_function, pad_info,
|
||
... pad_to_bucket_boundary)
|
||
|
||
.. py:method:: build_sentencepiece_vocab(columns, vocab_size, character_coverage, model_type, params)
|
||
|
||
迭代源数据集对象获取数据并构建SentencePiece词汇表。
|
||
|
||
**参数：**
|
||
|
||
- **columns** (list[str]) - 指定 `build_sentencepiece_vocab` 操作的输入列，会从该列获取数据构造词汇表。
|
||
- **vocab_size** (int) - 词汇表的容量。
|
||
- **character_coverage** (float) - 模型涵盖的字符百分比，必须介于0.98和1.0之间。
|
||
对于具有丰富字符集的语言，如日语或中文字符集，推荐使用0.9995；对于其他字符集较小的语言，比如英语或拉丁文，推荐使用1.0。
|
||
- **model_type** (SentencePieceModel) - 训练的SentencePiece模型类型，可取值为'SentencePieceModel.UNIGRAM'、'SentencePieceModel.BPE'、'SentencePieceModel.CHAR'或'SentencePieceModel.WORD'。
|
||
当取值为'SentencePieceModel.WORD'时，输入的数据必须进行预分词（pretokenize）。默认值：SentencePieceModel.UNIGRAM。
|
||
- **params** (dict) - 如果希望使用SentencePiece的其他参数，可以构造一个dict进行传入，键为SentencePiece库接口的输入参数名，值为参数值。
|
||
|
||
**返回：**
|
||
|
||
构建好的SentencePiece词汇表。
|
||
|
||
**样例：**
|
||
|
||
>>> from mindspore.dataset.text import SentencePieceModel
|
||
>>>
|
||
>>> # DE_C_INTER_SENTENCEPIECE_MODE 是一个映射字典
|
||
>>> from mindspore.dataset.text.utils import DE_C_INTER_SENTENCEPIECE_MODE
|
||
>>> dataset = ds.TextFileDataset("/path/to/sentence/piece/vocab/file", shuffle=False)
|
||
>>> dataset = dataset.build_sentencepiece_vocab(["text"], 5000, 0.9995,
|
||
... DE_C_INTER_SENTENCEPIECE_MODE[SentencePieceModel.UNIGRAM],
|
||
... {})
|
||
|
||
.. py:method:: build_vocab(columns, freq_range, top_k, special_tokens, special_first)
|
||
|
||
迭代源数据集对象获取数据并构建词汇表。
|
||
|
||
收集数据集中所有的不重复单词，并返回 `top_k` 个最常见的单词组成的词汇表（如果指定了 `top_k` ）。
|
||
|
||
**参数：**
|
||
|
||
- **columns** (Union[str, list[str]]) ：指定 `build_vocab` 操作的输入列，会从该列获取数据构造词汇表。
|
||
- **freq_range** (tuple[int]) - 由(min_frequency, max_frequency)组成的整数元组，代表词汇出现的频率范围，在这个频率范围的词汇会被保存下来。
|
||
取值范围需满足：0 <= min_frequency <= max_frequency <= 单词总数，其中min_frequency、max_frequency的默认值分别设置为0、单词总数。
|
||
- **top_k** (int) - 使用 `top_k` 个最常见的单词构建词汇表。 假如指定了参数 `freq_range` ，则优先统计给定频率范围内的词汇，再根据参数 `top_k` 选取最常见的单词构建词汇表。
|
||
如果 `top_k` 的值大于单词总数，则取所有单词构建词汇表。
|
||
- **special_tokens** (list[str]) - 指定词汇表的特殊标记（special token），如'[UNK]'、'[SEP]'。
|
||
- **special_first** (bool) - 是否将参数 `special_tokens` 指定的特殊标记添加到词汇表的开头。如果为True则放到开头，否则放到词汇表的结尾。
|
||
|
||
**返回：**
|
||
|
||
构建好的词汇表。
|
||
|
||
**样例：**
|
||
|
||
>>> def gen_corpus():
|
||
... # key：单词，value：出现次数，键的取值采用字母表示有利于排序和显示。
|
||
... corpus = {"Z": 4, "Y": 4, "X": 4, "W": 3, "U": 3, "V": 2, "T": 1}
|
||
... for k, v in corpus.items():
|
||
... yield (np.array([k] * v, dtype='S'),)
|
||
>>> column_names = ["column1", "column2", "column3"]
|
||
>>> dataset = ds.GeneratorDataset(gen_corpus, column_names)
|
||
>>> dataset = dataset.build_vocab(columns=["column3", "column1", "column2"],
|
||
... freq_range=(1, 10), top_k=5,
|
||
... special_tokens=["<pad>", "<unk>"],
|
||
... special_first=True,vocab='vocab')
|
||
|
||
.. py:method:: close_pool()
|
||
|
||
关闭数据集对象中的多进程池。如果您熟悉多进程库，可以将此视为进程池对象的析构函数。
|
||
|
||
.. py:method:: concat(datasets)
|
||
|
||
对传入的多个数据集对象进行拼接操作，也可以使用"+"运算符来进行数据集进行拼接。
|
||
|
||
.. note::用于拼接的多个数据集对象，每个数据集对象的列名、每列数据的维度（rank）和数据类型必须相同。
|
||
|
||
**参数：**
|
||
|
||
- **datasets** (Union[list, Dataset]) - 与当前数据集对象拼接的数据集对象列表或单个数据集对象。
|
||
|
||
|
||
**返回：**
|
||
|
||
Dataset，拼接后的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # 使用"+"运算符拼接dataset_1和dataset_2，获得拼接后的数据集对象
|
||
>>> dataset = dataset_1 + dataset_2
|
||
>>> # 通过concat操作拼接dataset_1和dataset_2，获得拼接后的数据集对象
|
||
>>> dataset = dataset_1.concat(dataset_2)
|
||
|
||
.. py:method:: create_dict_iterator(num_epochs=-1, output_numpy=False)
|
||
|
||
基于数据集对象创建迭代器，输出的数据为字典类型。
|
||
|
||
**参数：**
|
||
|
||
- **num_epochs** (int, 可选) - 迭代器可以迭代的最大次数。默认值：-1，迭代器可以迭代无限次。
|
||
- **output_numpy** (bool, 可选) - 输出的数据是否转为NumPy类型。如果为False，迭代器输出的每列数据类型为MindSpore.Tensor，否则为NumPy。默认值：False。
|
||
|
||
**返回：**
|
||
|
||
DictIterator，基于数据集对象创建的字典迭代器。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是任意数据集对象的实例
|
||
>>> iterator = dataset.create_dict_iterator()
|
||
>>> for item in iterator:
|
||
... # item 是一个dict
|
||
... print(type(item))
|
||
... break
|
||
<class 'dict'>
|
||
|
||
.. py:method:: create_tuple_iterator(columns=None, num_epochs=-1, output_numpy=False, do_copy=True)
|
||
|
||
基于数据集对象创建迭代器，输出数据为ndarray组成的列表。
|
||
|
||
可以通过参数 `columns` 指定输出的所有列名及列的顺序。如果columns未指定，列的顺序将保持不变。
|
||
|
||
**参数：**
|
||
|
||
- **columns** (list[str], 可选) - 用于指定输出的数据列和列的顺序。默认值：None，输出所有数据列。
|
||
- **num_epochs** (int, 可选) - 迭代器可以迭代的最大次数。默认值：-1，迭代器可以迭代无限次。
|
||
- **output_numpy** (bool, 可选) - 输出的数据是否转为NumPy类型。如果为False，迭代器输出的每列数据类型为MindSpore.Tensor，否则为NumPy。默认值：False。
|
||
- **do_copy** (bool, 可选) - 当参数 `output_numpy` 为False，即输出数据类型为mindspore.Tensor时，可以将此参数指定为False以减少拷贝，获得更好的性能。默认值：True。
|
||
|
||
**返回：**
|
||
|
||
TupleIterator，基于数据集对象创建的元组迭代器。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是任意数据集对象的实例
|
||
>>> iterator = dataset.create_tuple_iterator()
|
||
>>> for item in iterator：
|
||
... # item 是一个list
|
||
... print(type(item))
|
||
... break
|
||
<class 'list'>
|
||
|
||
.. py:method:: device_que(send_epoch_end=True, create_data_info_queue=False)
|
||
|
||
将数据异步传输到Ascend/GPU设备上。
|
||
|
||
**参数：**
|
||
|
||
- **send_epoch_end** (bool, 可选) - 数据发送完成后是否发送结束标识到设备上，默认值：True。
|
||
- **create_data_info_queue** (bool, 可选) - 是否创建一个队列，用于存储每条数据的数据类型和shape。默认值：False，不创建。
|
||
|
||
.. note::
|
||
如果设备类型为Ascend，每次传输的数据大小限制为256MB。
|
||
|
||
**返回：**
|
||
|
||
Dataset，用于帮助发送数据到设备上的数据集对象。
|
||
|
||
|
||
.. py:method:: dynamic_min_max_shapes()
|
||
|
||
当数据集对象中的数据shape不唯一（动态shape）时，获取数据的最小shape和最大shape。
|
||
|
||
**返回：**
|
||
|
||
两个列表代表最小shape和最大shape，每个列表中的shape按照数据列的顺序排列。
|
||
|
||
**样例：**
|
||
|
||
>>> import numpy as np
|
||
>>>
|
||
>>> def generator1():
|
||
>>> for i in range(1, 100):
|
||
>>> yield np.ones((16, i, 83)), np.array(i)
|
||
>>>
|
||
>>> dataset = ds.GeneratorDataset(generator1, ["data1", "data2"])
|
||
>>> dataset.set_dynamic_columns(columns={"data1": [16, None, 83], "data2": []})
|
||
>>> min_shapes, max_shapes = dataset.dynamic_min_max_shapes()
|
||
|
||
|
||
.. py:method:: filter(predicate, input_columns=None, num_parallel_workers=None)
|
||
|
||
通过自定义判断条件对数据集对象中的数据进行过滤。
|
||
|
||
**参数：**
|
||
|
||
- **predicate** (callable) - Python可调用对象。要求该对象接收n个入参，用于指代每个数据列的数据，最后返回值一个bool值。
|
||
如果返回值为False，则表示过滤掉该条数据。注意n的值与参数 `input_columns` 表示的输入列数量一致。
|
||
- **input_columns** (Union[str, list[str]], 可选) - `filter` 操作的输入数据列。默认值：None，`predicate` 将应用于数据集中的所有列。
|
||
- **num_parallel_workers** (int, 可选) - 指定 `filter` 操作的并发线程数。默认值：None，使用mindspore.dataset.config中配置的线程数。
|
||
|
||
**返回：**
|
||
|
||
Dataset，执行给定筛选过滤操作的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # 生成一个list，其取值范围为（0，63）
|
||
>>> def generator_1d():
|
||
... for i in range(64):
|
||
... yield (np.array(i),)
|
||
>>> dataset = ds.GeneratorDataset(generator_1d, ["data"])
|
||
>>> # 过滤掉数值大于或等于11的数据
|
||
>>> dataset = dataset.filter(predicate=lambda data: data < 11, input_columns = ["data"])
|
||
|
||
|
||
.. py:method:: flat_map(func)
|
||
|
||
对数据集对象中每一条数据执行给定的数据处理，并将结果展平。
|
||
|
||
**参数：**
|
||
|
||
- **func** (function) - 数据处理函数，要求输入必须为一个'ndarray'，返回值是一个'Dataset'对象。
|
||
|
||
**返回：**
|
||
|
||
执行给定操作后的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # 以NumpySlicesDataset为例
|
||
>>> dataset = ds.NumpySlicesDataset([[0, 1], [2, 3]])
|
||
>>>
|
||
>>> def flat_map_func(array):
|
||
... # 使用数组创建NumpySlicesDataset
|
||
... dataset = ds.NumpySlicesDataset(array)
|
||
... # 将数据集对象中的数据重复两次
|
||
... dataset = dataset.repeat(2)
|
||
... return dataset
|
||
>>>
|
||
>>> dataset = dataset.flat_map(flat_map_func)
|
||
>>> # [[0, 1], [0, 1], [2, 3], [2, 3]]
|
||
|
||
**异常：**
|
||
|
||
- **TypeError** - `func` 不是函数。
|
||
- **TypeError** - `func` 的返回值不是数据集对象。
|
||
|
||
.. py:method:: get_batch_size()
|
||
|
||
获得数据集对象定义的批处理大小，即一个批处理数据中包含的数据条数。
|
||
|
||
**返回：**
|
||
|
||
int，一个批处理数据中包含的数据条数。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是任意数据集对象的实例
|
||
>>> dataset = dataset.batch(16)
|
||
>>> batch_size = dataset.get_batch_size()
|
||
|
||
.. py:method:: get_class_indexing()
|
||
|
||
返回类别索引。
|
||
|
||
**返回：**
|
||
|
||
dict，描述类别名称到索引的键值对映射关系，通常为str-to-int格式。针对COCO数据集，类别名称到索引映射关系描述形式为str-to-list<int>格式，列表中的第二个数字表示超级类别。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是数据集类的实例化对象
|
||
>>> class_indexing = dataset.get_class_indexing()
|
||
|
||
|
||
.. py:method:: get_col_names()
|
||
|
||
返回数据集对象中包含的列名。
|
||
|
||
**返回：**
|
||
|
||
list，数据集中所有列名组成列表。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是数据集类的实例化对象
|
||
>>> col_names = dataset.get_col_names()
|
||
|
||
.. py:method:: get_dataset_size()
|
||
|
||
返回一个epoch中的batch数。
|
||
|
||
**返回：**
|
||
|
||
int，batch的数目。
|
||
|
||
.. py:method:: get_repeat_count()
|
||
|
||
获取 `RepeatDataset` 中的repeat次数（默认为1）。
|
||
|
||
**返回：**
|
||
|
||
int，repeat次数。
|
||
|
||
.. py:method:: input_indexs
|
||
:property:
|
||
|
||
获取input index信息。
|
||
|
||
**返回：**
|
||
|
||
input index信息的元组。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是Dataset对象的实例
|
||
>>> # 设置input_indexs
|
||
>>> dataset.input_indexs = 10
|
||
>>> print(dataset.input_indexs)
|
||
10
|
||
|
||
.. py:method:: map(operations, input_columns=None, output_columns=None, column_order=None, num_parallel_workers=None, python_multiprocessing=False, cache=None, callbacks=None)
|
||
|
||
将operations列表中的每个operation作用于数据集。
|
||
|
||
作用的顺序由每个operation在operations参数中的位置决定。
|
||
将首先作用operation[0]，然后operation[1]，operation[2]，以此类推。
|
||
|
||
每个operation将数据集中的一列或多列作为输入，并将输出零列或多列。
|
||
第一个operation将 `input_columns` 中指定的列作为输入。
|
||
如果operations列表中存在多个operation，则上一个operation的输出列将用作下一个operation的输入列。
|
||
|
||
最后一个operation输出列的列名由 `output_columns` 指定。
|
||
|
||
只有在 `column_order` 中指定的列才会传播到子节点，并且列的顺序将与 `column_order` 中指定的顺序相同。
|
||
|
||
**参数：**
|
||
|
||
- **operations** (Union[list[TensorOp], list[functions]]) - 要作用于数据集的operations列表。将按operations列表中显示的顺序作用在数据集。
|
||
- **input_columns** (Union[str, list[str]], optional) - 第一个operation输入的列名列表。此列表的大小必须与第一个operation预期的输入列数相匹配。（默认为None，从第一列开始，无论多少列，都将传递给第一个operation）。
|
||
- **output_columns** (Union[str, list[str]], optional) - 最后一个operation输出的列名列表。如果 `input_columns` 长度不等于 `output_columns` 长度，则此参数必选。此列表的大小必须与最后一个operation的输出列数相匹配（默认为None，输出列将与输入列具有相同的名称，例如，替换一些列）。
|
||
- **column_order** (list[str], optional) - 指定整个数据集中所需的所有列的列表。当 `input_columns` 长度不等于 `output_columns` 长度时，则此参数必选。注意：这里的列表不仅仅是参数 `input_columns` 和 `output_columns` 中指定的列。
|
||
- **num_parallel_workers** (int, optional) - 用于并行处理数据集的线程数（默认为None，将使用配置文件中的值）。
|
||
- **python_multiprocessing** (bool, optional) - 将Python operations委托给多个工作进程进行并行处理。如果Python operations计算量很大，此选项可能会很有用（默认值为False）。
|
||
- **cache** (DatasetCache, optional) - 使用Tensor缓存服务加快数据集处理速度（默认为None，即不使用缓存）。
|
||
- **callbacks** (DSCallback, list[DSCallback], optional) - 要调用的Dataset回调函数列表（默认为None）。
|
||
|
||
.. note::
|
||
- `operations` 参数主要接收 `mindspore.dataset` 模块中c_transforms、py_transforms算子，以及用户定义的Python函数(PyFuncs)。
|
||
- 不要将 `mindspore.nn` 和 `mindspore.ops` 或其他的网络计算算子添加到 `operations` 中。
|
||
|
||
**返回：**
|
||
|
||
MapDataset，map操作后的数据集。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是Dataset的一个实例，它有2列，"image"和"label"。
|
||
>>>
|
||
>>> # 定义两个operation，每个operation接受1列输入，输出1列。
|
||
>>> decode_op = c_vision.Decode(rgb=True)
|
||
>>> random_jitter_op = c_vision.RandomColorAdjust(brightness=(0.8, 0.8), contrast=(1, 1),
|
||
... saturation=(1, 1), hue=(0, 0))
|
||
>>>
|
||
>>> # 1）简单的map示例。
|
||
>>>
|
||
>>> # 在列“image"上应用decode_op。此列将被
|
||
>>> # decode_op的输出列替换。由于未指定column_order，因此两列“image"
|
||
>>> # 和“label"将按其原始顺序传播到下一个节点。
|
||
>>> dataset = dataset.map(operations=[decode_op], input_columns=["image"])
|
||
>>>
|
||
>>> # 解码列“image"并将其重命名为“decoded_image"。
|
||
>>> dataset = dataset.map(operations=[decode_op], input_columns=["image"], output_columns=["decoded_image"])
|
||
>>>
|
||
>>> # 指定输出列的顺序。
|
||
>>> dataset = dataset.map(operations=[decode_op], input_columns=["image"],
|
||
... output_columns=None, column_order=["label", "image"])
|
||
>>>
|
||
>>> # 将列“image"重命名为“decoded_image"，并指定输出列的顺序。
|
||
>>> dataset = dataset.map(operations=[decode_op], input_columns=["image"],
|
||
... output_columns=["decoded_image"], column_order=["label", "decoded_image"])
|
||
>>>
|
||
>>> # 将列“image"重命名为“decoded_image"，并只保留此列。
|
||
>>> dataset = dataset.map(operations=[decode_op], input_columns=["image"],
|
||
... output_columns=["decoded_image"], column_order=["decoded_image"])
|
||
>>>
|
||
>>> # 使用用户自定义Python函数的map简单示例。列重命名和指定列顺序
|
||
>>> # 的方式同前面的示例相同。
|
||
>>> dataset = ds.NumpySlicesDataset(data=[[0, 1, 2]], column_names=["data"])
|
||
>>> dataset = dataset.map(operations=[(lambda x: x + 1)], input_columns=["data"])
|
||
>>>
|
||
>>> # 2）多个operation的map示例。
|
||
>>>
|
||
>>> # 创建一个数据集，图像被解码，并随机颜色抖动。
|
||
>>> # decode_op以列“image"作为输入，并输出一列。将
|
||
>>> # decode_op输出的列作为输入传递给random_jitter_op。
|
||
>>> # random_jitter_op将输出一列。列“image"将替换为
|
||
>>> # random_jitter_op（最后一个operation）输出的列。所有其他
|
||
>>> # 列保持不变。由于未指定column_order，因此
|
||
>>> # 列的顺序将保持不变。
|
||
>>> dataset = dataset.map(operations=[decode_op, random_jitter_op], input_columns=["image"])
|
||
>>>
|
||
>>> # 将random_jitter_op输出的列重命名为“image_mapped"。
|
||
>>> # 指定列顺序的方式与1中的示例相同。
|
||
>>> dataset = dataset.map(operations=[decode_op, random_jitter_op], input_columns=["image"],
|
||
... output_columns=["image_mapped"])
|
||
>>>
|
||
>>> # 使用用户自定义Python函数的多个operation的map示例。列重命名和指定列顺序
|
||
>>> # 的方式与1中的示例相同。
|
||
>>> dataset = ds.NumpySlicesDataset(data=[[0, 1, 2]], column_names=["data"])
|
||
>>> dataset = dataset.map(operations=[(lambda x: x * x), (lambda x: x - 1)], input_columns=["data"],
|
||
... output_columns=["data_mapped"])
|
||
>>>
|
||
>>> # 3）输入列数不等于输出列数的示例。
|
||
>>>
|
||
>>> # operation[0] 是一个 lambda，它以 2 列作为输入并输出 3 列。
|
||
>>> # operations[1] 是一个 lambda，它以 3 列作为输入并输出 1 列。
|
||
>>> # operations[2] 是一个 lambda，它以 1 列作为输入并输出 4 列。
|
||
>>> #
|
||
>>> # 注：operation[i]的输出列数必须等于
|
||
>>> # operation[i+1]的输入列。否则，map算子会
|
||
>>> # 出错。
|
||
>>> operations = [(lambda x, y: (x, x + y, x + y + 1)),
|
||
... (lambda x, y, z: x * y * z),
|
||
... (lambda x: (x % 2, x % 3, x % 5, x % 7))]
|
||
>>>
|
||
>>> # 注：由于输入列数与
|
||
>>> # 输出列数不相同，必须指定output_columns和column_order
|
||
>>> # 参数。否则，此map算子也会出错。
|
||
>>>
|
||
>>> dataset = ds.NumpySlicesDataset(data=([[0, 1, 2]], [[3, 4, 5]]), column_names=["x", "y"])
|
||
>>>
|
||
>>> # 按以下顺序将所有列传播到子节点：
|
||
>>> dataset = dataset.map(operations, input_columns=["x", "y"],
|
||
... output_columns=["mod2", "mod3", "mod5", "mod7"],
|
||
... column_order=["mod2", "mod3", "mod5", "mod7"])
|
||
>>>
|
||
>>> # 按以下顺序将某些列传播到子节点：
|
||
>>> dataset = dataset.map(operations, input_columns=["x", "y"],
|
||
... output_columns=["mod2", "mod3", "mod5", "mod7"],
|
||
... column_order=["mod7", "mod3", "col2"])
|
||
|
||
.. py:method:: num_classes()
|
||
|
||
获取数据集中的样本的class数目。
|
||
|
||
**返回：**
|
||
|
||
int，class数目。
|
||
|
||
.. py:method:: output_shapes()
|
||
|
||
获取输出数据的shape。
|
||
|
||
**返回：**
|
||
|
||
list，每列shape的列表。
|
||
|
||
.. py:method:: output_types()
|
||
|
||
获取输出数据类型。
|
||
|
||
**返回：**
|
||
|
||
list，每列类型的列表。
|
||
|
||
.. py:method:: project(columns)
|
||
|
||
在输入数据集上投影某些列。
|
||
|
||
从数据集中选择列，并以指定的顺序传输到流水线中。
|
||
其他列将被丢弃。
|
||
|
||
**参数：**
|
||
|
||
- **columns** (Union[str, list[str]]) - 要投影列的列名列表。
|
||
|
||
**返回：**
|
||
|
||
ProjectDataset，投影后的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是Dataset对象的实例
|
||
>>> columns_to_project = ["column3", "column1", "column2"]
|
||
>>>
|
||
>>> # 创建一个数据集，无论列的原始顺序如何，依次包含column3, column1, column2。
|
||
>>> dataset = dataset.project(columns=columns_to_project)
|
||
|
||
.. py:method:: rename(input_columns, output_columns)
|
||
|
||
重命名输入数据集中的列。
|
||
|
||
**参数：**
|
||
|
||
- **input_columns** (Union[str, list[str]]) - 输入列的列名列表。
|
||
- **output_columns** (Union[str, list[str]]) - 输出列的列名列表。
|
||
|
||
**返回：**
|
||
|
||
RenameDataset，重命名后数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是Dataset对象的实例
|
||
>>> input_columns = ["input_col1", "input_col2", "input_col3"]
|
||
>>> output_columns = ["output_col1", "output_col2", "output_col3"]
|
||
>>>
|
||
>>> # 创建一个数据集，其中input_col1重命名为output_col1，
|
||
>>> # input_col2重命名为output_col2，input_col3重命名
|
||
>>> # 为output_col3。
|
||
>>> dataset = dataset.rename(input_columns=input_columns, output_columns=output_columns)
|
||
|
||
.. py:method:: repeat(count=None)
|
||
|
||
重复此数据集 `count` 次。如果count为None或-1，则无限重复。
|
||
|
||
.. note::
|
||
repeat和batch的顺序反映了batch的数量。建议：repeat操作在batch操作之后使用。
|
||
|
||
**参数：**
|
||
|
||
- **count** (int) - 数据集重复的次数（默认为None）。
|
||
|
||
**返回：**
|
||
|
||
RepeatDataset，重复操作后的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是Dataset对象的实例
|
||
>>>
|
||
>>> # 创建一个数据集，数据集重复50个epoch。
|
||
>>> dataset = dataset.repeat(50)
|
||
>>>
|
||
>>> # 创建一个数据集，其中每个epoch都是单独打乱的。
|
||
>>> dataset = dataset.shuffle(10)
|
||
>>> dataset = dataset.repeat(50)
|
||
>>>
|
||
>>> # 创建一个数据集，打乱前先将数据集重复
|
||
>>> # 50个epoch。shuffle算子将
|
||
>>> # 整个50个epoch视作一个大数据集。
|
||
>>> dataset = dataset.repeat(50)
|
||
>>> dataset = dataset.shuffle(10)
|
||
|
||
.. py:method:: reset()
|
||
|
||
重置下一个epoch的数据集。
|
||
|
||
.. py:method:: save(file_name, num_files=1, file_type='mindrecord')
|
||
|
||
将流水线正在处理的数据保存为通用的数据集格式。支持的数据集格式：'mindrecord'。
|
||
|
||
将数据保存为'mindrecord'格式时存在隐式类型转换。转换表展示如何执行类型转换。
|
||
|
||
.. list-table:: 保存为'mindrecord'格式时的隐式类型转换
|
||
:widths: 25 25 50
|
||
:header-rows: 1
|
||
|
||
* - 'dataset'类型
|
||
- 'mindrecord'类型
|
||
- 详细
|
||
* - bool
|
||
- None
|
||
- 不支持
|
||
* - int8
|
||
- int32
|
||
-
|
||
* - uint8
|
||
- bytes(1D uint8)
|
||
- Drop dimension
|
||
* - int16
|
||
- int32
|
||
-
|
||
* - uint16
|
||
- int32
|
||
-
|
||
* - int32
|
||
- int32
|
||
-
|
||
* - uint32
|
||
- int64
|
||
-
|
||
* - int64
|
||
- int64
|
||
-
|
||
* - uint64
|
||
- None
|
||
- 不支持
|
||
* - float16
|
||
- float32
|
||
-
|
||
* - float32
|
||
- float32
|
||
-
|
||
* - float64
|
||
- float64
|
||
-
|
||
* - string
|
||
- string
|
||
- 不支持多维字符串
|
||
|
||
.. note::
|
||
1. 如需按顺序保存示例，请将数据集的shuffle设置为False，将 `num_files` 设置为1。
|
||
2. 在调用函数之前，不要使用batch算子、repeat算子或具有随机属性的数据增强的map算子。
|
||
3. 当数据的维度可变时，只支持1维数组或者在0维变化的多维数组。
|
||
4. 不支持DE_UINT64类型、多维的DE_UINT8类型、多维DE_STRING类型。
|
||
|
||
**参数：**
|
||
|
||
- **file_name** (str) - 数据集文件的路径。
|
||
- **num_files** (int, optional) - 数据集文件的数量（默认为1）。
|
||
- **file_type** (str, optional) - 数据集格式（默认为'mindrecord'）。
|
||
|
||
.. py:method:: set_dynamic_columns(columns=None)
|
||
|
||
设置源数据的动态shape信息，需要在定义数据处理流水线后设置。
|
||
|
||
**参数：**
|
||
|
||
- **columns** (dict) - 包含数据集中每列shape信息的字典。shape[i]为 `None` 表示shape[i]的数据长度是动态的。
|
||
|
||
.. py:method:: shuffle(buffer_size)
|
||
|
||
使用以下策略随机打乱此数据集的行：
|
||
|
||
1. 生成一个shuffle缓冲区包含buffer_size条数据行。
|
||
|
||
2. 从shuffle缓冲区中随机选择一个元素，作为下一行传播到子节点。
|
||
|
||
3. 从父节点获取下一行（如果有的话），并将其放入shuffle缓冲区中。
|
||
|
||
4. 重复步骤2和3，直到打乱缓冲区中没有数据行为止。
|
||
|
||
可以提供随机种子，在第一个epoch中使用。在随后的每个epoch，种子都会被设置成一个新产生的随机值。
|
||
|
||
**参数：**
|
||
|
||
- **buffer_size** (int) - 用于shuffle的缓冲区大小（必须大于1）。将buffer_size设置为等于数据集大小将导致在全局shuffle。
|
||
|
||
**返回：**
|
||
|
||
ShuffleDataset，打乱后的数据集对象。
|
||
|
||
**异常：**
|
||
|
||
- **RuntimeError** - 打乱前存在同步操作。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是Dataset对象的实例
|
||
>>> # 可以选择设置第一个epoch的种子
|
||
>>> ds.config.set_seed(58)
|
||
>>> # 使用大小为4的shuffle缓冲区创建打乱后的数据集。
|
||
>>> dataset = dataset.shuffle(4)
|
||
|
||
.. py:method:: skip(count)
|
||
|
||
跳过此数据集的前N个元素。
|
||
|
||
**参数：**
|
||
|
||
- **count** (int) - 要跳过的数据集中的元素个数。
|
||
|
||
**返回：**
|
||
|
||
SkipDataset，减去跳过的行的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是Dataset对象的实例
|
||
>>> # 创建一个数据集，跳过前3个元素
|
||
>>> dataset = dataset.skip(3)
|
||
|
||
.. py:method:: split(sizes, randomize=True)
|
||
|
||
将数据集拆分为多个不重叠的数据集。
|
||
|
||
这是一个通用拆分函数，可以被数据处理流水线中的任何算子调用。
|
||
还有如果直接调用ds.split，其中 ds 是一个 MappableDataset，它将被自动调用。
|
||
|
||
**参数：**
|
||
|
||
- **sizes** (Union[list[int], list[float]]) - 如果指定了一列整数[s1, s2, …, sn]，数据集将被拆分为n个大小为s1、s2、...、sn的数据集。如果所有输入大小的总和不等于原始数据集大小，则报错。如果指定了一列浮点数[f1, f2, …, fn]，则所有浮点数必须介于0和1之间，并且总和必须为1，否则报错。数据集将被拆分为n个大小为round(f1*K)、round(f2*K)、...、round(fn*K)的数据集，其中K是原始数据集的大小。
|
||
|
||
如果舍入后：
|
||
|
||
- 任何大小等于0，都将发生错误。
|
||
- 如果拆分大小的总和<K，K - sigma(round(fi * k))的差值将添加到第一个子数据集。
|
||
- 如果拆分大小的总和>K，sigma(round(fi * K)) - K的差值将从第一个足够大的拆分子集中删除，删除差值后至少有1行。
|
||
|
||
- **randomize** (bool, optional) - 确定是否随机拆分数据（默认为True）。如果为True，则数据集将被随机拆分。否则，将使用数据集中的连续行创建每个拆分子集。
|
||
|
||
.. note::
|
||
1. 如果要调用 split，则无法对数据集进行分片。
|
||
2. 强烈建议不要对数据集进行打乱，而是使用随机化（randomize=True）。对数据集进行打乱的结果具有不确定性，每个拆分子集中的数据在每个epoch可能都不同。
|
||
|
||
**异常：**
|
||
|
||
- **RuntimeError** - get_dataset_size返回None或此数据集不支持。
|
||
- **RuntimeError** - sizes是整数列表，并且size中所有元素的总和不等于数据集大小。
|
||
- **RuntimeError** - sizes是float列表，并且计算后存在大小为0的拆分子数据集。
|
||
- **RuntimeError** - 数据集在调用拆分之前已进行分片。
|
||
- **ValueError** - sizes是float列表，且并非所有float数都在0和1之间，或者float数的总和不等于1。
|
||
|
||
**返回：**
|
||
|
||
tuple(Dataset)，拆分后子数据集对象的元组。
|
||
|
||
**样例：**
|
||
|
||
>>> # TextFileDataset不是可映射dataset，因此将调用通用拆分函数。
|
||
>>> # 由于许多数据集默认都打开了shuffle，如需调用拆分函数，请将shuffle设置为False。
|
||
>>> dataset = ds.TextFileDataset(text_file_dataset_dir, shuffle=False)
|
||
>>> train_dataset, test_dataset = dataset.split([0.9, 0.1])
|
||
|
||
.. py:method:: sync_update(condition_name, num_batch=None, data=None)
|
||
|
||
释放阻塞条件并使用给定数据触发回调函数。
|
||
|
||
**参数：**
|
||
|
||
- **condition_name** (str) - 用于切换发送下一行数据的条件名称。
|
||
- **num_batch** (Union[int, None]) - 释放的batch（row）数。当 `num_batch` 为None时，将默认为 `sync_wait` 算子指定的值（默认为None）。
|
||
- **data** (Any) - 用户自定义传递给回调函数的数据（默认为None）。
|
||
|
||
.. py:method:: sync_wait(condition_name, num_batch=1, callback=None)
|
||
|
||
向输入数据集添加阻塞条件。 将应用同步操作。
|
||
|
||
**参数：**
|
||
|
||
- **condition_name** (str) - 用于切换发送下一行的条件名称。
|
||
- **num_batch** (int) - 每个epoch开始时无阻塞的batch数。
|
||
- **callback** (function) - `sync_update` 中将调用的回调函数。
|
||
|
||
**返回：**
|
||
|
||
SyncWaitDataset，添加了阻塞条件的数据集对象。
|
||
|
||
**异常：**
|
||
|
||
- **RuntimeError** - 条件名称已存在。
|
||
|
||
**样例：**
|
||
|
||
>>> import numpy as np
|
||
>>> def gen():
|
||
... for i in range(100)：
|
||
... yield (np.array(i),)
|
||
>>>
|
||
>>> class Augment:
|
||
... def __init__(self, loss)：
|
||
... self.loss = loss
|
||
...
|
||
... def preprocess(self, input_)：
|
||
... return input_
|
||
...
|
||
... def update(self, data)：
|
||
... self.loss = data["loss"]
|
||
>>>
|
||
>>> batch_size = 4
|
||
>>> dataset = ds.GeneratorDataset(gen, column_names=["input"])
|
||
>>>
|
||
>>> aug = Augment(0)
|
||
>>> dataset = dataset.sync_wait(condition_name="policy", callback=aug.update)
|
||
>>> dataset = dataset.map(operations=[aug.preprocess], input_columns=["input"])
|
||
>>> dataset = dataset.batch(batch_size)
|
||
>>> count = 0
|
||
>>> for data in dataset.create_dict_iterator(num_epochs=1, output_numpy=True)：
|
||
... assert data["input"][0] == count
|
||
... count += batch_size
|
||
... data = {"loss": count}
|
||
... dataset.sync_update(condition_name="policy", data=data)
|
||
|
||
.. py:method:: take(count=-1)
|
||
|
||
从数据集中获取最多给定数量的元素。
|
||
|
||
.. note::
|
||
1. 如果count大于数据集中的元素数或等于-1，则取数据集中的所有元素。
|
||
2. take和batch操作顺序很重要，如果take在batch操作之前，则取给定行数；否则取给定batch数。
|
||
|
||
**参数：**
|
||
|
||
- **count** (int, optional) - 要从数据集中获取的元素数（默认为-1）。
|
||
|
||
**返回：**
|
||
|
||
TakeDataset，取出指定数目的数据集对象。
|
||
|
||
**样例：**
|
||
|
||
>>> # dataset是Dataset对象的实例。
|
||
>>> # 创建一个数据集，包含50个元素。
|
||
>>> dataset = dataset.take(50)
|
||
|
||
.. py:method:: to_device(send_epoch_end=True, create_data_info_queue=False)
|
||
|
||
将数据从CPU传输到GPU、Ascend或其他设备。
|
||
|
||
**参数：**
|
||
|
||
- **send_epoch_end** (bool, optional) - 是否将end of sequence发送到设备（默认为True）。
|
||
- **create_data_info_queue** (bool, optional) - 是否创建存储数据类型和shape的队列（默认值为False）。
|
||
|
||
.. note::
|
||
如果设备为Ascend，则逐个传输数据。每次传输的数据最大限制为256M。
|
||
|
||
**返回：**
|
||
|
||
TransferDataset，用于传输的数据集对象。
|
||
|
||
**异常：**
|
||
|
||
- **RuntimeError** - 如果提供了分布式训练的文件路径但读取失败。
|
||
|
||
.. py:method:: to_json(filename='')
|
||
|
||
将数据处理流水线序列化为JSON字符串，如果提供了文件名，则转储到文件中。
|
||
|
||
**参数：**
|
||
|
||
- **filename** (str) - 另存为JSON格式的文件名。
|
||
|
||
**返回：**
|
||
|
||
str，流水线的JSON字符串。
|