airflow.providers.amazon.aws.sensors.lambda_function¶

类¶

LambdaFunctionStateSensor

轮询 AWS Lambda 函数的部署状态直到达到目标状态。

模块内容¶

class airflow.providers.amazon.aws.sensors.lambda_function.LambdaFunctionStateSensor(*, function_name, qualifier=None, target_states=None, **kwargs)[source]¶

Bases: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.lambda_function.LambdaHook]

轮询 AWS Lambda 函数的部署状态直到达到目标状态。

如果查询失败则失败。

另请参阅

有关如何使用此 sensor 的更多信息，请查看指南：等待 AWS Lambda 函数部署状态

参数：

function_name (str) – AWS Lambda 函数、版本或别名的名称。
qualifier (str | None) – 指定版本或别名以获取函数的已发布版本详情。
target_states (list | None) – 所需的 Lambda 状态。
aws_conn_id – 要使用的 AWS 连接，默认为 'aws_default'。如果此参数为 None 或为空，则使用默认的 boto3 行为。如果以分布式方式运行 Airflow 且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（并且必须在每个 worker 节点上维护）。

FAILURE_STATES = ('Failed',)[source]¶

aws_hook_class[source]¶

template_fields: collections.abc.Sequence[str][source]¶

function_name[source]¶

qualifier = None[source]¶

target_states = ['Active'][source]¶

poke(context)[source]¶

派生此类时重写此方法。