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]¶

派生此類時重寫此方法。