airflow.providers.amazon.aws.hooks.appflow

模块内容

类

AppflowHook

与 Amazon AppFlow 交互。
class airflow.providers.amazon.aws.hooks.appflow.AppflowHook(*args, **kwargs)[源代码]

基类： 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)[源代码]

执行 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)[源代码]

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

参数

  • flow_name (str) – 流名称

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

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

返回

无

返回类型

无

此条目是否对您有帮助？