RDS PostgreSQL表或Schema变更时如何实现Slack通道自动通知

核心逻辑说明 #

• 首先纠正思路误区：information_schema.columns是系统只读视图，无法直接创建触发器。PostgreSQL提供了专属的事件触发器，专门用于捕获CREATE/ALTER/DROP这类DDL操作，比监控系统表的方案更稳定可靠，可完美覆盖新增Schema/表、修改表名、增删改列等场景。

前置准备 #

• 首先用RDS超级用户（默认是rds_superuser角色）在数据库中安装pg_http扩展，该扩展是RDS官方支持的扩展，用于发送HTTP请求调用Slack的Webhook接口，执行命令：CREATE EXTENSION IF NOT EXISTS pg_http;
• 提前在Slack目标通道创建传入Webhook，获取对应的Webhook调用地址。

步骤1：创建DDL事件回调函数 #

该函数会在指定DDL操作执行完成后触发，构造通知内容并发送到Slack：

CREATE OR REPLACE FUNCTION notify_ddl_change_to_slack()
RETURNS event_trigger AS $$
DECLARE
    ddl_event RECORD;
    slack_payload TEXT;
    response_status INT;
BEGIN
    -- 提取DDL事件的详细信息
    SELECT * INTO ddl_event FROM pg_event_trigger_ddl_commands();
    
    -- 构造Slack消息体，可按需调整内容格式
    slack_payload := format(
        '{"text": "【PostgreSQL元数据变更通知】\n操作类型：%s\n操作对象标识：%s\n执行用户：%s\n执行时间：%s"}',
        ddl_event.command_tag,
        ddl_event.object_identity,
        current_user,
        now()::TEXT
    );

    -- 调用Slack Webhook发送消息，替换下方占位符为你自己的Slack Webhook地址
    SELECT status INTO response_status 
    FROM http_post(
        '<你的Slack Webhook地址>',
        slack_payload,
        'application/json'
    );

    -- 可选配置：请求失败时打印日志，不会影响正常DDL操作执行
    IF response_status != 200 THEN
        RAISE LOG 'Slack通知发送失败，HTTP状态码：%', response_status;
    END IF;
END;
$$ LANGUAGE plpgsql SECURITY DEFINER;

步骤2：创建事件触发器捕获目标DDL操作 #

以下配置仅捕获你需要的元数据变更事件，可按需增减TAG类型：

CREATE EVENT TRIGGER track_schema_table_change
ON ddl_command_end
WHEN TAG IN (
    'CREATE SCHEMA', 'ALTER SCHEMA', 'DROP SCHEMA',
    'CREATE TABLE', 'ALTER TABLE', 'DROP TABLE',
    'ALTER TABLE RENAME', 'ALTER TABLE ADD COLUMN',
    'ALTER TABLE ALTER COLUMN', 'ALTER TABLE DROP COLUMN',
    'ALTER TABLE RENAME COLUMN'
)
EXECUTE FUNCTION notify_ddl_change_to_slack();

RDS实例额外配置 #

• 你需要在RDS对应的参数组中，将pg_http.allowed_hosts参数加上Slack Webhook的域名，否则pg_http会默认拦截对外请求
• 若你的RDS部署在私有子网，需要确保RDS的安全组放通到Slack Webhook地址的443端口出站规则

可选优化 #

• 可以在消息体中增加实例ID、环境标识等字段，方便区分不同实例的变更通知
• 可以在回调函数中增加过滤逻辑，屏蔽测试环境或者指定Schema的变更通知，减少冗余消息
• 可以将Slack Webhook地址存在单独的配置表中，避免硬编码在函数里，方便后续维护

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