`airflow.providers.amazon.aws.triggers.lambda_function`¶

模块内容¶

类¶

LambdaCreateFunctionCompleteTrigger

轮询 Lambda 函数创建完成的触发器。

class airflow.providers.amazon.aws.triggers.lambda_function.LambdaCreateFunctionCompleteTrigger(*, function_name, function_arn, waiter_delay=60, waiter_max_attempts=30, aws_conn_id=None, **kwargs)[源代码]¶

基类: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

轮询 Lambda 函数创建完成的触发器。

参数

function_name (str) – 函数名称
function_arn (str) – 函数 ARN
waiter_delay (int) – 尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭证的 Airflow 连接。

hook()[源代码]¶

在子类中重写以返回正确的 hook。

airflow.providers.amazon.aws.triggers.lambda_function¶

模块内容¶

类¶

`airflow.providers.amazon.aws.triggers.lambda_function`¶