amazon.aws.lambda_event 模块 – 创建、更新或删除 AWS Lambda 函数事件映射

注意

此模块是 amazon.aws 集合(版本 9.0.0)的一部分。

如果您正在使用 ansible 包,您可能已经安装了此集合。 它不包含在 ansible-core 中。 要检查是否已安装,请运行 ansible-galaxy collection list

要安装它,请使用:ansible-galaxy collection install amazon.aws。 您需要进一步的要求才能使用此模块,请参阅 要求 了解详细信息。

要在 playbook 中使用它,请指定:amazon.aws.lambda_event

amazon.aws 5.0.0 中的新增功能

概要

  • 此模块允许通过 Ansible 框架管理 AWS Lambda 函数事件源映射,例如 DynamoDB 和 Kinesis 流事件。 这些事件源映射仅在 AWS Lambda 拉取模型中相关,其中 AWS Lambda 调用该函数。 它是幂等的并支持“检查”模式。 使用模块 amazon.aws.lambda 管理 lambda 函数本身,并使用 amazon.aws.lambda_alias 管理函数别名。

  • 此模块最初在 1.0.0 版本中添加到 community.aws

要求

执行此模块的主机上需要以下要求。

  • python >= 3.6

  • boto3 >= 1.28.0

  • botocore >= 1.31.0

参数

参数

注释

access_key

别名: aws_access_key_id, aws_access_key, ec2_access_key

字符串

AWS 访问密钥 ID。

有关访问令牌的更多信息,请参阅 AWS 文档 https://docs.aws.amazon.com/general/latest/gr/aws-sec-cred-types.html#access-keys-and-secret-access-keys

也可以使用 AWS_ACCESS_KEY_IDAWS_ACCESS_KEYEC2_ACCESS_KEY 环境变量,优先级递减。

aws_access_keyprofile 选项是互斥的。

aws_access_key_id 别名在 5.1.0 版本中添加,以与 AWS botocore SDK 保持一致。

ec2_access_key 别名已弃用,将在 2024-12-01 之后的版本中删除。

EC2_ACCESS_KEY 环境变量的支持已弃用,将在 2024-12-01 之后的版本中删除。

别名

字符串

函数别名的名称。

version 互斥。

aws_ca_bundle

路径

用于验证 SSL 证书的 CA 包的位置。

也可以使用 AWS_CA_BUNDLE 环境变量。

aws_config

字典

用于修改 botocore 配置的字典。

参数可以在 AWS 文档中找到 https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html#botocore.config.Config

debug_botocore_endpoint_logs

布尔值

使用 botocore.endpoint 记录器来解析任务期间发出的唯一(而不是总计) "resource:action" API 调用,将集合输出到任务结果中的 resource_actions 键。 使用 aws_resource_action 回调输出到 playbook 期间生成的总列表。

也可以使用 ANSIBLE_DEBUG_BOTOCORE_LOGS 环境变量。

选项

  • false ←(默认)

  • true

endpoint_url

别名: ec2_url, aws_endpoint_url, s3_url

字符串

连接的 URL,用于替代默认的 AWS 终端节点。虽然这可以用于连接到其他与 AWS 兼容的服务,但 amazon.aws 和 community.aws 集合仅针对 AWS 进行了测试。

也可以使用 AWS_URLEC2_URL 环境变量,优先级递减。

ec2_urls3_url 别名已被弃用,将在 2024-12-01 之后的版本中删除。

EC2_URL 环境变量的支持已被弃用,将在 2024-12-01 之后的版本中删除。

event_source

字符串

触发 Lambda 函数的事件的来源。

对于 DynamoDB 和 Kinesis 事件,请选择 stream

对于 SQS 队列,请选择 sqs

选项

  • "stream" ← (默认)

  • "sqs"

lambda_function_arn

别名: function_name, function_arn

string / 必填

Lambda 函数的名称或 ARN。

profile

别名: aws_profile

字符串

用于身份验证的已命名 AWS 配置文件。

有关命名配置文件的更多信息,请参阅 AWS 文档 https://docs.aws.amazon.com/cli/latest/userguide/cli-configure-profiles.html

也可以使用 AWS_PROFILE 环境变量。

profile 选项与 aws_access_keyaws_secret_keysecurity_token 选项互斥。

region

别名: aws_region, ec2_region

字符串

要使用的 AWS 区域。

对于 IAM、Route53 和 CloudFront 等全局服务,将忽略 region

也可以使用 AWS_REGIONEC2_REGION 环境变量。

有关更多信息,请参阅 Amazon AWS 文档 http://docs.aws.amazon.com/general/latest/gr/rande.html#ec2_region

ec2_region 别名已被弃用,将在 2024-12-01 之后的版本中删除。

