airflow.contrib.hooks.gcp_video_intelligence_hook

Module Contents

class airflow.contrib.hooks.gcp_video_intelligence_hook.CloudVideoIntelligenceHook(gcp_conn_id='google_cloud_default', delegate_to=None)[source]

Bases: airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook

Hook for Google Cloud Video Intelligence APIs.

Parameters

  • gcp_conn_id (str) – The connection ID to use when fetching connection info.

  • delegate_to (str) – The account to impersonate, if any. For this to work, the service account making the request must have domain-wide delegation enabled.

_conn[source]
get_conn(self)[source]

Returns Gcp Video Intelligence Service client

Return type

google.cloud.videointelligence_v1.VideoIntelligenceServiceClient

annotate_video(self, input_uri=None, input_content=None, features=None, video_context=None, output_uri=None, location=None, retry=None, timeout=None, metadata=None)[source]

Performs video annotation.

Parameters

  • input_uri (str) – Input video location. Currently, only Google Cloud Storage URIs are supported, which must be specified in the following format: gs://bucket-id/object-id.

  • input_content (bytes) – The video data bytes. If unset, the input video(s) should be specified via input_uri. If set, input_uri should be unset.

  • features (list[google.cloud.videointelligence_v1.VideoIntelligenceServiceClient.enums.Feature]) – Requested video annotation features.

  • output_uri (str) – Optional, location where the output (in JSON format) should be stored. Currently, only Google Cloud Storage URIs are supported, which must be specified in the following format: gs://bucket-id/object-id.

  • video_context (dict or google.cloud.videointelligence_v1.types.VideoContext) – Optional, Additional video context and/or feature-specific parameters.

  • location (str) – Optional, cloud region where annotation should take place. Supported cloud regions: us-east1, us-west1, europe-west1, asia-east1. If no region is specified, a region will be determined based on video file location.

  • retry (google.api_core.retry.Retry) – Retry object used to determine when/if to retry requests. If None is specified, requests will not be retried.

  • timeout (float) – Optional, The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.

  • metadata (seq[tuple[str, str]]) – Optional, Additional metadata that is provided to the method.