airflow.providers.google.cloud.operators.dataproc_metastore¶

此模块包含 Google Dataproc Metastore Operator（操作符）。

属性¶

`BASE_LINK`
`METASTORE_BASE_LINK`
`METASTORE_BACKUP_LINK`
`METASTORE_BACKUPS_LINK`
`METASTORE_EXPORT_LINK`
`METASTORE_IMPORT_LINK`
`METASTORE_SERVICE_LINK`

类¶

`DataprocMetastoreLink`	用于构建 Dataproc Metastore 资源链接的辅助类。
`DataprocMetastoreDetailedLink`	用于构建 Dataproc Metastore 详细资源链接的辅助类。
`DataprocMetastoreCreateBackupOperator`	在给定的项目和位置中创建一个新的备份。
`DataprocMetastoreCreateMetadataImportOperator`	在给定的项目和位置中创建一个新的 MetadataImport。
`DataprocMetastoreCreateServiceOperator`	在项目和位置中创建一个 metastore 服务。
`DataprocMetastoreDeleteBackupOperator`	删除单个备份。
`DataprocMetastoreDeleteServiceOperator`	删除单个服务。
`DataprocMetastoreExportMetadataOperator`	从服务中导出元数据。
`DataprocMetastoreGetServiceOperator`	获取单个服务的详细信息。
`DataprocMetastoreListBackupsOperator`	列出服务中的备份。
`DataprocMetastoreRestoreServiceOperator`	从备份中恢复服务。
`DataprocMetastoreUpdateServiceOperator`	更新单个服务的参数。

模块内容¶

airflow.providers.google.cloud.operators.dataproc_metastore.BASE_LINK = 'https://console.cloud.google.com'[source]¶

airflow.providers.google.cloud.operators.dataproc_metastore.METASTORE_BASE_LINK = 'https://console.cloud.google.com/dataproc/metastore/services/{region}/{service_id}'[source]¶

airflow.providers.google.cloud.operators.dataproc_metastore.METASTORE_BACKUP_LINK = 'https://console.cloud.google.com/dataproc/metastore/services/{region}/{service_id}/backups/{reso...[source]¶

airflow.providers.google.cloud.operators.dataproc_metastore.METASTORE_BACKUPS_LINK = 'https://console.cloud.google.com/dataproc/metastore/services/{region}/{service_id}/backuprestore...[source]¶

airflow.providers.google.cloud.operators.dataproc_metastore.METASTORE_EXPORT_LINK = 'https://console.cloud.google.com/dataproc/metastore/services/{region}/{service_id}/importexport?...[source]¶

airflow.providers.google.cloud.operators.dataproc_metastore.METASTORE_IMPORT_LINK = 'https://console.cloud.google.com/dataproc/metastore/services/{region}/{service_id}/imports/{reso...[source]¶

airflow.providers.google.cloud.operators.dataproc_metastore.METASTORE_SERVICE_LINK = 'https://console.cloud.google.com/dataproc/metastore/services/{region}/{service_id}/config?projec...[source]¶

class airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreLink[source]¶

Bases: airflow.sdk.BaseOperatorLink

用于构建 Dataproc Metastore 资源链接的辅助类。

name = 'Dataproc Metastore'[source]¶: 链接的名称。这将是任务 UI 上的按钮名称。

key = 'conf'[source]¶

static persist(context, task_instance, url)[source]¶

get_link(operator, *, ti_key)[source]¶

指向外部系统的链接。

参数：

operator (airflow.models.BaseOperator) – 此链接关联的 Airflow operator 对象。
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 返回链接的 TaskInstance ID。

返回：

指向外部系统的链接

返回类型：

str

class airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreDetailedLink[source]¶

Bases: airflow.sdk.BaseOperatorLink

用于构建 Dataproc Metastore 详细资源链接的辅助类。

name = 'Dataproc Metastore 资源'[source]¶: 链接的名称。这将是任务 UI 上的按钮名称。

key = 'config'[source]¶

static persist(context, task_instance, url, resource)[source]¶

get_link(operator, *, ti_key)[source]¶

指向外部系统的链接。

参数：

operator (airflow.models.BaseOperator) – 此链接关联的 Airflow operator 对象。
ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 返回链接的 TaskInstance ID。

