使用Node.js Azure函数时间触发器更新SQL Server表遇部署问题

核心问题分析与修复步骤 #

1. 环境变量未在Azure配置 #

本地运行依赖.env文件，但部署到Azure后，函数应用不会读取该文件。需要在Azure函数应用的配置 > 应用程序设置中手动添加以下环境变量：

• SQL_SERVER：SQL Server实例地址
• SQL_USERNAME：数据库登录用户名
• SQL_PASSWORD：数据库登录密码

2. SQL Server防火墙限制 #

Azure SQL Server默认拒绝外部IP访问，需确保：

• 将函数应用的出站IP地址添加到SQL Server防火墙允许列表（在Azure门户的SQL Server > 网络设置中配置）
• 勾选允许Azure服务和资源访问此服务器选项（简化配置，适合测试场景）

3. 代码中的隐性错误 #

你的代码存在两处问题：

• 未导入TYPES对象，但调用了request.addParameter('sevenDaysAgo', TYPES.DateTime, sevenDaysAgo)，部署后会抛出未定义错误
• SQL语句中未使用@sevenDaysAgo参数，而是直接用DATEADD(DAY, -7, GETDATE())，添加的参数完全多余

修复后的完整代码：

const { app } = require('@azure/functions');
const { Connection, Request, TYPES } = require('tedious'); // 新增TYPES导入

app.timer('newtriggerexpre', {
    schedule: '0 */2 * * * *', // 每2分钟触发一次，可按需调整
    handler: (myTimer, context) => {
        const config = {
            "server": process.env.SQL_SERVER,
            "authentication": {
                "type": "default",
                "options": {
                    "userName": process.env.SQL_USERNAME,
                    "password": process.env.SQL_PASSWORD
                }
            },
            "options": {
                "port": 1433,
                "database": "Tutoringacademy",
                "trustServerCertificate": true,
                "connectTimeout": 15000 // 增加连接超时，避免部署环境网络延迟
            }
        }

        const connection = new Connection(config);

        connection.on('connect', function (err) {
            if (err) {
                context.log.error('数据库连接失败:', err);
                connection.close(); // 错误时关闭连接
                return;
            }

            try {
                // 使用SQL Server内置函数计算日期，避免前端时区差异
                const request = new Request(`
                    UPDATE TutorAds
                    SET Status = 'expired', Published_At = NULL
                    WHERE Published_At < DATEADD(DAY, -7, GETDATE())
                `, function (err, rowCount) {
                    if (err) {
                        context.log.error('更新语句执行失败:', err);
                    } else {
                        context.log(`${rowCount} 条记录已更新`);
                    }
                    connection.close(); // 执行完成后关闭连接
                });

                connection.execSql(request);
            } catch (err) {
                context.log.error('执行流程出错:', err);
                connection.close();
            }
        });

        // 监听连接错误事件
        connection.on('error', function(err) {
            context.log.error('连接异常:', err);
            connection.close();
        });
    }
});

1天后自动更新记录的实现示例 #

如果需要将Published_At早于1天前的记录标记为过期，只需修改SQL语句中的日期计算，并调整定时器触发频率：

代码修改点 #

1. SQL语句调整：将DATEADD(DAY, -7, GETDATE())改为DATEADD(DAY, -1, GETDATE())
2. 定时器调度：改为每天触发一次（例如每天凌晨0点），schedule设置为0 0 0 * * *

完整示例代码：

const { app } = require('@azure/functions');
const { Connection, Request, TYPES } = require('tedious');

app.timer('expireAdsDaily', {
    schedule: '0 0 0 * * *', // 每天凌晨0点触发
    handler: (myTimer, context) => {
        const config = {
            "server": process.env.SQL_SERVER,
            "authentication": {
                "type": "default",
                "options": {
                    "userName": process.env.SQL_USERNAME,
                    "password": process.env.SQL_PASSWORD
                }
            },
            "options": {
                "port": 1433,
                "database": "Tutoringacademy",
                "trustServerCertificate": true
            }
        }

        const connection = new Connection(config);

        connection.on('connect', function (err) {
            if (err) {
                context.log.error('数据库连接失败:', err);
                connection.close();
                return;
            }

            const request = new Request(`
                UPDATE TutorAds
                SET Status = 'expired', Published_At = NULL
                WHERE Published_At < DATEADD(DAY, -1, GETDATE())
            `, function (err, rowCount) {
                if (err) {
                    context.log.error('更新失败:', err);
                } else {
                    context.log(`每日过期任务完成，更新 ${rowCount} 条记录`);
                }
                connection.close();
            });

            connection.execSql(request);
        });

        connection.on('error', (err) => {
            context.log.error('连接错误:', err);
            connection.close();
        });
    }
});

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