TensorDictBase.from_csv#
- classmethod TensorDictBase.from_csv(path, *, auto_batch_size: bool = False, batch_dims: int | None = None, device: device | None = None, batch_size: Size | None = None, separator: str | None = None, dtype: dtype | None = None, **kwargs) Self#
Reads a CSV file into a tensordict, with one entry per column.
Requires pandas or pyarrow: the file is read with
pandas.read_csv()when pandas is installed, and withpyarrow.csv.read_csvotherwise. The columns are converted as infrom_pandas().to_csv()writes such a file. Through pandas, a string column is one value for the whole batch (see the note infrom_pandas()); through pyarrow, it is aNonTensorStackwith one value per row.- Parameters:
path (str or Path) – the path of the CSV file.
- Keyword Arguments:
auto_batch_size (bool, optional) – if
True, sets the batch size to the largest leading shape that all the entries share. Exclusive withbatch_size. Defaults toFalse.batch_dims (int, optional) – with
auto_batch_size, the maximum number of batch dimensions. Ignored withoutauto_batch_size, with aFutureWarningwhen it would change the result. Starting with TensorDict 0.17, the default will change to turning onauto_batch_sizewhenbatch_dimsis given, asfrom_dictdoes. Defaults toNone.device (device, str or int, optional) – the device of the result. Leaves on another device are moved to it.
Noneleaves each leaf where it is, and the result has no device. Defaults toNone.batch_size (Size or list of int, optional) – the batch size of the result: the leading dimensions that all its entries share. Exclusive with
auto_batch_size. Defaults toNone, which gives[num_rows].separator (str, optional) – if given, splits the column names on it to build nested entries: with
separator=".", the column"obs.x"becomes the entry("obs", "x"). Defaults toNone, which keeps the column names as keys.dtype (dtype, optional) – if given, casts the numeric and boolean columns to it. Defaults to
None, which keeps the dtype of each column.**kwargs – passed to the CSV reader.
- Returns:
A tensordict of the class this method is called on (
TensorDictforTensorDictBase).
Examples
>>> import os >>> import tempfile >>> import torch >>> from tensordict import TensorDict >>> data = TensorDict(obs=torch.arange(3.0), reward=torch.ones(3), batch_size=[3]) >>> with tempfile.TemporaryDirectory() as tmpdir: ... path = os.path.join(tmpdir, "data.csv") ... data.to_csv(path) ... td = TensorDict.from_csv(path) ... td32 = TensorDict.from_csv(path, dtype=torch.float32) >>> td.batch_size, td["obs"].dtype, td32["obs"].dtype (torch.Size([3]), torch.float64, torch.float32)
Every tensordict class and every tensorclass has this method. For the other methods, see Methods by task.