如何让Google Cloud Functions在上一个函数执行完成后再启动新函数？

Google Cloud Functions本身没有内置的请求串行执行机制，默认会并发处理请求——当同一实例收到新请求时，正在运行的函数会被终止，直接启动新请求的执行。要实现上一个函数执行完再启动下一个的需求，需要借助Cloud Tasks做中间队列，具体方案如下：

核心思路 #

把原来直接处理Webhook逻辑的函数拆成两部分：

1. 一个接收GitHub Webhook的函数：只负责把请求内容打包成任务，发送到Cloud Tasks队列
2. 一个处理实际业务的函数：由Cloud Tasks队列触发，队列配置为串行分发任务，确保任务按顺序执行

具体实现步骤 #

1. 创建并配置Cloud Tasks队列 #

在GCP控制台或用gcloud命令创建队列，将队列的最大并发分发数设为1，强制串行执行：

gcloud tasks queues create webhook-queue --max-concurrent-dispatches=1

（如果已有队列，用update命令修改参数）

2. 编写Webhook接收函数（Node.js） #

这个函数只做任务转发，快速响应GitHub的Webhook请求：

const { CloudTasksClient } = require('@google-cloud/tasks');
const client = new CloudTasksClient();

exports.receiveGitHubWebhook = async (req, res) => {
  // 提取Webhook的请求体
  const webhookPayload = req.body;
  // 替换成你的GCP项目信息和队列配置
  const projectId = 'your-gcp-project-id';
  const location = 'us-central1'; // 你的队列所在区域
  const queueName = 'webhook-queue';
  // 替换成业务处理函数的部署URL
  const processFunctionUrl = 'https://us-central1-your-gcp-project-id.cloudfunctions.net/processWebhookTask';

  // 构造Cloud Tasks任务
  const task = {
    httpRequest: {
      httpMethod: 'POST',
      url: processFunctionUrl,
      // 把请求体转成base64编码（Cloud Tasks要求）
      body: Buffer.from(JSON.stringify(webhookPayload)).toString('base64'),
      headers: {
        'Content-Type': 'application/json',
      },
    },
  };

  const parent = client.queuePath(projectId, location, queueName);
  await client.createTask({ parent, task });

  // 快速响应GitHub，避免Webhook重试
  res.status(200).send('Webhook task queued');
};

3. 编写业务处理函数（Node.js） #

这个函数负责原来的Webhook逻辑，由Cloud Tasks触发：

exports.processWebhookTask = async (req, res) => {
  console.log('Function execution started');
  const webhookPayload = req.body;

  // 这里写你的实际业务逻辑
  // 比如处理GitHub推送、创建Issue等操作
  // ...

  console.log('Function execution took XX ms, finished with status code: 200');
  res.status(200).send('Task processed successfully');
};

4. 配置权限 #

• 确保receiveGitHubWebhook函数拥有cloudtasks.tasks.create权限，可以通过IAM角色roles/cloudtasks.enqueuer赋予
• 确保processWebhookTask函数允许Cloud Tasks触发：在函数的触发器设置中，添加Cloud Tasks的服务账号为授权调用者

关键注意事项 #

• Cloud Tasks会自动处理任务重试，如果业务函数执行失败，队列会按默认策略重试（可在队列配置中调整）
• GitHub Webhook的超时时间较短，所以接收函数必须快速响应，不能等待业务逻辑完成
• 队列的并发数可以根据需求调整，如果需要并行处理多个任务，只需修改max-concurrent-dispatches的值即可

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