airflow.providers.amazon.aws.hooks.appflow

类

AppflowHook

与 Amazon AppFlow 交互。

模块内容

class airflow.providers.amazon.aws.hooks.appflow.AppflowHook(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsGenericHook[mypy_boto3_appflow.client.AppflowClient]

与 Amazon AppFlow 交互。

提供 `boto3.client("appflow")` 的轻量级封装。

可以指定额外的参数（例如 `aws_conn_id`），并将其传递给底层的 AwsBaseHook。

另请参阅

run_flow(flow_name, poll_interval=20, wait_for_completion=True, max_attempts=60)[source]

执行 AppFlow 运行。

参数：

  • flow_name (str) – 流的名称

  • poll_interval (int) – 两次连续调用之间等待的时间（秒），用于检查运行状态

  • wait_for_completion (bool) – 是否等待运行结束再返回

  • max_attempts (int) – 超时/返回失败之前的轮询次数。

返回：

运行执行 ID

返回类型：

str

update_flow_filter(flow_name, filter_tasks, set_trigger_ondemand=False)[source]

更新流任务过滤器；如果传递空数组给 `filter_tasks`，则移除所有过滤器。

参数：

  • flow_name (str) – 流的名称

  • filter_tasks – 要添加的流任务列表

  • set_trigger_ondemand (bool) – 如果为 True，则将触发器设置为按需触发；否则，保持触发器不变

返回：

None

返回类型：

None

此条目有帮助吗？