airflow.providers.google.cloud.hooks.video_intelligence¶

此模块包含 Google Cloud Video Intelligence Hook。

类¶

CloudVideoIntelligenceHook

用于 Google Cloud Video Intelligence API 的 Hook。

模块内容¶

class airflow.providers.google.cloud.hooks.video_intelligence.CloudVideoIntelligenceHook(gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

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

用于 Google Cloud Video Intelligence API 的 Hook。

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

参数:

gcp_conn_id (str) – 用于获取连接信息的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务账号用于使用短期凭据进行模拟，或用于获取列表中最后一个账号的 access_token 的链式账号列表，最后一个账号将在请求中被模拟。如果设置为字符串，则该账号必须授予原始账号 Service Account Token Creator IAM 角色。如果设置为序列，则列表中的身份必须授予直接前置身份 Service Account Token Creator IAM 角色，列表中的第一个账号将此角色授予原始账号。

get_conn()[source]¶

返回 Gcp Video Intelligence Service 客户端。

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

执行视频标注。

参数:

input_uri (str | None) – 输入视频的位置。目前仅支持 Google Cloud Storage URI，格式如下：gs://bucket-id/object-id。
input_content (bytes | None) – 视频数据字节。如果未设置，则应通过 input_uri 指定输入视频。如果已设置，则不应设置 input_uri。
features (collections.abc.Sequence[google.cloud.videointelligence_v1.Feature] | None) – 请求的视频标注功能。
output_uri (str | None) – 可选，输出（JSON 格式）应存储的位置。目前仅支持 Google Cloud Storage URI，格式如下：gs://bucket-id/object-id。
video_context (dict | google.cloud.videointelligence_v1.VideoContext | None) – 可选，附加的视频上下文和/或功能特定参数。
location (str | None) – 可选，应进行标注的云区域。支持的云区域：us-east1, us-west1, europe-west1, asia-east1。如果未指定区域，将根据视频文件位置确定区域。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于确定何时/是否重试请求的 Retry 对象。如果指定为 None，则不会重试请求。
timeout (float | None) – 可选，等待请求完成的时间（秒）。请注意，如果指定了 retry，则超时适用于每次尝试。
metadata (collections.abc.Sequence[tuple[str, str]]) – 可选，提供给方法的附加元数据。