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

此條目有幫助嗎?