返回：

指向外部系统的链接

返回类型：

str

class airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreCreateBackupOperator(*, project_id, region, service_id, backup, backup_id, request_id=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

在给定的项目和位置中创建一个新的备份。

参数：

project_id (str) – 必填。服务所属的 Google Cloud 项目的 ID。
region (str) – 必填。服务所属的 Google Cloud 区域的 ID。
service_id (str) –
必填。metastore 服务的 ID，用作 metastore 服务名称的最后一部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 service_id 字段；如果提供了 request，则不应设置此项。
backup (dict | google.cloud.metastore_v1.types.Backup) –
必填。要创建的备份。将忽略 name 字段。创建的备份的 ID 必须在请求的 backup_id 字段中提供。

这对应于 request 实例上的 backup 字段；如果提供了 request，则不应设置此项。
backup_id (str) –
必填。备份的 ID，用作备份名称的最后一部分。此值必须包含 1 到 64 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 backup_id 字段；如果提供了 request，则不应设置此项。
request_id (str | None) – 可选。用于标识请求的唯一 ID。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 可选。指定应重试哪些错误（如果有）。
timeout (float | None) – 可选。此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 可选。应随请求作为元数据发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'backup', 'impersonation_chain')[source]¶

template_fields_renderers[source]¶

operator_extra_links[source]¶

project_id[source]¶

region[source]¶

service_id[source]¶

backup[source]¶

backup_id[source]¶

