Typescript Firebase HTTPS函数 在完成后台工作之前响应200状态码

您需要非常小心地使用HTTP函数，并确保all您的工作已完成before您启动了响应.这在The Node.js Runtime中有记录:

在处理涉及回调或Promise个对象的异步任务时，必须显式通知运行库函数已完成这些任务的执行.您可以通过几种不同的方式完成此操作，如下面的示例所示.关键是，您的代码必须等待异步任务或Promise完成才能返回；否则，函数的异步组件可能会在完成之前终止.

// OK: await-ing a Promise before sending an HTTP response
await Promise.resolve();

// WRONG: HTTP functions should send an
// HTTP response instead of returning.
return Promise.resolve();

// HTTP functions should signal termination by returning an HTTP response.
// This should not be done until all background tasks are complete.
res.send(200);
res.end();

// WRONG: this may not execute since an
// HTTP response has already been sent.
return Promise.resolve();

实际上，这意味着您的两个示例永远不会像预期的那样工作，因为您是在完成// do other POST requests所描述的工作之前启动响应的.

从你的描述来看，这听起来像是:

1. 您需要对呼叫者做出快速响应
2. 当调用此函数时，您需要触发另外两个函数
3. 但来自其他两个函数的响应不会用于对原始调用方的响应

如果是这种情况，我建议您使用发布/订阅触发的后台函数，并按如下方式构造此函数:

const { PubSub } = require('@google-cloud/pubsub')

const pubSubTopic1 = new PubSub('your-project-id').topic('the-first-topic-name')
const pubSubTopic2 = new PubSub('your-project-id').topic('the-second-topic-name')

exports.example = functions
  .https
  .onRequest(async (request, response) => {
    const authHeader = request.get("authorization");
    const {statusCode, httpsResponseMessage} = verifyAuthHeader(authHeader, token);

    // Publish messages to the Pub/Sub topics to trigger those functions
    await Promise.all([
      pubSubTopic1.publishMessage('message-1'),
      pubSubTopic2.publishMessage('message-2')
    ]);

    // Send 200 response to our caller within 10 seconds to avoid more retries.
    response.status(statusCode).send(
     {
      message: httpsResponseMessage,
     }
    );

    // Do nothing after calling .send() because the function has terminated
  }

发布/订阅速度快，延迟低，考虑到您正在处理的并发性数量，您的函数应该保持在热状态并快速启动.

不要将FiRestore用于此功能；创建一个触发函数的文档and会遇到成本问题，而创建大量必须保留或删除的文档会遇到成本问题，并且每个创建/删除操作都会产生成本.无论如何，FiRestore文档触发器的工作方式是通过发送发布/订阅消息，因此在您的流程中引入文档写入只会增加整个流程的延迟.

示例PubSub函数

正如在下面的注释中提到的，使用Firebase-Functions非常笨重，因此这里有一个不需要它的示例PubSub触发函数.

假设该函数期望接收一个JSON字符串作为发送到PubSub主题的消息.例如，在上面的HTTP函数中，您可能会发布如下消息:

const message1 = {
  "foo": "bar",
  "bar": "baz"
}
let statusCode = 202 // Accepted

try {
  await pubSubTopic1.publishMessage({ json: message1 })
} catch (error) {
  statusCode = 502 // Bad Gateway
} finally {
  res.status(statusCode).send({ message: httpsResponseMessage })
}

您的接收PubSub函数可以像下面这样小而简单:

export const examplePubSubFunction = message => {
  const data = JSON.parse(Buffer.from(message.data, 'base64').toString())
  console.log(data.foo) // prints "bar"
  console.log(data.bar) // prints "baz"
}

然后，您可以通过以下方式部署该功能:

gcloud functions deploy examplePubSubFunction --runtime=nodejs18 --trigger-topic=the-first-topic-name