airflow.providers.microsoft.psrp.hooks.psrp¶

属性¶

`INFORMATIONAL_RECORD_LEVEL_MAP`
`OutputCallback`

类¶

PsrpHook

用于PowerShell远程协议执行的Hook。

模块内容¶

airflow.providers.microsoft.psrp.hooks.psrp.INFORMATIONAL_RECORD_LEVEL_MAP[源码]¶

airflow.providers.microsoft.psrp.hooks.psrp.OutputCallback[源码]¶

class airflow.providers.microsoft.psrp.hooks.psrp.PsrpHook(psrp_conn_id, logging_level=DEBUG, operation_timeout=None, runspace_options=None, wsman_options=None, on_output_callback=None, exchange_keys=True, host=None)[源码]¶

基类: airflow.hooks.base.BaseHook

用于PowerShell远程协议执行的Hook。

当用作上下文管理器时，runspace池将在shell会话之间重用。

参数:

psrp_conn_id (str) – 必需。PSRP连接的名称。
logging_level (int) – 远程执行期间接收的消息流的日志级别。默认设置是将所有消息包含在任务日志中。
operation_timeout (int | None) – 轮询管道时，覆盖默认的WSMan超时。
runspace_options (dict[str, Any] | None) – 可选字典，用于创建runspace池时传递。有关可用选项的描述，请参阅RunspacePool。
wsman_options (dict[str, Any] | None) – 可选字典，用于创建WSMan客户端时传递。有关可用选项的描述，请参阅WSMan。
on_output_callback (OutputCallback | None) – 可选回调函数，用于在作业状态轮询期间收到输出响应项时调用。
exchange_keys (bool) – 如果为true（默认），当hook用作上下文管理器时，自动启动会话密钥交换。
host (pypsrp.host.PSHost | None) – 可选的PowerShell主机实例。如果未设置，将使用默认实现。

您可以使用runspace_options或将此键设置为连接的额外字段来提供替代的configuration_name。

conn_name_attr = 'psrp_conn_id'[源码]¶

default_conn_name = 'psrp_default'[源码]¶

conn_type = 'psrp'[源码]¶

hook_name = 'PowerShell 远程协议'[源码]¶

conn_id[源码]¶

__enter__()[源码]¶

__exit__(exc_type, exc_value, traceback)[源码]¶

get_conn()[源码]¶

返回一个runspace池。

返回的对象必须用作上下文管理器。

invoke()[源码]¶

生成一个可以添加命令的PowerShell对象。

退出时，将调用命令。

invoke_cmdlet(name, use_local_scope=None, arguments=None, parameters=None)[源码]¶

调用PowerShell cmdlet并返回会话。

invoke_powershell(script)[源码]¶

调用PowerShell脚本并返回会话。

test_connection()[源码]¶: 测试PSRP连接。