request_id = None[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreCreateMetadataImportOperator(*, project_id, region, service_id, metadata_import, metadata_import_id, request_id=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

在给定的项目和位置中创建一个新的 MetadataImport。

参数：

project_id (str) – 必填。服务所属的 Google Cloud 项目的 ID。
region (str) – 必填。服务所属的 Google Cloud 区域的 ID。
service_id (str) –
必填。metastore 服务的 ID，用作 metastore 服务名称的最后一部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 service_id 字段；如果提供了 request，则不应设置此项。
metadata_import (dict | google.cloud.metastore_v1.types.MetadataImport) –
必填。要创建的元数据导入。将忽略 name 字段。创建的元数据导入的 ID 必须在请求的 metadata_import_id 字段中提供。

这对应于 request 实例上的 metadata_import 字段；如果提供了 request，则不应设置此项。
metadata_import_id (str) –
必填。元数据导入的 ID，用作元数据导入名称的最后一部分。此值必须包含 1 到 64 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 metadata_import_id 字段；如果提供了 request，则不应设置此项。
request_id (str | None) – 可选。用于标识请求的唯一 ID。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 可选。指定应重试哪些错误（如果有）。
timeout (float | None) – 可选。此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 可选。应随请求作为元数据发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'metadata_import', 'impersonation_chain')[source]¶

template_fields_renderers[source]¶

operator_extra_links[source]¶

project_id[source]¶

region[source]¶

service_id[source]¶

metadata_import[source]¶

metadata_import_id[source]¶

request_id = None[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreCreateServiceOperator(*, region, project_id, service, service_id, request_id=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

在项目和位置中创建一个 metastore 服务。

参数：

region (str) – 必填。服务所属的 Google Cloud 区域的 ID。
project_id (str) – 必填。服务所属的 Google Cloud 项目的 ID。
service (dict | google.cloud.metastore_v1.types.Service) –
必需。要创建的 Metastore 服务。将忽略 name 字段。创建的 metastore 服务的 ID 必须在请求的 service_id 字段中提供。

这对应于请求实例上的 service 字段；如果提供了 request，则不应设置此项。
service_id (str) –
必填。metastore 服务的 ID，用作 metastore 服务名称的最后一部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 service_id 字段；如果提供了 request，则不应设置此项。
request_id (str | None) – 可选。用于标识请求的唯一 ID。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定哪些错误（如果有）应该重试。
timeout (float | None) – 此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 应作为元数据随请求发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'service', 'impersonation_chain')[source]¶

template_fields_renderers[source]¶

operator_extra_links[source]¶

region[source]¶

project_id[source]¶

service[source]¶

service_id[source]¶

request_id = None[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreDeleteBackupOperator(*, project_id, region, service_id, backup_id, request_id=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

删除单个备份。

参数：

project_id (str) – 必需。备份所属的 Google Cloud 项目 ID。
region (str) – 必需。备份所属的 Google Cloud 区域 ID。
service_id (str) –
必填。metastore 服务的 ID，用作 metastore 服务名称的最后一部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 service_id 字段；如果提供了 request，则不应设置此项。
backup_id (str) –
必填。备份的 ID，用作备份名称的最后一部分。此值必须包含 1 到 64 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 backup_id 字段；如果提供了 request，则不应设置此项。
request_id (str | None) – 可选。用于标识请求的唯一 ID。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 可选。指定应重试哪些错误（如果有）。
timeout (float | None) – 可选。此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 可选。应随请求作为元数据发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'impersonation_chain')[source]¶

project_id[source]¶

region[source]¶

service_id[source]¶

backup_id[source]¶

request_id = None[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreDeleteServiceOperator(*, region, project_id, service_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

删除单个服务。

参数：

region (str) – 必填。服务所属的 Google Cloud 区域的 ID。
project_id (str) – 必填。服务所属的 Google Cloud 项目的 ID。
service_id (str) – 必需。Metastore 服务的 ID，用作 Metastore 服务名称的最后一个组成部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且仅包含字母数字 ASCII 字符或连字符。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定哪些错误（如果有）应该重试。
timeout (float | None) – 此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 应作为元数据随请求发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'impersonation_chain')[source]¶

region[source]¶

project_id[source]¶

service_id[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

class airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreExportMetadataOperator(*, destination_gcs_folder, project_id, region, service_id, request_id=None, database_dump_type=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

从服务中导出元数据。

参数：

destination_gcs_folder (str) – 文件夹的 Cloud Storage URI，格式为 gs://<桶名称>/<桶内路径>。将在此路径下创建一个包含导出文件的子文件夹 <导出文件夹>。
project_id (str) – 必填。服务所属的 Google Cloud 项目的 ID。
region (str) – 必填。服务所属的 Google Cloud 区域的 ID。
service_id (str) – 必需。Metastore 服务的 ID，用作 Metastore 服务名称的最后一个组成部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且仅包含字母数字 ASCII 字符或连字符。这对应于请求实例上的 service_id 字段；如果提供了 request，则不应设置此项。
request_id (str | None) – 可选。用于标识请求的唯一 ID。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 可选。指定应重试哪些错误（如果有）。
timeout (float | None) – 可选。此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 可选。应随请求作为元数据发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'impersonation_chain')[source]¶

operator_extra_links[source]¶

destination_gcs_folder[source]¶

project_id[source]¶

region[source]¶

service_id[source]¶

request_id = None[source]¶

database_dump_type = None[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

类 airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreGetServiceOperator(*, region, project_id, service_id, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

获取单个服务的详细信息。

参数：

region (str) – 必填。服务所属的 Google Cloud 区域的 ID。
project_id (str) – 必填。服务所属的 Google Cloud 项目的 ID。
service_id (str) –
必填。metastore 服务的 ID，用作 metastore 服务名称的最后一部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 service_id 字段；如果提供了 request，则不应设置此项。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 指定哪些错误（如果有）应该重试。
timeout (float | None) – 此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 应作为元数据随请求发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'impersonation_chain')[source]¶

operator_extra_links[source]¶

region[source]¶

project_id[source]¶

service_id[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

类 airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreListBackupsOperator(*, project_id, region, service_id, page_size=None, page_token=None, filter=None, order_by=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

列出服务中的备份。

参数：

project_id (str) – 必需。备份所属的 Google Cloud 项目 ID。
region (str) – 必需。备份所属的 Google Cloud 区域 ID。
service_id (str) –
必填。metastore 服务的 ID，用作 metastore 服务名称的最后一部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 service_id 字段；如果提供了 request，则不应设置此项。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 可选。指定应重试哪些错误（如果有）。
timeout (float | None) – 可选。此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 可选。应随请求作为元数据发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'impersonation_chain')[source]¶

operator_extra_links[source]¶

project_id[source]¶

region[source]¶

service_id[source]¶

page_size = None[source]¶

page_token = None[source]¶

filter = None[source]¶

order_by = None[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

类 airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreRestoreServiceOperator(*, project_id, region, service_id, backup_project_id, backup_region, backup_service_id, backup_id, restore_type=None, request_id=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

从备份中恢复服务。

参数：

project_id (str) – 必填。服务所属的 Google Cloud 项目的 ID。
region (str) – 必填。服务所属的 Google Cloud 区域的 ID。
service_id (str) –
必填。metastore 服务的 ID，用作 metastore 服务名称的最后一部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 service_id 字段；如果提供了 request，则不应设置此项。
backup_project_id (str) – 必需。用于从中恢复 metastore 服务备份的 Google Cloud 项目 ID。
backup_region (str) – 必需。用于从中恢复 metastore 服务备份的 Google Cloud 区域 ID。
backup_service_id (str) – 必需。用于从中恢复 metastore 服务备份的 ID，该 ID 用作 metastore 服务名称的最后一个组成部分。该值必须包含 2 到 63 个字符（含），以字母开头，以字母或数字结尾，由字母数字 ASCII 字符或连字符组成。
backup_id (str) – 必需。用于从中恢复的 metastore 服务备份的 ID
restore_type (google.cloud.metastore_v1.types.metastore.Restore | None) – 可选。恢复类型。如果未指定，则默认为 METADATA_ONLY
request_id (str | None) – 可选。用于标识请求的唯一 ID。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 可选。指定应重试哪些错误（如果有）。
timeout (float | None) – 可选。此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 可选。应随请求作为元数据发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。

template_fields: collections.abc.Sequence[str] = ('project_id', 'impersonation_chain')[source]¶

operator_extra_links[source]¶

project_id[source]¶

region[source]¶

service_id[source]¶

backup_project_id[source]¶

backup_region[source]¶

backup_service_id[source]¶

backup_id[source]¶

restore_type = None[source]¶

request_id = None[source]¶

retry[source]¶

timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

execute(context)[source]¶

创建 operator 时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文信息，请参阅 get_template_context。

类 airflow.providers.google.cloud.operators.dataproc_metastore.DataprocMetastoreUpdateServiceOperator(*, project_id, region, service_id, service, update_mask, request_id=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

更新单个服务的参数。

参数：

project_id (str) – 必填。服务所属的 Google Cloud 项目的 ID。
region (str) – 必填。服务所属的 Google Cloud 区域的 ID。
service_id (str) –
必填。metastore 服务的 ID，用作 metastore 服务名称的最后一部分。此值必须包含 2 到 63 个字符，以字母开头，以字母或数字结尾，并且包含字母数字 ASCII 字符或连字符。

这对应于 request 实例上的 service_id 字段；如果提供了 request，则不应设置此项。
service (dict | google.cloud.metastore_v1.types.Service) –
必需。要更新的 metastore 服务。服务器仅在 update_mask 中指定了服务字段时才合并这些字段。

metastore 服务的 name 字段用于标识要更新的 metastore 服务。

这对应于请求实例上的 service 字段；如果提供了 request，则不应设置此项。
update_mask (google.protobuf.field_mask_pb2.FieldMask) –
必需。一个字段掩码，用于指定在更新中要覆盖 metastore 服务资源中的哪些字段。update_mask 中指定的字段是相对于资源而言的（而非相对于整个请求）。如果在掩码中指定了某个字段，则该字段将被覆盖。

这对应于 request 实例上的 update_mask 字段；如果提供了 request，则不应设置此字段。
request_id (str | None) – 可选。用于标识请求的唯一 ID。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 可选。指定应重试哪些错误（如果有）。
timeout (float | None) – 可选。此请求的超时时间。
metadata (collections.abc.Sequence[tuple[str, str]]) – 可选。应随请求作为元数据发送的字符串。
gcp_conn_id (str) – 用于连接到 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐号，或获取列表中最后一个帐号（将在请求中模拟该帐号）的 access_token 所需的帐号链列表。如果设置为字符串，该帐号必须授予发起帐号 Service Account Token Creator IAM 角色。如果设置为序列，列表中的身份必须授予紧随其前的身份 Service Account Token Creator IAM 角色，列表中第一个帐号授予发起帐号此角色（模板化）。