airflow.providers.google.marketing_platform.hooks.display_video¶

此模块包含 Google DisplayVideo hook。

类¶

GoogleDisplayVideo360Hook

用于 Google Display & Video 360 的 Hook。

模块内容¶

class airflow.providers.google.marketing_platform.hooks.display_video.GoogleDisplayVideo360Hook(api_version='v2', gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.providers.google.common.hooks.base_google.GoogleBaseHook

用于 Google Display & Video 360 的 Hook。

api_version = 'v2'[source]¶

get_conn()[source]¶

检索与 DisplayVideo 的连接。

get_conn_to_display_video()[source]¶

检索与 DisplayVideo 的连接。

static erf_uri(partner_id, entity_type)[source]¶

返回 bucket 中所有实体读取文件 (Entity Read Files) 的 URI。

例如，如果要为合作伙伴 123 生成一个文件名以检索 2013 年 4 月 2 日的 `line_item` 表的实体读取文件，您的文件名将类似于： `gdbm-123/entity/20130402.0.LineItem.json`

:param partner_id: 您的合作伙伴的数字 ID。 :param entity_type: 文件类型：合作伙伴, 广告主, 订单, 行项目, 素材, 像素, 广告资源来源, 用户名单, UniversalChannel, 和摘要。

create_query(query)[source]¶

创建一个查询。

参数:: query (dict[str, Any]) – 要传递到请求正文中的查询对象。

delete_query(query_id)[source]¶

删除存储的查询以及相关的存储报告。

参数:: query_id (str) – 要删除的查询 ID。

get_query(query_id)[source]¶

检索存储的查询。

参数:: query_id (str) – 要检索的查询 ID。

list_queries()[source]¶

检索存储的查询。

run_query(query_id, params)[source]¶

运行存储的查询以生成报告。

参数:

query_id (str) – 要运行的查询 ID。
params (dict[str, Any] | None) – 报告参数。

get_report(query_id, report_id)[source]¶

检索报告。

参数:

query_id (str) – 生成报告所用的查询 ID。
report_id (str) – 要检索的报告 ID。

upload_line_items(line_items)[source]¶

以 CSV 格式上传行项目 (line items)。

参数:: line_items (Any) – 从 GCS 下载并传递到请求正文的数据。
返回:: 响应正文。
返回类型:: list[dict[str, Any]]

download_line_items(request_body)[source]¶

以 CSV 格式检索行项目 (line items)。

参数:: request_body (dict[str, Any]) – 包含应传入的参数的字典。更多信息可在此处找到：https://developers.google.com/bid-manager/v1.1/lineitems/downloadlineitems

create_sdf_download_operation(body_request)[source]¶

创建一个 SDF 下载任务并返回一个操作 (Operation)。

参数:: body_request (dict[str, Any]) – 请求正文。

有关请求正文的更多信息可在此处找到：https://developers.google.com/display-video/api/reference/rest/v1/sdfdownloadtasks/create

get_sdf_download_operation(operation_name)[source]¶

获取异步 SDF 下载任务操作 (operation) 的最新状态。

参数:: operation_name (str) – 操作资源的名称。

download_media(resource_name)[source]¶

下载媒体。

参数:: resource_name (str) – 正在下载的媒体的资源名称。