NodeJS连接Snowflake报错：必须指定连接选项

错误原因 #

你的代码里有两个关键问题触发了Error [MissingParameterError]: Connection options must be specified：

• 构造函数错误初始化连接对象：snowflake.createConnection是工厂函数，不需要用new关键字调用，且你调用时未传入任何配置参数，直接触发参数缺失错误。
• Promise未正确处理连接结果：init方法中的connect使用回调，但没在回调里调用resolve或reject，导致start方法的Promise链无法正常推进。
  另外，代码中this.configsf未定义，会引发额外错误，需确保Config实例已正确初始化。

解决方案 #

1. 移除构造函数中错误的连接初始化逻辑，将连接创建移到init方法中处理。
2. 正确调用createConnection：直接调用工厂函数并传入配置参数，不用加new。
3. 在connect回调中手动处理Promise状态：连接成功时调用resolve，失败时调用reject。
4. 在类的构造函数中初始化Config实例，避免this.configsf未定义的问题。

修正后的代码示例 #

import * as snowflake from 'snowflake-sdk';
import { Config } from "./config";

const config1 = {
    account:"xxx.eu-west-1",
    username:"xxxx",
    password:"xxxx",
    authenticator:"SNOWFLAKE",
    clientSessionKeepAlive:true,
    warehouse:"xxxxx",
    database:"xxxx",
    schema:"xxxx"
}

export class InjectSF {
    public connectionpoolsf: snowflake.Connection;
    private configsf: Config;

    constructor() {
        this.configsf = new Config();
    }

    public init = () => {
        return new Promise((resolve, reject) => {
            this.configsf.initConfig()
                .then(() => {
                    // 正确调用工厂函数创建连接
                    this.connectionpoolsf = snowflake.createConnection(config1);
                    this.connectionpoolsf.connect((err, conn) => {
                        if (err) {
                            console.error('Unable to connect: ' + err.message);
                            reject(err);
                        } else {
                            console.log('Successfully connected to Snowflake.');
                            resolve(conn);
                        }
                    });
                })
                .catch((err) => reject(err));
        });
    }

    // ... 其他函数保持不变 ...

    public start = () => {
        return new Promise((resolve, reject) => {
            this.init()
                .then(() => this.readDir())
                .then((filenames) => this.readFiles(filenames))
                .then((resultFile) => this.createTable(resultFile))
                .then(() => resolve())
                .catch((err) => reject(err));
        });
    };
}

try {
    const injectSF = new InjectSF();
    injectSF.start()
        .then(() => console.log('Insert Ok!'))
        .catch((err) => {
            console.error('Insert failed:', err);
            throw err;
        });
} catch (err) {
    console.error('Unexpected error:', err);
    throw err;
}

额外说明 #

• 若从AWS Secret Manager获取密码，需确保config1中的密码是加载完成的有效值，避免因密码为空或未加载导致的参数问题。
• 连接参数里的account格式正确，xxx.eu-west-1的格式符合Snowflake的要求。

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