如何实现Snowflake新用户入职自动邮件通知？无需外部工具可行吗？

完全可以无需外部工具，仅通过Snowflake内置的流（Stream）、任务（Task）和邮件功能实现自动化通知，以下是具体步骤：

前提配置 #

1. 确认Snowflake账户已开启邮件服务：检查账户参数EMAIL_SERVICE_ENABLED是否为TRUE，若未开启需联系Snowflake支持启用。
2. 创建邮件集成：先配置允许发送和接收邮件的地址，示例：

CREATE OR REPLACE EMAIL INTEGRATION NEW_USER_NOTIFY_EMAIL
ENABLED = TRUE
ALLOWED_RECIPIENTS = ('admin@company.com', 'hr@company.com') -- 替换为实际收件邮箱
ALLOWED_SENDERS = ('snowflake-notify@company.com'); -- 替换为已授权的发件邮箱

步骤1：创建流监控用户创建事件 #

通过流捕获SNOWFLAKE.ACCOUNT_USERS视图中的新用户插入记录：

CREATE OR REPLACE STREAM USER_CREATION_STREAM
ON VIEW SNOWFLAKE.ACCOUNT_USERS
APPEND_ONLY = TRUE
SHOW_INITIAL_ROWS = FALSE;

该流仅追踪新增用户，不会包含历史数据。

步骤2：编写邮件发送存储过程 #

创建存储过程读取流中的新用户数据，调用内置SYSTEM$SEND_EMAIL发送通知：

CREATE OR REPLACE PROCEDURE SEND_NEW_USER_NOTIFICATION()
RETURNS VARCHAR
LANGUAGE JAVASCRIPT
AS
$$
    var output = "";
    // 查询流中未处理的新用户
    var userStmt = snowflake.createStatement({
        sqlText: "SELECT USER_NAME, EMAIL, CREATED_ON FROM USER_CREATION_STREAM WHERE ACTION = 'INSERT'"
    });
    var userRs = userStmt.execute();

    while (userRs.next()) {
        var userName = userRs.getColumnValue(1);
        var userEmail = userRs.getColumnValue(2);
        var createdTime = userRs.getColumnValue(3);

        // 构造邮件内容
        var mailSubject = `新Snowflake用户入职通知：${userName}`;
        var mailBody = `
            <h3>新用户入职提醒</h3>
            <p><strong>用户名：</strong>${userName}</p>
            <p><strong>用户邮箱：</strong>${userEmail}</p>
            <p><strong>创建时间：</strong>${createdTime}</p>
        `;

        // 发送邮件
        var sendStmt = snowflake.createStatement({
            sqlText: `CALL SYSTEM$SEND_EMAIL('NEW_USER_NOTIFY_EMAIL', 'admin@company.com', ?, ?)`,
            binds: [mailSubject, mailBody]
        });
        sendStmt.execute();
        output += `已发送通知：${userName}\n`;
    }

    // 刷新流，标记已处理数据
    var refreshStmt = snowflake.createStatement({
        sqlText: "ALTER STREAM USER_CREATION_STREAM REFRESH"
    });
    refreshStmt.execute();

    return output;
$$;

注意：替换代码中的邮箱地址和邮件集成名称为实际值。

步骤3：创建定时任务触发存储过程 #

设置任务定期检查流中的新用户，示例为每分钟执行一次：

CREATE OR REPLACE TASK NEW_USER_NOTIFICATION_TASK
WAREHOUSE = YOUR_WH_NAME -- 替换为你的仓库名称
SCHEDULE = 'USING CRON * * * * * UTC'
AS
CALL SEND_NEW_USER_NOTIFICATION();

启动任务：

ALTER TASK NEW_USER_NOTIFICATION_TASK RESUME;

验证与调试 #

• 创建测试用户后，等待任务执行周期，检查收件邮箱是否收到通知。
• 查询任务执行历史：

SELECT * FROM TABLE(INFORMATION_SCHEMA.TASK_HISTORY(TASK_NAME => 'NEW_USER_NOTIFICATION_TASK')) ORDER BY SCHEDULED_TIME DESC;

注意事项 #

• 确保任务使用的仓库拥有访问SNOWFLAKE.ACCOUNT_USERS视图、执行存储过程及邮件集成的权限。
• 若需更实时通知，可调整CRON表达式（如每30秒执行一次：USING CRON */30 * * * * UTC）。
• SYSTEM$SEND_EMAIL支持HTML格式邮件，可根据需求自定义内容样式。

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