airflow.providers.google.cloud.operators.vision

此模組包含一個 Google Cloud Vision 運算子。

屬性

MetaData

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 引數建立一個值。

模組內容

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。如果提供的是字典,則其格式必須與 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) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_set_id', 'gcp_conn_id', 'impersonation_chain')[原始碼]
location[原始碼]
project_id = None[原始碼]
product_set[原始碼]
product_set_id = None[原始碼]
retry[原始碼]
timeout = None[原始碼]
metadata = ()[原始碼]
gcp_conn_id = 'google_cloud_default'[原始碼]
impersonation_chain = None[原始碼]
execute(context)[原始碼]

建立運算子時派生。

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 所在的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_set_id', 'gcp_conn_id', 'impersonation_chain')[原始碼]
location[原始碼]
project_id = None[原始碼]
product_set_id[原始碼]
retry[原始碼]
timeout = None[原始碼]
metadata = ()[原始碼]
gcp_conn_id = 'google_cloud_default'[原始碼]
impersonation_chain = None[原始碼]
execute(context)[原始碼]

建立運算子時派生。

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 將由運算子根據 locationproduct_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) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_set_id', 'gcp_conn_id', 'impersonation_chain')[原始碼]
product_set[原始碼]
update_mask = None[原始碼]
location = None[原始碼]
project_id = None[原始碼]
product_set_id = None[原始碼]
retry[原始碼]
timeout = None[原始碼]
metadata = ()[原始碼]
gcp_conn_id = 'google_cloud_default'[原始碼]
impersonation_chain = None[原始碼]
execute(context)[原始碼]

建立運算子時派生。

context 與渲染 jinja 模板時使用的字典相同。

有關更多上下文,請參閱 get_template_context。

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)[source]

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

永久刪除一個 ProductSet

產品參考影像產品集 中不會被刪除。實際的影像檔案不會從 Google Cloud Storage 中刪除。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: 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) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_set_id', 'gcp_conn_id', 'impersonation_chain')[source]
location[source]
project_id = None[source]
product_set_id[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

context 與渲染 jinja 模板時使用的字典相同。

有關更多上下文,請參閱 get_template_context。

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)[source]

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

建立並返回一個新的 Product 資源。

關於提供的 產品 物件的可能錯誤

  • 如果 display_name 缺失或長度超過 4096 個字元,則返回 INVALID_ARGUMENT

  • 如果 description 長度超過 4096 個字元,則返回 INVALID_ARGUMENT

  • 如果 product_category 缺失或無效,則返回 INVALID_ARGUMENT

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: CloudVisionCreateProductOperator

引數
  • location (str) – (必需) 應建立產品的區域。有效區域(截至 2019-02-05)包括:us-east1, us-west1, europe-west1, asia-east1

  • product (str) – (必需) 要建立的產品。如果提供的是字典,其形式必須與 protobuf 訊息 產品 的形式相同。

  • project_id (str) – (可選) 應建立產品的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id。

  • product_id (str | None) – (可選) 使用者為此產品提供的資源 ID。如果設定,伺服器將嘗試使用此值作為資源 ID。如果該 ID 已被使用,將返回程式碼為 ALREADY_EXISTS 的錯誤。長度必須最多為 128 個字元,且不能包含字元 /。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_id', 'gcp_conn_id', 'impersonation_chain')[source]
location[source]
product[source]
project_id = None[source]
product_id = None[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

context 與渲染 jinja 模板時使用的字典相同。

有關更多上下文,請參閱 get_template_context。

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)[source]

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

獲取與 Product 相關的資訊。

可能的錯誤

  • 如果 產品 不存在,則返回 NOT_FOUND

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: CloudVisionGetProductOperator

引數
  • location (str) – (必需) 產品所在的區域。有效區域(截至 2019-02-05)包括:us-east1, us-west1, europe-west1, asia-east1

  • product_id (str) – (必需) 此產品的資源 ID。

  • project_id (str) – (可選) 產品所在的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_id', 'gcp_conn_id', 'impersonation_chain')[source]
location[source]
product_id[source]
project_id = None[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

context 與渲染 jinja 模板時使用的字典相同。

有關更多上下文,請參閱 get_template_context。

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)[source]

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

更改 Product 資源。

目前只能更新 display_name、description 和 labels 欄位。

如果更新 labels,更改直到下一次索引時才會反映在查詢中。

注意

要找到 產品 資源,需要其 name,格式為 projects/PROJECT_ID/locations/LOC_ID/products/PRODUCT_ID

你可以直接將 name 作為 product 物件的屬性提供。但是,你也可以將其留空,改為提供 locationproduct_id(以及可選的 project_id - 如果未提供,則使用連線預設值),name 將由 Operator 本身建立。

這種機制是為了方便你,允許你將 project_id 留空,並讓 Airflow 使用連線的預設 project_id

