在 lambda 函数中使用 EventBridge 事件模式字符串

Question

我有一个使用 Python 的 lambda 函数。它连接到 EventBridge 规则，该规则在每次 Glue table.

发生变化时触发。

它输出的事件模式看起来像这样：

{
    "version":"0",
    "detail":{
        "databaseName":"flights-db",
        "typeOfChange":"UpdateTable",
        "tableName":"flightscsv"
    }
}

我想将此输出中的 tableName 和 databaseName 值作为变量传入函数。

我的 Lambda 函数：

import json
import boto3

def lambda_handler(event, context):
    boto3_version = boto3.__version__

    return_statement = 'Boto3 version: ', boto3_version,\
                       'Event output: ', event

    return {
        'statusCode': 200,
        'body': json.dumps(return_statement)
    }

我期望在我的 return 语句中从 event 获得事件模式输出，但事实并非如此。

测试此函数时，event 的 return 输出为：

{\"key1\": \"value1\", \"key2\": \"value2\", \"key3\": \"value3\"}

这个键和值在函数的测试模式中是这样定义的。

eventbridge规则定义如下：

如何从事件模式获取值到变量？我是否需要配置测试模式才能将结果输入 event？

编辑： table 更改事件的日志事件图片：

Answer 1

列出了 CloudWatch (CW) 事件/事件桥 (EB) 生成的 event 对象 here。当 EB 触发时，这些事件将传递给您的函数。

您的 EB 事件模式应该是：

{
  "source": ["aws.glue"],
  "detail-type": ["Glue Data Catalog Table State Change"]
}

以上内容应该与您的粘合目录中的任何表格的更改相匹配。 event 应该类似于下面的：

{
    "version": "0",
    "id": "2617428d-715f-edef-70b8-d210da0317a0",
    "detail-type": "Glue Data Catalog Table State Change",
    "source": "aws.glue",
    "account": "123456789012",
    "time": "2019-01-16T18:16:01Z",
    "region": "eu-west-1",
    "resources": [
        "arn:aws:glue:eu-west-1:123456789012:table/d1/t1"
    ],
    "detail": {
        "databaseName": "d1",
        "changedPartitions": [
            "[C.pdf, dir3]",
            "[D.doc, dir4]"
        ],
        "typeOfChange": "BatchCreatePartition",
        "tableName": "t1"
    }
}

因此，要获得 tableName 和 databaseName，您的 lambda 函数可以是：

import json
import boto3

def lambda_handler(event, context):
    boto3_version = boto3.__version__

    print(event)

    table_name = event['detail']['tableName']
    database_name = event['detail']['databaseName']

    print(table_name, database_name)

    return_statement = {
        'boto3_version': boto3_version,
        'table_name': table_name,
        'database_name': database_name
    }

    return {
        'statusCode': 200,
        'body': json.dumps(return_statement)
    }

为了测试，您可以在 lambda 测试中设置示例 EB 事件 window:

在 lambda 函数中使用 EventBridge 事件模式字符串

Using an EventBridge event pattern string in a lambda function

amazon-web-services

aws-glue

aws-event-bridge