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

此條目有幫助嗎？