EC2_REGION 环境变量的支持已被弃用,将在 2024-12-01 之后的版本中删除。

secret_key

别名: aws_secret_access_key, aws_secret_key, ec2_secret_key

字符串

AWS 秘密访问密钥。

有关访问令牌的更多信息,请参阅 AWS 文档 https://docs.aws.amazon.com/general/latest/gr/aws-sec-cred-types.html#access-keys-and-secret-access-keys

也可以使用 AWS_SECRET_ACCESS_KEYAWS_SECRET_KEYEC2_SECRET_KEY 环境变量,优先级递减。

secret_keyprofile 选项互斥。

aws_secret_access_key 别名在 5.1.0 版本中添加,以与 AWS botocore SDK 保持一致。

ec2_secret_key 别名已被弃用,将在 2024-12-01 之后的版本中删除。

EC2_SECRET_KEY 环境变量的支持已被弃用,将在 2024-12-01 之后的版本中删除。

session_token

别名: aws_session_token, security_token, aws_security_token, access_token

字符串

用于临时凭据的 AWS STS 会话令牌。

有关访问令牌的更多信息,请参阅 AWS 文档 https://docs.aws.amazon.com/general/latest/gr/aws-sec-cred-types.html#access-keys-and-secret-access-keys

也可以使用 AWS_SESSION_TOKENAWS_SECURITY_TOKENEC2_SECURITY_TOKEN 环境变量,优先级递减。

security_tokenprofile 选项互斥。

别名 aws_session_tokensession_token 在 3.2.0 版本中添加,参数在 6.0.0 版本中从 security_token 重命名为 session_token

security_tokenaws_security_tokenaccess_token 别名已被弃用,将在 2024-12-01 之后的版本中删除。

EC2_SECRET_KEYAWS_SECURITY_TOKEN 环境变量的支持已被弃用,将在 2024-12-01 之后的版本中删除。

source_params

dictionary / 必填

事件源所需的子参数。

batch_size

integer

AWS Lambda 在调用您的函数时将从您的事件源检索的最大记录数。

Amazon Kinesis - 默认值 100。最大值 10000

Amazon DynamoDB Streams - 默认值 100。最大值 10000

Amazon Simple Queue Service - 默认值 10。对于标准队列,最大值为 10000。对于 FIFO 队列,最大值为 10

Amazon Managed Streaming for Apache Kafka - 默认值 100。最大值 10000

自托管 Apache Kafka - 默认值 100。最大值 10000

Amazon MQ(ActiveMQ 和 RabbitMQ)- 默认值 100。最大值 10000

DocumentDB - 默认值 100。最大值 10000

enabled

布尔值

指示 AWS Lambda 是否应开始轮询或从事件源读取。

选项

  • false

  • true ← (默认)

function_response_types

list / elements=string

在 amazon.aws 5.5.0 中添加

(Streams 和 Amazon SQS)应用于事件源映射的当前响应类型枚举的列表。

选项

  • "ReportBatchItemFailures"

maximum_batching_window_in_seconds

integer

在 amazon.aws 8.0.0 中添加

Lambda 在调用函数之前花费的最大时间(以秒为单位)来收集记录。

您可以将 source_params.maximum_batching_window_in_seconds 配置为从 0 秒到 300 秒的任何值,以秒为增量。

对于流和 Amazon SQS 事件源,当 source_params.batch_size 设置为大于 10 的值时,source_params.maximum_batching_window_in_seconds 默认为 1

source_params.maximum_batching_window_in_seconds 不受 FIFO 队列的支持。

source_arn

string / 必填

作为事件源的 SQS 队列、Kinesis 流或 DynamoDB 流的 Amazon 资源名称 (ARN)。

starting_position

字符串

AWS Lambda 应开始读取的流中的位置。

event_source=stream 时,为必填项。

选项

  • "TRIM_HORIZON"

  • "LATEST"

state

字符串

描述所需的状态。

选项

  • "present" ← (默认)

  • "absent"

validate_certs

布尔值

当设置为 false 时,与 AWS API 通信时将不会验证 SSL 证书。

强烈建议不要设置 validate_certs=false,作为替代方案,请考虑设置 aws_ca_bundle

选项

  • false

  • true ← (默认)

version

integer

Lambda 函数的版本。

alias 互斥。

默认值: 0

说明

注意

  • 警告:对于模块,环境变量和配置文件是从 Ansible “host” 上下文读取的,而不是从“controller” 上下文读取的。因此,可能需要将文件显式复制到“host”。对于查找和连接插件,环境变量和配置文件是从 Ansible “controller” 上下文读取的,而不是从“host” 上下文读取的。

  • Ansible 使用的 AWS SDK (boto3) 也可能会从 Ansible “主机” 上下文(通常是 ~/.aws/credentials)的配置文件中读取凭证和其他设置(例如区域)的默认值。有关详细信息,请参阅 https://boto3.amazonaws.com/v1/documentation/api/latest/guide/credentials.html

