airflow.providers.amazon.aws.utils.waiter_with_logging

模块内容

函数

wait(waiter, waiter_delay, waiter_max_attempts, args, ...)

使用 boto 等待器轮询 AWS 服务以获取指定状态。

async_wait(waiter, waiter_delay, waiter_max_attempts, ...)

使用异步 boto 等待器轮询 AWS 服务以获取指定状态。
airflow.providers.amazon.aws.utils.waiter_with_logging.wait(waiter, waiter_delay, waiter_max_attempts, args, failure_message, status_message, status_args)[源码]

使用 boto 等待器轮询 AWS 服务以获取指定状态。

尽管此函数使用 boto 等待器轮询服务状态，但它会在每次尝试后记录服务的响应，而 boto 等待器目前不支持此功能。

参数

  • waiter (botocore.waiter.Waiter) – 要使用的 boto 等待器。

  • waiter_delay (int) – 两次尝试之间等待的时间（秒）。

  • waiter_max_attempts (int) – 最大尝试次数。

  • args (dict[str, Any]) – 传递给等待器的参数。

  • failure_message (str) – 如果达到失败状态，要记录的消息。

  • status_message (str) – 打印服务状态时记录的消息。

  • status_args (list[str]) –

    包含 JMESPath 查询的列表，用于从等待器响应中检索状态信息。 例如，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)[源码]

使用异步 boto 等待器轮询 AWS 服务以获取指定状态。

尽管此函数使用 boto 等待器轮询服务状态，但它会在每次尝试后记录服务的响应，而 boto 等待器目前不支持此功能。

参数

  • waiter (botocore.waiter.Waiter) – 要使用的 boto 等待器。

  • waiter_delay (int) – 两次尝试之间等待的时间（秒）。

  • waiter_max_attempts (int) – 最大尝试次数。

  • args (dict[str, Any]) – 传递给等待器的参数。

  • failure_message (str) – 如果达到失败状态，要记录的消息。

  • status_message (str) – 打印服务状态时记录的消息。

  • status_args (list[str]) –

    包含 JMESPath 查询的列表，用于从等待器响应中检索状态信息。 例如，response = {“Cluster”: {“state”: “CREATING”}} status_args = [“Cluster.state”]

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

此条目是否有帮助？