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)[源代码]

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

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

如果查询失败,则失败。

另请参阅

有关如何使用此传感器的更多信息,请查看指南: 等待 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 配置(并且必须在每个工作节点上维护)。

FAILURE_STATES = ('Failed',)[源代码]
aws_hook_class[源代码]
template_fields: collections.abc.Sequence[str][源代码]
poke(context)[源代码]

在派生此类时覆盖。

此条目是否有帮助?