與提供的 產品 相關的可能錯誤

  • 如果產品不存在,則返回 NOT_FOUND

  • 如果 display_name 存在於 update_mask 中但請求中缺失

    或長度超過 4096 個字元,則返回 INVALID_ARGUMENT

  • 如果 description 存在於 update_mask 中但長度超過 4096 個

    字元,則返回 INVALID_ARGUMENT

  • 如果 product_category 存在於 update_mask 中,則返回 INVALID_ARGUMENT

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: CloudVisionUpdateProductOperator

引數
  • product (dict | google.cloud.vision_v1.Product) – (必需) 將替換伺服器上產品資源的 Product 資源。product.name 是不可變的。如果提供字典,其形式必須與 protobuf 訊息 產品 的形式相同。

  • location (str | None) – (可選) 產品所在的區域。有效區域(截至 2019-02-05)包括:us-east1, us-west1, europe-west1, asia-east1

  • product_id (str | None) – (可選) 此產品的資源 ID。

  • project_id (str) – (可選) 產品所在的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id。

  • update_mask (dict | google.protobuf.field_mask_pb2.FieldMask | None) – (可選) 指定要更新哪些欄位的 FieldMask。如果未指定 update_mask,則更新所有可變欄位。有效的掩碼路徑包括 product_labels、display_name 和 description。如果提供字典,其形式必須與 protobuf 訊息 FieldMask 的形式相同。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_id', 'gcp_conn_id', 'impersonation_chain')[source]
product[source]
location = None[source]
product_id = None[source]
project_id = None[source]
update_mask = None[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

context 與渲染 jinja 模板時使用的字典相同。

有關更多上下文,請參閱 get_template_context。

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)[source]

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

永久刪除一個產品及其參考影像。

產品及其所有影像的元資料將立即刪除,但針對包含該產品的產品集的搜尋查詢可能仍然有效,直到所有相關快取重新整理為止。

可能的錯誤

  • 如果產品不存在,則返回 NOT_FOUND

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: CloudVisionDeleteProductOperator

引數
  • location (str) – (必需) 產品所在的區域。有效區域(截至 2019-02-05)包括:us-east1, us-west1, europe-west1, asia-east1

  • product_id (str) – (必需) 此產品的資源 ID。

  • project_id (str) – (可選) 產品所在的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'project_id', 'product_id', 'gcp_conn_id', 'impersonation_chain')[source]
