airflow.providers.microsoft.azure.hooks.container_instance

类

AzureContainerInstanceHook

用于与 Azure 容器实例通信的 Hook。

模块内容

class airflow.providers.microsoft.azure.hooks.container_instance.AzureContainerInstanceHook(azure_conn_id=default_conn_name)[source]

基类: airflow.providers.microsoft.azure.hooks.base_azure.AzureBaseHook

用于与 Azure 容器实例通信的 Hook。

此 Hook 需要服务主体才能工作。创建服务主体后（Azure Active Directory/应用注册），您需要将 client_id（应用程序 ID）填写为登录名，将生成的密码填写为密码，并在 extra 字段中以 json 格式填写 tenantId 和 subscriptionId。

参数：

azure_conn_id (str) – Azure 连接 ID，是用于启动容器实例的服务主体的连接 ID。

conn_name_attr = 'azure_conn_id'[source]
default_conn_name = 'azure_default'[source]
conn_type = 'azure_container_instance'[source]
hook_name = 'Azure Container Instance'[source]
property connection[source]
get_conn()[source]

使用初始化时传入的连接 ID 对资源进行身份验证。

返回：

已认证的客户端。

返回类型：

Any

create_or_update(resource_group, name, container_group)[source]

创建一个新的容器组。

参数：

  • resource_group (str) – 资源组的名称

  • name (str) – 容器组的名称

  • container_group (azure.mgmt.containerinstance.models.ContainerGroup) – 容器组的属性

get_state(resource_group, name)[source]

获取容器组的状态。

参数：

  • resource_group (str) – 资源组的名称

  • name (str) – 容器组的名称

返回：

ContainerGroup

返回类型：

azure.mgmt.containerinstance.models.ContainerGroup

get_logs(resource_group, name, tail=1000)[source]

获取容器组日志的末尾部分。

参数：

  • resource_group (str) – 资源组的名称

  • name (str) – 容器组的名称

  • tail (int) – 末尾部分的尺寸

返回：

日志消息列表

返回类型：

list

delete(resource_group, name)[source]

删除一个容器组。

参数：

  • resource_group (str) – 资源组的名称

  • name (str) – 容器组的名称

exists(resource_group, name)[source]

测试容器组是否存在。

参数：

  • resource_group (str) – 资源组的名称

  • name (str) – 容器组的名称

test_connection()[source]

测试已配置的 Azure 容器实例连接。

本条目有帮助吗？