`airflow.providers.google.cloud.hooks.vision`¶

此模块包含一个 Google Cloud Vision Hook。

模块内容¶

类¶

`NameDeterminer`	用于确定实体名称的辅助类。
`CloudVisionHook`	用于 Google Cloud Vision API 的 Hook。

属性¶

`ERR_DIFF_NAMES`
`ERR_UNABLE_TO_CREATE`

airflow.providers.google.cloud.hooks.vision.ERR_DIFF_NAMES = 多行字符串[源代码]¶

显示值

"""The {label} name provided in the object ({explicit_name}) is different
    than the name created from the input parameters ({constructed_name}). Please either:
    1) Remove the {label} name,
    2) Remove the location and {id_label} parameters,
    3) Unify the {label} name and input parameters.
    """

airflow.providers.google.cloud.hooks.vision.ERR_UNABLE_TO_CREATE = 多行字符串[源代码]¶

显示值

"""Unable to determine the {label} name. Please either set the name directly
    in the {label} object or provide the `location` and `{id_label}` parameters.
    """

class airflow.providers.google.cloud.hooks.vision.NameDeterminer(label, id_label, get_path)[源代码]¶

用于确定实体名称的辅助类。

get_entity_with_name(entity, entity_id, location, project_id)[源代码]¶

检查实体是否设置了 name 属性。

如果设置了，则不执行任何操作。
如果未设置，并且可以从提供的其他参数构造名称，则会创建并填充到实体中。
实体。
如果实体“name”属性已设置并且名称可以从提供的其他参数构造：
* 如果它们相同 - 不执行任何操作 * 如果它们不同 - 则会引发异常。

参数

entity (Any) – 实体
entity_id (str | None) – 实体 ID
location (str | None) – 位置
project_id (str) – Google Cloud Vision 项目的 ID。

返回

相同的实体或具有新名称的实体

引发

AirflowException

返回类型

Any

class airflow.providers.google.cloud.hooks.vision.CloudVisionHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]¶

基类： airflow.providers.google.common.hooks.base_google.GoogleBaseHook

用于 Google Cloud Vision API 的 Hook。

必须使用关键字参数而不是位置参数来调用 hook 中使用 project_id 的所有方法。

product_name_determiner[源代码]¶

product_set_name_determiner[源代码]¶

get_conn()[源代码]¶

检索与 Cloud Vision 的连接。

返回: Google Cloud Vision 客户端对象。
返回类型: google.cloud.vision_v1.ProductSearchClient

annotator_client()[源代码]¶

创建 ImageAnnotatorClient。

返回: Google Image Annotator 客户端对象。
返回类型: google.cloud.vision_v1.ImageAnnotatorClient

create_product_set(location, product_set, project_id=PROVIDE_PROJECT_ID, product_set_id=None, retry=DEFAULT, timeout=None, metadata=())[源代码]¶

创建产品集。

有关文档，请参阅：CloudVisionCreateProductSetOperator。

get_product_set(location, product_set_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=())[源代码]¶

获取产品集。

有关文档，请参阅：CloudVisionGetProductSetOperator。

update_product_set(product_set, project_id=PROVIDE_PROJECT_ID, location=None, product_set_id=None, update_mask=None, retry=DEFAULT, timeout=None, metadata=())[source]¶

更新产品集。

有关文档，请参阅：CloudVisionUpdateProductSetOperator。

delete_product_set(location, product_set_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=())[source]¶

删除产品集。

有关文档，请参阅：CloudVisionDeleteProductSetOperator。

create_product(location, product, project_id=PROVIDE_PROJECT_ID, product_id=None, retry=DEFAULT, timeout=None, metadata=())[source]¶

创建产品。

有关文档，请参阅：CloudVisionCreateProductOperator。

get_product(location, product_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=())[source]¶

获取产品。

有关文档，请参阅：CloudVisionGetProductOperator。

update_product(product, project_id=PROVIDE_PROJECT_ID, location=None, product_id=None, update_mask=None, retry=DEFAULT, timeout=None, metadata=())[source]¶

更新产品。

有关文档，请参阅：CloudVisionUpdateProductOperator。

delete_product(location, product_id, project_id=PROVIDE_PROJECT_ID, retry=DEFAULT, timeout=None, metadata=())[source]¶

删除产品。

有关文档，请参阅：CloudVisionDeleteProductOperator。

create_reference_image(location, product_id, reference_image, project_id, reference_image_id=None, retry=DEFAULT, timeout=None, metadata=())[source]¶

创建参考图像。

有关文档，请参阅：CloudVisionCreateReferenceImageOperator。

delete_reference_image(location, product_id, reference_image_id, project_id, retry=DEFAULT, timeout=None, metadata=())[source]¶

删除参考图像。

有关文档，请参阅：CloudVisionDeleteReferenceImageOperator。

add_product_to_product_set(product_set_id, product_id, project_id, location, retry=DEFAULT, timeout=None, metadata=())[source]¶

将产品添加到产品集。

有关文档，请参阅：CloudVisionAddProductToProductSetOperator。

remove_product_from_product_set(product_set_id, product_id, project_id, location, retry=DEFAULT, timeout=None, metadata=())[source]¶