Cloud Tasks队列任务滞留未执行 无法触发Handler处理函数

任务永久滞留队列无法触发处理函数，是以下几个问题共同导致的：

• 任务目标类型配置完全错误：你在任务定义中使用了appEngineHttpRequest字段，该配置仅会将请求转发至同项目下的Google App Engine服务，而你的处理程序部署在Cloud Functions平台，不属于App Engine资源，队列无法找到对应请求端点，所有投递请求都会返回404，触发无限重试。
• 生成任务的代码存在语法错误：createTask.js中在task对象尚未定义完成时，就插入了一行调用createTask的冗余代码，代码中引用的tasksClient、queuePath两个变量均未声明，属于无效废代码。
• 处理函数代码缺失依赖引入：server.js中直接调用bodyParser.raw但未提前引入body-parser包，即使请求到达函数也会直接抛出变量未定义的运行时错误。
• 缺失身份认证配置：Cloud Functions HTTP触发器默认开启身份校验，即使修正了目标类型，未携带合法认证令牌的请求会被权限层直接拦截，无法到达业务逻辑。

按以下步骤调整即可恢复正常调度：

1. 替换任务目标类型：将appEngineHttpRequest替换为httpRequest，配置项中填写处理函数的完整公网触发URL。
2. 添加OIDC认证配置：在httpRequest配置中增加oidcToken字段，指定有权限调用Cloud Functions的服务账号作为请求身份。
3. 删除createTask.js中位置错误的冗余createTask调用，修正代码语法。
4. 补全server.js中缺失的body-parser依赖引入，同时调整服务启动逻辑适配Cloud Functions托管运行时（不要在托管环境中直接监听固定端口）。
5. 为配置中指定的服务账号绑定目标处理函数的Cloud Functions Invoker角色，授予其调用权限。

修正后代码 #

createTask.js（任务生成函数） #

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

exports.createTask = async (req, res) =>  {
  const location = 'us-central1';
  const project = 'project-id'; // 替换为实际项目ID
  const queue = 'queueid'; // 替换为实际队列名称
  const payload = 'Hello, World!';
  const parent = client.queuePath(project, location, queue);
  // 替换为你的处理函数完整触发URL
  const workerFunctionUrl = 'https://us-central1-你的项目ID.cloudfunctions.net/处理函数部署名';
  // 替换为实际使用的服务账号邮箱，默认可使用App Engine默认服务账号
  const serviceAccountEmail = `${project}@appspot.gserviceaccount.com`;

  const task = {
    httpRequest: {
      httpMethod: 'POST',
      url: workerFunctionUrl,
      headers: {
        'Content-Type': 'application/octet-stream'
      },
      oidcToken: {
        serviceAccountEmail
      }
    }
  };

  if (payload) {
    task.httpRequest.body = Buffer.from(payload).toString('base64');
  }
  const inSeconds = 0;
  if (inSeconds) {
    task.scheduleTime = {
      seconds: inSeconds + Date.now() / 1000,
    };
  }

  console.log('Sending task:');
  console.log(task);
  const request = {parent, task};
  const [response] = await client.createTask(request);
  console.log(`Created task ${response.name}`);
  res.send({message: "Ok"});
}

server.js（任务处理函数） #

const express = require('express');
const bodyParser = require('body-parser'); // 补全缺失的依赖引入
const app = express();
app.enable('trust proxy');
app.use(bodyParser.raw({type: 'application/octet-stream'}));

app.get('/', (req, res) => {
  res.send('Hello, World!').end();
});

app.post('/log_payload', (req, res) => {
  console.log('Received task with payload: %s', req.body);
  res.send(`Printed task payload: ${req.body}`).end();
});

app.get('*', (req, res) => {
  res.send('OK').end();
});

// 适配本地调试和Cloud Functions托管环境
if (require.main === module) {
  app.listen(3000, () => {
    console.log('App listening on port 3000');
    console.log('Press Ctrl+C to quit.');
  });
} else {
  module.exports = app;
}

注意：部署处理函数时，需要将函数入口点配置为导出的app；如果队列和函数不在同一项目，还需要提前给Cloud Tasks的服务账号授予跨项目调用权限。

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