• 首页
• airflow.providers.google
• airflow.providers.google.cloud
• airflow.providers.google.cloud.operators
• airflow.providers.google.cloud.operators.vision

airflow.providers.google.cloud.operators.vision

此模块包含一个 Google Cloud Vision 操作符。

模块内容

类

CloudVisionCreateProductSetOperator	创建新的 ProductSet 资源。
CloudVisionGetProductSetOperator	获取与 ProductSet 关联的信息。
CloudVisionUpdateProductSetOperator	更改 ProductSet 资源。
CloudVisionDeleteProductSetOperator	永久删除 ProductSet。
CloudVisionCreateProductOperator	创建并返回新的 product 资源。
CloudVisionGetProductOperator	获取与 Product 关联的信息。
CloudVisionUpdateProductOperator	更改 Product 资源。
CloudVisionDeleteProductOperator	永久删除产品及其参考图像。
CloudVisionImageAnnotateOperator	对单个图像或一批图像运行图像检测和注释。
CloudVisionCreateReferenceImageOperator	创建并返回新的 ReferenceImage ID 资源。
CloudVisionDeleteReferenceImageOperator	删除 ReferenceImage ID 资源。
CloudVisionAddProductToProductSetOperator	将 Product 添加到指定的 ProductSet。
CloudVisionRemoveProductFromProductSetOperator	从指定的 ProductSet 中删除 Product。
CloudVisionDetectTextOperator	检测图像中的文本。
CloudVisionTextDetectOperator	检测图像中的文档文本。
CloudVisionDetectImageLabelsOperator	检测图像中的文档文本。
CloudVisionDetectImageSafeSearchOperator	检测图像中的文档文本。

函数

prepare_additional_parameters(additional_properties, ...)

为 additional_properties 参数创建一个值。

属性

MetaData

airflow.providers.google.cloud.operators.vision.MetaData

