Node.js应用：如何在Pulumi Preview/Up阶段调用本地函数？

我们直接讲几种实用的调用方式，以及分析你关心的index.ts直接调用的优劣：

1. 直接在index.ts顶层调用（不推荐） #

你可以直接在index.ts里用立即执行异步函数调用检查逻辑，比如：

import dbCheck from "./your-db-check-module";

(async () => {
  try {
    const pass = await dbCheck();
    if (!pass) throw new Error("数据库检查不通过");
    console.log("数据库检查OK");
  } catch (err) {
    console.error("数据库检查失败:", err.message);
    process.exit(1);
  }
})();

// 你的Pulumi资源定义
// const myApp = new ...

但这种方式问题不少：

• pulumi preview和pulumi up都会触发检查，preview阶段资源还没创建/更新，大概率会报错
• 检查逻辑和Pulumi资源生命周期完全脱节，万一资源还没就绪就跑检查，结果毫无意义
• 错误处理太粗暴，直接终止流程，没有和Pulumi的日志体系联动

2. 绑定Pulumi资源生命周期调用（推荐） #

如果你的数据库检查依赖已部署的资源（比如刚创建的数据库实例），用Pulumi的动态资源或invoke机制更靠谱：

方式一：自定义动态资源 #

把检查逻辑封装成一个Pulumi动态资源，让它依赖目标数据库，确保数据库部署完成后再执行检查：

import * as pulumi from "@pulumi/pulumi";
import * as dynamic from "@pulumi/pulumi/dynamic";
import dbCheck from "./your-db-check-module";

class DbCheckProvider implements dynamic.ResourceProvider {
  async create(inputs: { dbConnStr: string }) {
    const pass = await dbCheck(inputs.dbConnStr);
    if (!pass) throw new Error("数据库健康检查失败");
    return { id: `db-check-${Date.now()}`, outs: { passed: true } };
  }
}

class DbHealthCheck extends dynamic.Resource {
  constructor(name: string, args: { dbConnStr: pulumi.Input<string> }, opts?: pulumi.ResourceOptions) {
    super(new DbCheckProvider(), name, args, opts);
  }
}

// 使用示例：等数据库部署完再跑检查
const myDb = new YourDbResource("prod-db", { ... });
new DbHealthCheck("prod-db-check", { dbConnStr: myDb.connectionString }, { dependsOn: [myDb] });

这种方式的好处：

• 只有pulumi up会实际执行检查，preview阶段只会显示计划，不会真跑检查
• 严格依赖数据库资源，确保资源就绪后再验证
• 检查结果会纳入Pulumi的部署状态，失败会直接标记部署失败

方式二：用pulumi.invoke封装 #

如果检查不需要作为资源存在，只是一个验证步骤，可以用invoke调用：

import * as pulumi from "@pulumi/pulumi";
import dbCheck from "./your-db-check-module";

// 把检查逻辑包装成可invoke的函数
pulumi.runtime.registerFunction("my:utils:checkDb", async (args: { connStr: string }) => {
  return { passed: await dbCheck(args.connStr) };
});

// 在资源部署后触发检查
const myDb = new YourDbResource("prod-db", { ... });
myDb.connectionString.apply(async (connStr) => {
  const result = await pulumi.invoke("my:utils:checkDb", { connStr });
  if (!result.passed) throw new Error("数据库检查失败");
});

这种方式更轻量，适合简单的验证场景，同样能和资源输出值联动。

3. 用Automation API编排流程（CI/CD场景首选） #

如果你的团队用Automation API做部署编排，可以把检查逻辑放在部署流程的最前面，完全控制执行时机：

import * as automation from "@pulumi/pulumi/automation";
import dbCheck from "./your-db-check-module";

async function deploy() {
  // 先跑数据库检查
  const pass = await dbCheck();
  if (!pass) {
    console.error("数据库检查不通过，终止部署");
    process.exit(1);
  }

  // 再执行Pulumi部署
  const stack = await automation.LocalWorkspace.createOrSelectStack({
    stackName: "prod",
    projectRoot: "./your-project",
  });

  await stack.setConfig("db:connStr", { value: "your-db-string" });
  const upResult = await stack.up({ onOutput: console.log });
  console.log(`部署完成: ${upResult.summary.result}`);
}

deploy().catch(err => console.error(err));

这种方式适合CI/CD流水线，你可以轻松区分preview和up操作——比如preview时跳过检查，只在up时执行，或者根据环境变量控制。

结论：直接在index.ts调用不是最优方案 #

直接在index.ts顶层调用检查逻辑的弊端太明显，无法适配Pulumi的生命周期，也没法灵活控制执行时机。更推荐根据场景选：

• 依赖已部署资源：用动态资源或invoke
• CI/CD编排：用Automation API前置检查
• 非要在index.ts里调用：加个判断，跳过preview阶段

  if (!pulumi.runtime.isDryRun()) {
    // 只在up时执行检查
    (async () => { await dbCheck(); })();
  }
  

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