airflow.providers.google.cloud.transfers.calendar_to_gcs

模块内容

GoogleCalendarToGCSOperator

将 Google 日历数据写入 Google Cloud Storage。

class airflow.providers.google.cloud.transfers.calendar_to_gcs.GoogleCalendarToGCSOperator(*, destination_bucket, api_version, calendar_id='primary', i_cal_uid=None, max_attendees=None, max_results=None, order_by=None, private_extended_property=None, text_search_query=None, shared_extended_property=None, show_deleted=None, show_hidden_invitation=None, single_events=None, sync_token=None, time_max=None, time_min=None, time_zone=None, updated_min=None, destination_path=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]

基类: airflow.models.BaseOperator

将 Google 日历数据写入 Google Cloud Storage。

另请参阅

有关如何使用此操作符的更多信息,请查看指南:从 Google 日历上传数据到 GCS

参数
  • calendar_id (str) – 要与之交互的 Google 日历 ID。

  • i_cal_uid (str | None) – 可选。指定响应中 iCalendar 格式的事件 ID。

  • max_attendees (int | None) – 可选。如果参与者数量超过指定数量,则仅返回参与者。

  • max_results (int | None) – 可选。在一个结果页面上返回的最大事件数。可以通过响应中非空的 nextPageToken 字段来检测不完整的页面。默认值为 250 个事件。页面大小永远不能超过 2500 个事件。

  • order_by (str | None) – 可选。可接受的值为 "startTime" 或 “updated”。

  • private_extended_property (str | None) – 可选。扩展属性约束指定为 propertyName=value。仅匹配私有属性。此参数可以重复多次,以返回与所有给定约束匹配的事件。

  • text_search_query (str | None) – 可选。自由文本搜索。

  • shared_extended_property (str | None) – 可选。扩展属性约束指定为 propertyName=value。仅匹配共享属性。此参数可以重复多次,以返回与所有给定约束匹配的事件。

  • show_deleted (bool | None) – 可选。默认为 False。

  • show_hidden_invitation (bool | None) – 可选。默认为 False。

  • single_events (bool | None) – 可选。默认为 False。

  • sync_token (str | None) – 可选。从返回的 nextSyncToken 字段获取的令牌。

  • time_max (datetime.datetime | None) – 可选。用于筛选事件开始时间的上限(不含)。默认情况下不进行筛选。

  • time_min (datetime.datetime | None) – 可选。用于筛选事件结束时间的下限(不含)。默认情况下不进行筛选。

  • time_zone (str | None) – 可选。响应中使用的时区。默认为日历的时区。

  • updated_min (datetime.datetime | None) – 可选。事件上次修改时间的下限。

  • destination_bucket (str) – 报告应写入的目标 Google Cloud Storage 存储桶。(已模板化)

  • destination_path (str | None) – 操作符创建的对象的 Google Cloud Storage URI 数组。例如:path/to/my/files

  • gcp_conn_id (str) – 获取连接信息时要使用的连接 ID。

  • impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭据模拟的服务帐户,或获取列表中最后一个帐户的 access_token 所需的链式帐户列表,该帐户将在请求中被模拟。如果设置为字符串,则该帐户必须授予原始帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列,则列表中的身份必须将“服务帐户令牌创建者”IAM 角色授予紧接在其之前的身份,列表中的第一个帐户将此角色授予原始帐户(已模板化)。

template_fields = ['calendar_id', 'destination_bucket', 'destination_path', 'impersonation_chain'][source]
execute(context)[source]

在创建操作符时派生。

上下文是与渲染 Jinja 模板时使用的相同的字典。

有关更多上下文,请参阅 get_template_context。

此条目是否有帮助?