单Python Lambda能否响应两个EventBridge事件完成Redshift用户增删？

完全可以在同一段Lambda代码中处理两种操作，不需要拆分创建、删除两个独立Lambda函数，只需要将你已经配置的两条EventBridge规则都绑定到同一个Lambda函数即可，修改少量代码即可实现预期逻辑。

你当前写的判断逻辑event['EventType']不生效，原因是EventBridge触发Lambda时传入的事件结构里不存在EventType字段，操作类型需要从事件的detail.operation字段获取，同时你当前的代码把用户名、密码写死，不符合动态处理的要求。

核心逻辑调整 #

• 从事件的detail.operation字段判断是创建还是删除操作
• 从事件的detail.name字段提取目标用户名（截取/Users/后的部分）
• 创建用户时需要主动调用SSM接口获取对应参数的值作为Redshift用户密码
• 补充必要的异常处理避免执行报错导致Lambda异常退出

示例修正代码 #

import boto3

# 初始化客户端，放在函数外复用
ssm_client = boto3.client('ssm')
redshift_data_client = boto3.client('redshift-data')

# 配置参数，建议存到Lambda环境变量不要硬编码
CLUSTER_ID = '你的集群ID'
DB_NAME = '你的数据库名'
DB_ADMIN_USER = '你的数据库管理员用户名'

def create_redshift_user(username, password):
    sql = f"CREATE USER {username} PASSWORD '{password}';"
    response = redshift_data_client.execute_statement(
        ClusterIdentifier=CLUSTER_ID,
        Database=DB_NAME,
        DbUser=DB_ADMIN_USER,
        Sql=sql
    )
    return response

def delete_redshift_user(username):
    sql = f"DROP USER IF EXISTS {username};"
    response = redshift_data_client.execute_statement(
        ClusterIdentifier=CLUSTER_ID,
        Database=DB_NAME,
        DbUser=DB_ADMIN_USER,
        Sql=sql
    )
    return response

def lambda_handler(event, context):
    # 提取事件信息
    param_name = event['detail']['name']
    operation = event['detail']['operation']
    # 提取用户名：格式/Users/xxx 取最后一段
    username = param_name.split('/')[-1]
    
    try:
        if operation == 'Create':
            # 创建操作需要获取SSM参数值作为密码
            param_resp = ssm_client.get_parameter(
                Name=param_name,
                WithDecryption=True # 如果参数是加密的需要加这个参数
            )
            password = param_resp['Parameter']['Value']
            resp = create_redshift_user(username, password)
            print(f"用户{username}创建成功, 执行ID: {resp['Id']}")
        elif operation == 'Delete':
            resp = delete_redshift_user(username)
            print(f"用户{username}删除成功, 执行ID: {resp['Id']}")
    except Exception as e:
        print(f"处理{operation}操作失败，用户名{username}, 错误信息: {str(e)}")
        # 如果需要触发Lambda重试可以保留抛出异常，不需要可以注释
        raise e

• Lambda执行角色需要添加对应的权限：ssm:GetParameter（对应你/Users/*前缀的参数）、redshift-data:ExecuteStatement、redshift:GetStatementResult（可选，如果你需要获取执行结果）
• 如果你存储密码的SSM参数用KMS加密，还需要给Lambda角色加对应KMS密钥的kms:Decrypt权限
• 建议把Redshift集群ID、数据库名这类配置放到Lambda环境变量中，不要硬编码在代码里，方便后续修改
• 如果有SQL注入风险的顾虑，可以对提取的username做格式校验，比如只允许字母、数字、下划线组合，避免非法字符注入

内容的提问来源于stack exchange，提问作者kain666