TransformedEnv¶
- class torchrl.envs.transforms.TransformedEnv(*args, **kwargs)[source]¶
一个已转换的(transformed_in)环境。
- 参数:
env (EnvBase) – 要转换的(transformed_in)原始环境。
transform (Transform 或 callable, 可选) –
应用于
env.step(td)
产生的 tensordict 的转换。如果未提供,则使用空的 Compose 占位符,处于评估模式。注意
如果
transform
是一个可调用对象,它必须接收一个 tensordict 作为输入,并输出一个 tensordict。该可调用对象将在step
和reset
时被调用:如果它作用于奖励(在重置时奖励不存在),则需要实现一个检查以确保转换能够顺利运行。>>> def add_1(data): ... if "reward" in data.keys(): ... return data.set("reward", data.get("reward") + 1) ... return data >>> env = TransformedEnv(base_env, add_1)
cache_specs (bool, 可选) – 如果为
True
,则在第一次调用后缓存规格(即,规格只会被转换一次)。如果转换在训练期间发生变化,则原始规格转换可能不再有效,在这种情况下,此值应设置为 False。默认为True
。
- 关键字参数:
auto_unwrap (bool, optional) –
如果为
True
,则将一个 TransformedEnv 包装到另一个 TransformedEnv 中会将内部 TransformedEnv 的转换解包到外部一个(新的实例)中。默认为True
。注意
此行为将在 v0.9 中切换为
False
。
示例
>>> env = GymEnv("Pendulum-v0") >>> transform = RewardScaling(0.0, 1.0) >>> transformed_env = TransformedEnv(env, transform) >>> # check auto-unwrap >>> transformed_env = TransformedEnv(transformed_env, StepCounter()) >>> # The inner env has been unwrapped >>> assert isinstance(transformed_env.base_env, GymEnv)
- add_truncated_keys() TransformedEnv [source]¶
将截断键添加到环境中。
- append_transform(transform: Transform | Callable[[TensorDictBase], TensorDictBase]) TransformedEnv [source]¶
向环境追加一个转换。
Transform
或可调用对象均可接受。
- property batch_locked: bool¶
环境是否可以用于与初始化时不同的批次大小。
如果为 True,则需要在与环境相同批次大小的 tensordict 上使用该环境。batch_locked 是一个不可变属性。
- property batch_size: Size¶
此环境实例中批次化环境的数量,组织为 torch.Size() 对象。
环境可能相似或不同,但假定它们之间几乎没有(如果有的话)交互(例如,多任务或并行批处理执行)。
- eval() TransformedEnv [source]¶
将模块设置为评估模式。
这只对某些模块有影响。请参阅特定模块的文档,了解它们在训练/评估模式下的行为,即它们是否受影响,例如
Dropout
、BatchNorm
等。这等效于
self.train(False)
。请参阅 局部禁用梯度计算,以比较 .eval() 和几种可能与之混淆的类似机制。
- 返回:
self
- 返回类型:
模块
- property input_spec: TensorSpec¶
转换环境的观测规格。
- insert_transform(index: int, transform: Transform) TransformedEnv [source]¶
将转换插入到指定索引的环境中。
Transform
或可调用对象均可接受。
- load_state_dict(state_dict: OrderedDict, **kwargs) None [source]¶
将 state_dict 中的参数和缓冲区复制到此模块及其子模块中。
如果
strict
为True
,则 state_dict 中的键必须与此模块的state_dict()
函数返回的键完全匹配。警告
如果
assign
为True
,则优化器必须在调用load_state_dict
后创建,除非get_swap_module_params_on_conversion()
为True
。- 参数:
state_dict (dict) – 包含参数和持久 buffer 的字典。
strict (bool, optional) – 是否严格执行 state_dict 中的键与此模块的
state_dict()
函数返回的键匹配。默认为True
。assign (bool, optional) – 当设置为
False
时,将保留当前模块中张量的属性;设置为True
时,将保留 state dict 中张量的属性。唯一的例外是requires_grad
字段。Default: ``False`
- 返回:
- missing_keys 是一个包含任何预期键的 str 列表。
在提供的
state_dict
中缺失的任何键的字符串列表。
- unexpected_keys 是一个包含不匹配的键的 str 列表。
不期望但在提供的
state_dict
中存在的键。
- 返回类型:
NamedTuple
,包含missing_keys
和unexpected_keys
字段。
注意
如果参数或缓冲区注册为
None
且其对应键存在于state_dict
中,load_state_dict()
将引发RuntimeError
。
- property output_spec: TensorSpec¶
转换环境的观测规格。
- rand_action(tensordict: TensorDictBase | None = None) TensorDict [source]¶
根据 action_spec 属性执行随机动作。
- 参数:
tensordict (TensorDictBase, optional) – 要将生成的动作写入的 tensordict。
- 返回:
一个 tensordict 对象,其“action”条目已用从 action-spec 中随机抽取的样本更新。
- state_dict(*args, **kwargs) OrderedDict [source]¶
返回一个字典,其中包含对模块整个状态的引用。
参数和持久缓冲区(例如,运行平均值)都包含在内。键是相应的参数和缓冲区名称。设置为
None
的参数和缓冲区不包含在内。注意
返回的对象是浅拷贝。它包含对模块参数和缓冲区的引用。
警告
目前
state_dict()
也接受destination
、prefix
和keep_vars
的位置参数,按顺序排列。但是,这正在被弃用,并且在未来的版本中将强制使用关键字参数。警告
请避免使用参数
destination
,因为它不是为最终用户设计的。- 参数:
destination (dict, optional) – 如果提供,模块的状态将更新到 dict 中,并返回相同的对象。否则,将创建一个
OrderedDict
并返回。默认为None
。prefix (str, optional) – a prefix added to parameter and buffer names to compose the keys in state_dict. Default:
''
。keep_vars (bool, optional) – 默认情况下,state dict 中返回的
Tensor
已从 autograd 中分离。如果设置为True
,则不会执行分离。默认为False
。
- 返回:
包含模块整体状态的字典
- 返回类型:
dict
示例
>>> # xdoctest: +SKIP("undefined vars") >>> module.state_dict().keys() ['bias', 'weight']
- to(*args, **kwargs) TransformedEnv [source]¶
移动和/或转换参数和缓冲区。
这可以这样调用
- to(device=None, dtype=None, non_blocking=False)[source]
- to(dtype, non_blocking=False)[source]
- to(tensor, non_blocking=False)[source]
- to(memory_format=torch.channels_last)[source]
其签名类似于
torch.Tensor.to()
,但只接受浮点数或复数dtype
。此外,此方法只会将浮点数或复数参数和缓冲区转换为dtype
(如果已给出)。整数参数和缓冲区将被移动到device
(如果已给出),但 dtype 不变。当设置non_blocking
时,它会尝试异步(相对于主机)进行转换/移动(如果可能),例如,将具有固定内存的 CPU 张量移动到 CUDA 设备。有关示例,请参阅下文。
注意
此方法就地修改模块。
- 参数:
device (
torch.device
) – 此模块中参数和缓冲区的所需设备。dtype (
torch.dtype
) – 此模块中参数和缓冲区的所需浮点数或复数 dtype。tensor (torch.Tensor) – 张量,其 dtype 和 device 是此模块中所有参数和缓冲区的所需 dtype 和 device。
memory_format (
torch.memory_format
) – 此模块中 4D 参数和缓冲区的所需内存格式(仅关键字参数)。
- 返回:
self
- 返回类型:
模块
示例
>>> # xdoctest: +IGNORE_WANT("non-deterministic") >>> linear = nn.Linear(2, 2) >>> linear.weight Parameter containing: tensor([[ 0.1913, -0.3420], [-0.5113, -0.2325]]) >>> linear.to(torch.double) Linear(in_features=2, out_features=2, bias=True) >>> linear.weight Parameter containing: tensor([[ 0.1913, -0.3420], [-0.5113, -0.2325]], dtype=torch.float64) >>> # xdoctest: +REQUIRES(env:TORCH_DOCTEST_CUDA1) >>> gpu1 = torch.device("cuda:1") >>> linear.to(gpu1, dtype=torch.half, non_blocking=True) Linear(in_features=2, out_features=2, bias=True) >>> linear.weight Parameter containing: tensor([[ 0.1914, -0.3420], [-0.5112, -0.2324]], dtype=torch.float16, device='cuda:1') >>> cpu = torch.device("cpu") >>> linear.to(cpu) Linear(in_features=2, out_features=2, bias=True) >>> linear.weight Parameter containing: tensor([[ 0.1914, -0.3420], [-0.5112, -0.2324]], dtype=torch.float16) >>> linear = nn.Linear(2, 2, bias=None).to(torch.cdouble) >>> linear.weight Parameter containing: tensor([[ 0.3741+0.j, 0.2382+0.j], [ 0.5593+0.j, -0.4443+0.j]], dtype=torch.complex128) >>> linear(torch.ones(3, 2, dtype=torch.cdouble)) tensor([[0.6122+0.j, 0.1150+0.j], [0.6122+0.j, 0.1150+0.j], [0.6122+0.j, 0.1150+0.j]], dtype=torch.complex128)
- train(mode: bool = True) TransformedEnv [source]¶
将模块设置为训练模式。
这只对某些模块有影响。请参阅特定模块的文档,了解它们在训练/评估模式下的行为,即它们是否受影响,例如
Dropout
、BatchNorm
等。- 参数:
mode (bool) – 是设置训练模式(
True
)还是评估模式(False
)。默认为True
。- 返回:
self
- 返回类型:
模块