class airflow.providers.google.cloud.operators.vision.CloudVisionCreateProductSetOperator(*, product_set, location, project_id=PROVIDE_PROJECT_ID, product_set_id=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

创建新的 ProductSet 资源。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionProductSetCreateOperator

参数

• product_set (dict | google.cloud.vision_v1.ProductSet) – （必需）要创建的 ProductSet。如果提供 dict，则其形式必须与 protobuf 消息 ProductSet 相同。

• location (str) – （必需）应在其中创建 ProductSet 的区域。有效区域（截至 2019-02-05）为：us-east1、us-west1、europe-west1、asia-east1

• project_id (str) – （可选）应在其中创建 ProductSet 的项目。如果设置为 None 或缺失，则使用 Google Cloud 连接中的默认 project_id。

• product_set_id (str | None) – （可选）此 ProductSet 的用户提供的资源 ID。如果设置，服务器将尝试使用此值作为资源 ID。如果已被使用，则返回错误代码 ALREADY_EXISTS。长度必须最多为 128 个字符。它不能包含字符 /。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_set_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionGetProductSetOperator(*, location, product_set_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

获取与 ProductSet 关联的信息。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionGetProductSetOperator

参数

• location (str) – (必填) ProductSet 所在的区域。有效的区域（截至 2019-02-05）为：us-east1、us-west1、europe-west1、asia-east1

• product_set_id (str) – (必填) 此 ProductSet 的资源 ID。

• project_id (str) – (可选) ProductSet 所在的 Project。如果设置为 None 或缺失，则使用 Google Cloud 连接中的默认 project_id。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_set_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionUpdateProductSetOperator(*, product_set, location=None, product_set_id=None, project_id=PROVIDE_PROJECT_ID, update_mask=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

更改 ProductSet 资源。

目前只能更新 display_name。

注意

要定位 ProductSet 资源，需要其 name，格式为 projects/PROJECT_ID/locations/LOC_ID/productSets/PRODUCT_SET_ID。

您可以直接将 name` 作为 ``product_set`` 对象的属性提供。您也可以将其留空，在这种情况下，name 将由操作符根据 location 和 product_set_id 创建（可选地，还可以使用 project_id；如果不存在，则将使用连接默认值）。

提供此机制是为了您的方便，允许您将 project_id 留空，并让 Airflow 使用连接默认值。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionUpdateProductSetOperator

参数

• product_set (dict | google.cloud.vision_v1.ProductSet) – (必填) 替换服务器上的 ProductSet 资源。如果提供的是字典，则其格式必须与 protobuf 消息 ProductSet 相同。

• location (str | None) – (可选) ProductSet 所在的区域。有效的区域（截至 2019-02-05）为：us-east1、us-west1、europe-west1、asia-east1

• product_set_id (str | None) – (可选) 此 ProductSet 的资源 ID。

• project_id (str) – （可选）应在其中创建 ProductSet 的项目。如果设置为 None 或缺失，则使用 Google Cloud 连接中的默认 project_id。

• update_mask (dict | google.protobuf.field_mask_pb2.FieldMask | None) – (可选) 指定要更新的字段的 FieldMask。如果未指定 update_mask，则将更新所有可变字段。有效的掩码路径是 display_name。如果提供的是字典，则其格式必须与 protobuf 消息 FieldMask 相同。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_set_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionDeleteProductSetOperator(*, location, product_set_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

永久删除 ProductSet。

不会删除 ProductSet 中的 Products 和 ReferenceImages。也不会从 Google Cloud Storage 中删除实际的图像文件。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionDeleteProductSetOperator

参数

• location (str) – (必填) ProductSet 所在的区域。有效的区域（截至 2019-02-05）为：us-east1、us-west1、europe-west1、asia-east1

• product_set_id (str) – (必填) 此 ProductSet 的资源 ID。

• project_id (str) – （可选）应在其中创建 ProductSet 的项目。如果设置为 None 或缺失，则使用 Google Cloud 连接中的默认 project_id。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_set_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionCreateProductOperator(*, location, product, project_id=PROVIDE_PROJECT_ID, product_id=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

创建并返回新的 product 资源。

关于提供的 Product 对象可能出现的错误

• 如果 display_name 缺失或长度超过 4096 个字符，则返回 INVALID_ARGUMENT。

• 如果 description 长度超过 4096 个字符，则返回 INVALID_ARGUMENT。

• 如果 product_category 缺失或无效，则返回 INVALID_ARGUMENT。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionCreateProductOperator

参数

• location (str) – （必需）应创建 Product 的区域。截至 2019-02-05，有效的区域为：us-east1、us-west1、europe-west1、asia-east1

• product (str) – （必需）要创建的产品。如果提供字典，则其格式必须与 protobuf 消息 Product 相同。

• project_id (str) – （可选）应在其中创建 Product 的项目。如果设置为 None 或缺失，则使用来自 Google Cloud 连接的默认 project_id。

• product_id (str | None) – （可选）为此 Product 提供用户定义的资源 ID。如果设置，服务器将尝试使用此值作为资源 ID。如果它已被使用，则返回代码为 ALREADY_EXISTS 的错误。长度必须最多为 128 个字符。它不能包含字符 /。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionGetProductOperator(*, location, product_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

获取与 Product 关联的信息。

可能出现的错误

• 如果 Product 不存在，则返回 NOT_FOUND。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionGetProductOperator

参数

• location (str) – （必需）Product 所在的区域。截至 2019-02-05，有效的区域为：us-east1、us-west1、europe-west1、asia-east1

• product_id (str) – （必需）此 Product 的资源 ID。

• project_id (str) – （可选）Product 所在的项目。如果设置为 None 或缺失，则使用来自 Google Cloud 连接的默认 project_id。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionUpdateProductOperator(*, product, location=None, product_id=None, project_id=PROVIDE_PROJECT_ID, update_mask=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

更改 Product 资源。

目前只能更新 display_name、description 和 labels 字段。

如果更新了标签，更改将在下一次索引时间才会反映在查询中。

注意

要定位 Product 资源，需要其 name，格式为 projects/PROJECT_ID/locations/LOC_ID/products/PRODUCT_ID。

您可以直接将 name 作为 product 对象的属性提供。但是，您可以将其留空，并提供 location 和 product_id （以及可选的 project_id - 如果不存在，将使用连接默认值），name 将由操作符本身创建。

此机制是为了方便您，允许将 project_id 留空，并让 Airflow 使用连接默认的 project_id。

与提供的 Product 相关的可能错误

• 如果 Product 不存在，则返回 NOT_FOUND。

• 如果 update_mask 中存在 display_name，但请求中缺少 display_name，则返回 INVALID_ARGUMENT。

  或者超过 4096 个字符。

• 如果 update_mask 中存在 description，但超过 4096 个字符，则返回 INVALID_ARGUMENT。

  个字符。

• 如果 update_mask 中存在 product_category，则返回 INVALID_ARGUMENT。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionUpdateProductOperator

参数

• product (dict | google.cloud.vision_v1.Product) – (必需) 要替换服务器上的 Product 资源。product.name 是不可变的。如果提供 dict，则其格式必须与 protobuf 消息 Product 相同。

• location (str | None) – (可选) Product 所在的区域。有效的区域（截至 2019-02-05）为：us-east1、us-west1、europe-west1、asia-east1

• product_id (str | None) – (可选) 此 Product 的资源 ID。

• project_id (str) – （可选）Product 所在的项目。如果设置为 None 或缺失，则使用来自 Google Cloud 连接的默认 project_id。

• update_mask (dict | google.protobuf.field_mask_pb2.FieldMask | None) – (可选) 指定要更新的字段的 FieldMask。如果未指定 update_mask，则将更新所有可变字段。有效的掩码路径包括 product_labels、display_name 和 description。如果提供 dict，则其格式必须与 protobuf 消息 FieldMask 相同。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionDeleteProductOperator(*, location, product_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

永久删除产品及其参考图像。

产品及其所有图像的元数据将立即删除，但针对包含该产品的 ProductSets 的搜索查询在所有相关缓存刷新之前可能仍然有效。

可能出现的错误

• 如果产品不存在，则返回 NOT_FOUND。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionDeleteProductOperator

参数

• location (str) – （必需）Product 所在的区域。截至 2019-02-05，有效的区域为：us-east1、us-west1、europe-west1、asia-east1

• product_id (str) – （必需）此 Product 的资源 ID。

• project_id (str) – （可选）Product 所在的项目。如果设置为 None 或缺失，则使用来自 Google Cloud 连接的默认 project_id。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionImageAnnotateOperator(*, request, retry=DEFAULT, timeout=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

对单个图像或一批图像运行图像检测和注释。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionImageAnnotateOperator

参数

• request (dict | google.cloud.vision_v1.AnnotateImageRequest) – (必需) 图像或批次的注释请求。如果提供 dict，则其格式必须与 protobuf 消息类相同：google.cloud.vision_v1.types.AnnotateImageRequest

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('request', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionCreateReferenceImageOperator(*, location, reference_image, product_id, reference_image_id=None, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

创建并返回新的 ReferenceImage ID 资源。

参见

有关如何使用此操作符的更多信息，请查看以下指南：CloudVisionCreateReferenceImageOperator

参数

• location (str) – （必需）Product 所在的区域。截至 2019-02-05，有效的区域为：us-east1、us-west1、europe-west1、asia-east1

• reference_image (dict | google.cloud.vision_v1.ReferenceImage) – (必填) 要创建的参考图像。如果指定了图像 ID，则会被忽略。如果提供了字典，则它必须与 protobuf 消息 google.cloud.vision_v1.types.ReferenceImage 具有相同的形式。

• reference_image_id (str | None) – (可选) 用户提供的要添加的 ReferenceImage 的资源 ID。如果设置，服务器将尝试使用此值作为资源 ID。如果它已被使用，则会返回错误代码 ALREADY_EXISTS。长度必须最多为 128 个字符。它不能包含字符 /。

• product_id (str) – (可选) 此产品的资源 ID。

• project_id (str) – （可选）Product 所在的项目。如果设置为 None 或缺失，则使用来自 Google Cloud 连接的默认 project_id。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'reference_image', 'product_id', 'reference_image_id', 'project_id', 'gcp_conn_id',...

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionDeleteReferenceImageOperator(*, location, product_id, reference_image_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

删除 ReferenceImage ID 资源。

参见

有关如何使用此操作符的更多信息，请查看以下指南：CloudVisionDeleteReferenceImageOperator

参数

• location (str) – （必需）Product 所在的区域。截至 2019-02-05，有效的区域为：us-east1、us-west1、europe-west1、asia-east1

• reference_image_id (str) – (可选) 用户提供的要添加的 ReferenceImage 的资源 ID。如果设置，服务器将尝试使用此值作为资源 ID。如果它已被使用，则会返回错误代码 ALREADY_EXISTS。长度必须最多为 128 个字符。它不能包含字符 /。

• product_id (str) – (可选) 此产品的资源 ID。

• project_id (str) – （可选）Product 所在的项目。如果设置为 None 或缺失，则使用来自 Google Cloud 连接的默认 project_id。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'product_id', 'reference_image_id', 'project_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionAddProductToProductSetOperator(*, product_set_id, product_id, location, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

将 Product 添加到指定的 ProductSet。

如果产品已存在，则不会进行任何更改。一个产品最多可以添加到 100 个 ProductSets。

可能出现的错误

• 如果产品或 ProductSet 不存在，则返回 NOT_FOUND。

参见

有关如何使用此操作符的更多信息，请查看以下指南：CloudVisionAddProductToProductSetOperator

参数

• product_set_id (str) – (必填) 要修改的 ProductSet 的资源 ID。

• product_id (str) – （必需）此 Product 的资源 ID。

• location (str) – (必填) ProductSet 所在的区域。有效的区域（截至 2019-02-05）为：us-east1、us-west1、europe-west1、asia-east1

• project_id (str) – （可选）Product 所在的项目。如果设置为 None 或缺失，则使用来自 Google Cloud 连接的默认 project_id。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'product_set_id', 'product_id', 'project_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionRemoveProductFromProductSetOperator(*, product_set_id, product_id, location, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

从指定的 ProductSet 中删除 Product。

参见

有关如何使用此操作符的更多信息，请查看以下指南： CloudVisionRemoveProductFromProductSetOperator

参数

• product_set_id (str) – (必填) 要修改的 ProductSet 的资源 ID。

• product_id (str) – （必需）此 Product 的资源 ID。

• location (str) – (必填) ProductSet 所在的区域。有效的区域（截至 2019-02-05）为：us-east1、us-west1、europe-west1、asia-east1

• project_id (str) – （可选）Product 所在的项目。如果设置为 None 或缺失，则使用来自 Google Cloud 连接的默认 project_id。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – （可选）等待请求完成的时间（以秒为单位）。请注意，如果指定了重试，则超时适用于每个单独的尝试。

• metadata (MetaData) – （可选）提供给方法的其他元数据。

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('location', 'product_set_id', 'product_id', 'project_id', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionDetectTextOperator(image, max_results=None, retry=DEFAULT, timeout=None, language_hints=None, web_detection_params=None, additional_properties=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

检测图像中的文本。

参见

有关如何使用此操作符的更多信息，请查看以下指南： CloudVisionDetectTextOperator

参数

• image (dict | google.cloud.vision_v1.Image) – (必需) 要分析的图像。 更多信息请参考： https://googleapis.github.io/google-cloud-python/latest/vision/gapic/v1/types.html#google.cloud.vision_v1.types.Image

• max_results (int | None) – (可选) 要返回的结果数。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – 超时前的秒数。

• language_hints (str | list[str] | None) – 用于 TEXT_DETECTION 的语言列表。在大多数情况下，空值会产生最佳结果，因为它启用了自动语言检测。对于基于拉丁字母的语言，无需设置 language_hints。

• web_detection_params (dict | None) – 用于 Web 检测的参数。

• additional_properties (dict | None) – 要在 AnnotateImageRequest 上设置的其他属性。 更多信息请参考： google.cloud.vision_v1.types.AnnotateImageRequest

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('image', 'max_results', 'timeout', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionTextDetectOperator(image, max_results=None, retry=DEFAULT, timeout=None, language_hints=None, web_detection_params=None, additional_properties=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

检测图像中的文档文本。

参见

有关如何使用此操作符的更多信息，请查看以下指南： CloudVisionTextDetectOperator

参数

• image (dict | google.cloud.vision_v1.Image) – (必需) 要分析的图像。 更多信息请参考： https://googleapis.github.io/google-cloud-python/latest/vision/gapic/v1/types.html#google.cloud.vision_v1.types.Image

• max_results (int | None) – 要返回的结果数。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – 超时前的秒数。

• language_hints (str | list[str] | None) – 用于 TEXT_DETECTION 的语言列表。在大多数情况下，空值会产生最佳结果，因为它启用了自动语言检测。对于基于拉丁字母的语言，无需设置 language_hints。

• web_detection_params (dict | None) – 用于 Web 检测的参数。

• additional_properties (dict | None) – 要在 AnnotateImageRequest 上设置的其他属性。 更多信息请参考： https://googleapis.github.io/google-cloud-python/latest/vision/gapic/v1/types.html#google.cloud.vision_v1.types.AnnotateImageRequest

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('image', 'max_results', 'timeout', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionDetectImageLabelsOperator(image, max_results=None, retry=DEFAULT, timeout=None, additional_properties=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

检测图像中的文档文本。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionDetectImageLabelsOperator

参数

• image (dict | google.cloud.vision_v1.Image) – (必需) 要分析的图像。 更多信息请参考： https://googleapis.github.io/google-cloud-python/latest/vision/gapic/v1/types.html#google.cloud.vision_v1.types.Image

• max_results (int | None) – 要返回的结果数。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – 超时前的秒数。

• additional_properties (dict | None) – 要在 AnnotateImageRequest 上设置的其他属性。 更多信息请参考： https://googleapis.github.io/google-cloud-python/latest/vision/gapic/v1/types.html#google.cloud.vision_v1.types.AnnotateImageRequest

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('image', 'max_results', 'timeout', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

class airflow.providers.google.cloud.operators.vision.CloudVisionDetectImageSafeSearchOperator(image, max_results=None, retry=DEFAULT, timeout=None, additional_properties=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)

基类: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

检测图像中的文档文本。

参见

有关如何使用此操作符的更多信息，请查看指南：CloudVisionDetectImageSafeSearchOperator

参数

• image (dict | google.cloud.vision_v1.Image) – (必需) 要分析的图像。 更多信息请参考： https://googleapis.github.io/google-cloud-python/latest/vision/gapic/v1/types.html#google.cloud.vision_v1.types.Image

• max_results (int | None) – 要返回的结果数。

• retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – （可选）用于重试请求的重试对象。如果指定 None，则不会重试请求。

• timeout (float | None) – 超时前的秒数。

• additional_properties (dict | None) – 要在 AnnotateImageRequest 上设置的其他属性。 更多信息请参考： https://googleapis.github.io/google-cloud-python/latest/vision/gapic/v1/types.html#google.cloud.vision_v1.types.AnnotateImageRequest

• gcp_conn_id (str) – （可选）用于连接到 Google Cloud 的连接 ID。

• impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链式帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。

template_fields: collections.abc.Sequence[str] = ('image', 'max_results', 'timeout', 'gcp_conn_id', 'impersonation_chain')

execute(context)

在创建操作符时派生。

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

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

airflow.providers.google.cloud.operators.vision.prepare_additional_parameters(additional_properties, language_hints, web_detection_params)

为 additional_properties 参数创建一个值。

新值基于用户指定的 language_hints、web_detection_params 和 additional_properties 参数。

上一页 下一页

此条目是否对您有所帮助？