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)[源码]

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

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

此 Hook 需要一个服务主体才能工作。创建此服务主体(Azure Active Directory/应用程序注册)后,您需要在 extra 字段中填写 client_id(应用程序 ID)作为登录名,生成的密码作为密码,以及 tenantId 和 subscriptionId 作为 json。

参数

azure_conn_id (str) – Azure 连接 ID,服务主体将使用该 ID 来启动容器实例。

conn_name_attr = 'azure_conn_id'[源码]
default_conn_name = 'azure_default'[源码]
conn_type = 'azure_container_instance'[源码]
hook_name = 'Azure 容器 实例'[源码]
connection()[源码]
get_conn()[源码]

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

返回

已验证的客户端。

返回类型

Any

create_or_update(resource_group, name, container_group)[源码]

创建新的容器组。

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

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

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

get_state(resource_group, name)[源码]

获取容器组的状态。

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

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

返回

ContainerGroup

返回类型

azure.mgmt.containerinstance.models.ContainerGroup

get_logs(resource_group, name, tail=1000)[源码]

获取容器组日志的尾部。

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

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

  • tail (int) – 尾部的大小

返回

日志消息列表

返回类型

list

delete(resource_group, name)[源码]

删除容器组。

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

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

exists(resource_group, name)[源码]

测试容器组是否存在。

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

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

test_connection()[源码]

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

此条目是否有帮助?