airflow.providers.amazon.aws.operators.lambda_function¶
模块内容¶
类¶
创建一个 AWS Lambda 函数。 |
|
调用一个 AWS Lambda 函数。 |
- class airflow.providers.amazon.aws.operators.lambda_function.LambdaCreateFunctionOperator(*, function_name, runtime=None, role, handler=None, code, description=None, timeout=None, config=None, wait_for_completion=False, waiter_max_attempts=60, waiter_delay=15, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[源代码]¶
基类：
airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.lambda_function.LambdaHook]创建一个 AWS Lambda 函数。
有关此操作符的参数的更多信息，请访问 https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/lambda.html#Lambda.Client.create_function
另请参阅
有关如何使用此操作符的更多信息，请查看以下指南：创建 AWS Lambda 函数
- 参数
function_name (str) – AWS Lambda 函数、版本或别名的名称。
runtime (str | None) – 函数运行时的标识符。如果部署包是 .zip 文件存档，则需要运行时。
role (str) – 函数执行角色的 Amazon 资源名称 (ARN)。
handler (str | None) – Lambda 调用以运行函数的代码中的方法名称。如果部署包是 .zip 文件存档，则需要处理程序。
code (dict) – 函数的代码。
description (str | None) – 函数的描述。
timeout (int | None) – Lambda 允许函数在停止运行之前运行的时间量（以秒为单位）。
config (dict | None) – 用于 boto API create_lambda 调用的任意参数的可选字典。
wait_for_completion (bool) – 如果为 True，则操作符将等待直到该函数处于活动状态。
waiter_max_attempts (int) – 轮询创建的最大尝试次数。
waiter_delay (int) – 轮询创建状态之间的时间间隔（以秒为单位）。
deferrable (bool) – 如果为 True，则操作符将异步等待创建完成。这意味着等待创建完成。此模式需要安装 aiobotocore 模块。（默认为 False，但可以在配置文件中将 default_deferrable 设置为 True 来覆盖）
aws_conn_id – 要使用的 AWS 连接 ID
- template_fields: collections.abc.Sequence[str][源代码]¶
- class airflow.providers.amazon.aws.operators.lambda_function.LambdaInvokeFunctionOperator(*, function_name, log_type=None, keep_empty_log_lines=True, qualifier=None, invocation_type=None, client_context=None, payload=None, **kwargs)[源代码]¶
基类：
airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.lambda_function.LambdaHook]调用一个 AWS Lambda 函数。
您可以同步（并等待响应）或异步调用函数。要异步调用函数，请将 invocation_type 设置为 Event。有关更多详细信息，请查看 boto3 Lambda 调用文档。
另请参阅
有关如何使用此运算符的更多信息，请查看本指南：调用 AWS Lambda 函数
- 参数
function_name (str) – AWS Lambda 函数、版本或别名的名称。
log_type (str | None) – 设置为 Tail 以在响应和任务日志中包含执行日志。否则，设置为“None”。仅适用于同步调用的函数，并返回执行日志的最后 4 KB。
keep_empty_log_lines (bool) – 是否保留执行日志中的空行。
qualifier (str | None) – 指定版本或别名以调用函数的已发布版本。
invocation_type (str | None) – AWS Lambda 调用类型 (RequestResponse、Event、DryRun)
client_context (str | None) – 关于调用客户端的数据，以便在上下文对象中传递给函数
aws_conn_id – 要使用的 AWS 连接 ID
- template_fields: collections.abc.Sequence[str][源代码]¶