airflow.providers.amazon.aws.operators.quicksight

QuickSightCreateIngestionOperator

创建并启动数据集新的 SPICE 摄取任务;也用于刷新现有的 SPICE 数据集。

模块内容

class airflow.providers.amazon.aws.operators.quicksight.QuickSightCreateIngestionOperator(data_set_id, ingestion_id, ingestion_type='FULL_REFRESH', wait_for_completion=True, check_interval=30, **kwargs)[source]

Bases: airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.quicksight.QuickSightHook]

创建并启动数据集新的 SPICE 摄取任务;也用于刷新现有的 SPICE 数据集。

另请参阅

有关如何使用此操作器的更多信息,请参阅指南: Amazon QuickSight 创建摄取任务

参数:
  • data_set_id (str) – 摄取任务中使用的数据集的 ID。

  • ingestion_id (str) – 摄取任务的 ID。

  • ingestion_type (str) – 摄取任务类型。可选值包括 INCREMENTAL_REFRESH 或 FULL_REFRESH。默认为 FULL_REFRESH。

  • wait_for_completion (bool) – 如果 wait 设置为 True,表示操作等待检查 Amazon QuickSight 摄取状态的时间间隔(以秒为单位)。

  • check_interval (int) – 如果 wait 设置为 true,则这是操作器检查 Amazon QuickSight 摄取状态的时间间隔(以秒为单位)

  • aws_conn_id – 用于 AWS 凭据的 Airflow 连接 ID。如果此项为 None 或为空,则使用默认的 boto3 行为。如果在分布式环境中运行 Airflow 且 aws_conn_id 为 None 或为空,则将使用默认的 boto3 配置(且必须在每个工作节点上维护)。

  • region_name – AWS 区域名称。如果未指定,则使用默认的 boto3 行为。

  • verify – 是否验证 SSL 证书。参见: https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html

  • botocore_config – botocore 客户端的配置字典(键值对)。参见: https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

aws_hook_class[source]
template_fields: collections.abc.Sequence[str][source]
ui_color = '#ffd700'[source]
data_set_id[source]
ingestion_id[source]
ingestion_type = 'FULL_REFRESH'[source]
wait_for_completion = True[source]
check_interval = 30[source]
execute(context)[source]

在创建操作器时派生。

Context 是与渲染 jinja 模板时使用的字典相同。

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

此条目有帮助吗?