示例

# Example that creates a lambda event notification for a DynamoDB stream
- name: DynamoDB stream event mapping
  amazon.aws.lambda_event:
    state: present
    event_source: stream
    function_name: "{{ function_name }}"
    alias: Dev
    source_params:
      source_arn: arn:aws:dynamodb:us-east-1:123456789012:table/tableName/stream/2016-03-19T19:51:37.457
      enabled: true
      batch_size: 100
      starting_position: TRIM_HORIZON
  register: event

# Example that creates a lambda event notification for a DynamoDB stream
- name: DynamoDB stream event mapping
  amazon.aws.lambda_event:
    state: present
    event_source: stream
    function_name: "{{ function_name }}"
    source_params:
      source_arn: arn:aws:dynamodb:us-east-1:123456789012:table/tableName/stream/2016-03-19T19:51:37.457
      enabled: true
      batch_size: 100
      starting_position: LATEST
      function_response_types:
        - ReportBatchItemFailures
  register: event

- name: Show source event
  ansible.builtin.debug:
    var: event.lambda_stream_events

返回值

常见的返回值记录在此处,以下是此模块独有的字段

描述

events

字典

API 返回的描述流事件映射的字典

返回: 成功

batch_size

integer

Lambda 拉取的每个批次中的最大记录数。

返回: 总是

bisect_batch_on_function_error

布尔值

如果函数返回错误,则将批次分成两部分并重试。

返回: 仅适用于 Kinesis 和 DynamoDB Streams

示例: false

destination_config

字典

指定 Lambda 处理事件后事件目标的配置对象。

返回: 仅适用于 Kinesis、DynamoDB Streams、Amazon MSK 和自管理 Kafka

on_failure

字典

失败调用的目标配置。

返回: 成功

destination

字符串

目标资源 ARN。

返回: 成功

on_success

字典

失败调用的目标配置。

返回: 成功

destination

字符串

目标资源 ARN。

返回: 成功

event_source_arn

字符串

事件源的 Amazon 资源名称 (ARN)。

返回: 总是

示例: "arn:aws:dynamodb:us-west-2:123456789012:table/yyyy/stream/2024-06-06T07:03:58.956"

function_arn

字符串

Lambda 函数的 ARN。

返回: 总是

示例: "arn:aws:lambda:us-west-2:123456789012:function:test-lambda-3a0a29d0dbb5:1"

function_response_types

list / elements=string

应用于事件源映射的当前响应类型枚举列表。

返回: 适用于 Kinesis、DynamoDB Streams 和 Amazon SQS

示例: ["ReportBatchItemFailures"]

last_modified

字符串

上次更新事件源映射或其状态更改的日期。

返回: 总是

示例: "2024-06-06T12:34:21.990000+05:30"

last_processing_result

字符串

您的函数的上次 Lambda 调用的结果。

返回: 总是

示例: "没有 处理记录"

maximum_batching_window_in_seconds

integer

Lambda 在调用函数之前花费的最大时间(以秒为单位)来收集记录。

返回: 总是

示例: 1

maximum_record_age_in_seconds

integer

放弃早于指定年龄的记录。默认值为无限 (-1)。

返回: 仅适用于 Kinesis 和 DynamoDB Streams

示例: -1

maximum_retry_attempts

integer

在指定次数的重试后放弃记录。

返回: 仅适用于 Kinesis 和 DynamoDB Streams

示例: -1

parallelization_factor

integer

从每个分片并发处理的批次数。

返回: 仅适用于 Kinesis 和 DynamoDB Streams

示例: 1

starting_position

字符串

从哪个位置开始读取流。

返回: 仅适用于 Kinesis 和 DynamoDB Streams

示例: "LATEST"

state

字符串

事件源映射的状态。

返回: 总是

示例: "正在删除"

state_transition_reason

字符串

指示用户或 Lambda 是否对事件源映射进行了上次更改。

返回: 总是

示例: "用户发起"

tumbling_window_in_seconds

integer

用于 DynamoDB 和 Kinesis Streams 事件源的处理窗口的持续时间(以秒为单位)。

返回: 仅适用于 Kinesis 和 DynamoDB Streams

示例: 1

uuid

字符串

事件源映射的标识符。

返回: 总是

示例: "a1b2c3d4-5678-90ab-cdef-11111EXAMPLE"

作者

  • Pierre Jodouin (@pjodouin)

  • Ryan Brown (@ryansb)