airflow.providers.amazon.aws.utils.waiter_with_logging¶

函数¶

`wait`(waiter, waiter_delay, waiter_max_attempts, args, ...)	使用 boto waiter 轮询 AWS 服务的指定状态。
`async_wait`(waiter, waiter_delay, waiter_max_attempts, ...)	使用异步 boto waiter 轮询 AWS 服务的指定状态。

模块内容¶

airflow.providers.amazon.aws.utils.waiter_with_logging.wait(waiter, waiter_delay, waiter_max_attempts, args, failure_message, status_message, status_args)[source]¶

使用 boto waiter 轮询 AWS 服务的指定状态。

尽管此函数使用 boto waiter 轮询服务的状态，但它会在每次尝试后记录服务的响应，这目前不是 boto waiter 原生支持的。

参数:

waiter (botocore.waiter.Waiter) – 要使用的 boto waiter。
waiter_delay (int) – 每次尝试之间等待的时间间隔（秒）。
waiter_max_attempts (int) – 最大尝试次数。
args (dict[str, Any]) – 要传递给 waiter 的参数。
failure_message (str) – 如果达到失败状态时要记录的消息。
status_message (str) – 打印服务状态时记录的消息。
status_args (list[str]) –
一个包含 JMESPath 查询的列表，用于从 waiter 响应中检索状态信息。例如：response = {“Cluster”: {“state”: “CREATING”}} status_args = [“Cluster.state”]

response = { “Clusters”: [{“state”: “CREATING”, “details”: “User initiated.”},] } status_args = [“Clusters[0].state”, “Clusters[0].details”]

async airflow.providers.amazon.aws.utils.waiter_with_logging.async_wait(waiter, waiter_delay, waiter_max_attempts, args, failure_message, status_message, status_args)[source]¶

使用异步 boto waiter 轮询 AWS 服务的指定状态。

尽管此函数使用 boto waiter 轮询服务的状态，但它会在每次尝试后记录服务的响应，这目前不是 boto waiter 原生支持的。

参数:

waiter (botocore.waiter.Waiter) – 要使用的 boto waiter。
waiter_delay (int) – 每次尝试之间等待的时间间隔（秒）。
waiter_max_attempts (int) – 最大尝试次数。
args (dict[str, Any]) – 要传递给 waiter 的参数。
failure_message (str) – 如果达到失败状态时要记录的消息。
status_message (str) – 打印服务状态时记录的消息。
status_args (list[str]) –
一个包含 JMESPath 查询的列表，用于从 waiter 响应中检索状态信息。例如：response = {“Cluster”: {“state”: “CREATING”}} status_args = [“Cluster.state”]

response = { “Clusters”: [{“state”: “CREATING”, “details”: “User initiated.”},] } status_args = [“Clusters[0].state”, “Clusters[0].details”]