location[source]
product_id[source]
project_id = None[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

對一張或一批影像執行影像檢測和標註。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: 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) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('request', 'gcp_conn_id', 'impersonation_chain')[source]
request[source]
retry[source]
timeout = None[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

建立並返回一個新的 ReferenceImage ID 資源。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: CloudVisionCreateReferenceImageOperator

引數
  • location (str) – (必需) 產品所在的區域。有效區域(截至 2019-02-05)包括:us-east1, us-west1, europe-west1, asia-east1

  • reference_image (dict | google.cloud.vision_v1.ReferenceImage) – (必需)要建立的參考圖片。 如果指定了圖片 ID,則會被忽略。 如果提供 dict,則其形式必須與以下 protobuf 訊息 google.cloud.vision_v1.types.ReferenceImage 相同

  • reference_image_id (str | None) – (可選)要新增的 ReferenceImage 的使用者提供的資源 ID。 如果設定此項,伺服器將嘗試使用此值作為資源 ID。 如果此 ID 已在使用,則返回帶有 ALREADY_EXISTS 錯誤程式碼的錯誤。 長度必須不超過 128 個字元。 不能包含字元 /

  • product_id (str) – (可選)此 Product 的資源 ID。

  • project_id (str) – (可選) 產品所在的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'reference_image', 'product_id', 'reference_image_id', 'project_id', 'gcp_conn_id',...[source]
location[source]
product_id[source]
reference_image[source]
reference_image_id = None[source]
project_id = None[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

刪除一個 ReferenceImage ID 資源。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: CloudVisionDeleteReferenceImageOperator

引數
  • location (str) – (必需) 產品所在的區域。有效區域(截至 2019-02-05)包括:us-east1, us-west1, europe-west1, asia-east1

  • reference_image_id (str) – (可選)要新增的 ReferenceImage 的使用者提供的資源 ID。 如果設定此項,伺服器將嘗試使用此值作為資源 ID。 如果此 ID 已在使用,則返回帶有 ALREADY_EXISTS 錯誤程式碼的錯誤。 長度必須不超過 128 個字元。 不能包含字元 /

  • product_id (str) – (可選)此 Product 的資源 ID。

  • project_id (str) – (可選) 產品所在的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'product_id', 'reference_image_id', 'project_id', 'gcp_conn_id', 'impersonation_chain')[source]
location[source]
product_id[source]
reference_image_id[source]
project_id = None[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

將一個 Product 新增到指定的 ProductSet。

如果 Product 已存在,則不會進行任何更改。一個 Product 最多可新增到 100 個 ProductSet。

可能的錯誤

  • 如果 Product 或 ProductSet 不存在,則返回 NOT_FOUND

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: CloudVisionAddProductToProductSetOperator

引數
  • product_set_id (str) – (必需)要修改的 ProductSet 的資源 ID。

  • product_id (str) – (必需) 此產品的資源 ID。

  • location (str) – (必需) ProductSet 所在的區域。有效區域(截至 2019-02-05)包括:us-east1, us-west1, europe-west1, asia-east1

  • project_id (str) – (可選) 產品所在的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'product_set_id', 'product_id', 'project_id', 'gcp_conn_id', 'impersonation_chain')[source]
product_set_id[source]
product_id[source]
location[source]
project_id = None[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

從指定的 ProductSet 中移除一個 Product。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南:CloudVisionRemoveProductFromProductSetOperator

引數
  • product_set_id (str) – (必需)要修改的 ProductSet 的資源 ID。

  • product_id (str) – (必需) 此產品的資源 ID。

  • location (str) – (必需) ProductSet 所在的區域。有效區域(截至 2019-02-05)包括:us-east1, us-west1, europe-west1, asia-east1

  • project_id (str) – (可選) 產品所在的專案。如果設定為 None 或缺失,則使用 Google Cloud 連線中的預設 project_id。

  • retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – (可選) 用於重試請求的重試物件。如果指定為 None,則不重試請求。

  • timeout (float | None) – (可選) 等待請求完成的時間(秒)。請注意,如果指定了 retry,則超時適用於每次單獨的嘗試。

  • metadata (MetaData) – (可選) 提供給方法的附加元資料。

  • gcp_conn_id (str) – (可選) 用於連線 Google Cloud 的連線 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可選的服務賬號,用於使用短期憑據進行模擬,或所需的賬號鏈,以獲取列表中最後一個賬號的 access_token,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('location', 'product_set_id', 'product_id', 'project_id', 'gcp_conn_id', 'impersonation_chain')[source]
product_set_id[source]
product_id[source]
location[source]
project_id = None[source]
retry[source]
timeout = None[source]
metadata = ()[source]
gcp_conn_id = 'google_cloud_default'[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

檢測影像中的文字。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南: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) – 網頁檢測引數。

  • 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,該 token 將用於請求模擬。如果設定為字串,則該賬號必須授予源賬號 Service Account Token Creator IAM 角色。如果設定為序列,則列表中的身份必須授予直接前置身份 Service Account Token Creator IAM 角色,列表中的第一個賬號將此角色授予源賬號(模板化)。

template_fields: collections.abc.Sequence[str] = ('image', 'max_results', 'timeout', 'gcp_conn_id', 'impersonation_chain')[source]
image[source]
max_results = None[source]
retry[source]
timeout = None[source]
gcp_conn_id = 'google_cloud_default'[source]
kwargs[source]
additional_properties = None[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

檢測影像中的文件文字。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南:CloudVisionTextDetectOperator

引數
template_fields: collections.abc.Sequence[str] = ('image', 'max_results', 'timeout', 'gcp_conn_id', 'impersonation_chain')[source]
image[source]
max_results = None[source]
retry[source]
timeout = None[source]
gcp_conn_id = 'google_cloud_default'[source]
additional_properties = None[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

檢測影像中的文件文字。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南:CloudVisionDetectImageLabelsOperator

引數
template_fields: collections.abc.Sequence[str] = ('image', 'max_results', 'timeout', 'gcp_conn_id', 'impersonation_chain')[source]
image[source]
max_results = None[source]
retry[source]
timeout = None[source]
gcp_conn_id = 'google_cloud_default'[source]
additional_properties = None[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

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)[source]

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

檢測影像中的文件文字。

另請參見

有關如何使用此 Operator 的更多資訊,請參閱指南:CloudVisionDetectImageSafeSearchOperator

引數
template_fields: collections.abc.Sequence[str] = ('image', 'max_results', 'timeout', 'gcp_conn_id', 'impersonation_chain')[source]
image[source]
max_results = None[source]
retry[source]
timeout = None[source]
gcp_conn_id = 'google_cloud_default'[source]
additional_properties = None[source]
impersonation_chain = None[source]
execute(context)[source]

建立運算子時派生。

context 與渲染 jinja 模板時使用的字典相同。

有關更多上下文,請參閱 get_template_context。

airflow.providers.google.cloud.operators.vision.prepare_additional_parameters(additional_properties, language_hints, web_detection_params)[原始碼]

additional_properties 引數建立一個值。

新值基於使用者指定的 language_hintsweb_detection_paramsadditional_properties 引數。

此條目有幫助嗎?