如何在代码中为Google Cloud Task单个任务设置MAX_ATTEMPTS重试次数

结论 #

Google Cloud Tasks目前原生不支持为单个任务单独配置最大重试次数，重试规则（包括MAX_ATTEMPT、重试间隔等参数）只能在队列维度统一配置，你查到的官方规则描述是准确的。

可用的替代实现方案 #

如果你需要为不同任务动态配置最大重试次数，可以采用两种方案落地：

• 按重试要求拆分队列
  你可以根据业务场景创建多个重试配置不同的队列，比如最大重试10次的高容错队列、最大重试2次的低容错队列、不重试的关键队列，创建任务时根据需求把任务投递到对应配置的队列即可。
• 任务执行端自行控制重试逻辑
  你可以在任务的payload中自定义max_attempts和current_attempt两个字段，任务处理器每次执行前先做计数判断：
  1. 当前重试次数未超过上限：正常执行业务逻辑，执行失败时将重试计数+1，重新投递新任务到队列
  2. 当前重试次数超过上限：直接终止执行，标记任务失败即可

自定义重试逻辑的代码示例 #

你可以对原有创建任务的逻辑做如下调整：

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

// 创建任务时可传入自定义最大重试次数
async function createHttpTask(customMaxAttempt = 3, currentAttempt = 1, payloadContent = 'Hello, World!') {
  const project = 'my-project-id';
  const queue = 'my-queue';
  const location = 'us-central1';
  const url = 'https://example.com/taskhandler';
  const inSeconds = 180;
  // 把自定义重试参数注入payload
  const payload = JSON.stringify({
    content: payloadContent,
    max_attempts: customMaxAttempt,
    current_attempt: currentAttempt
  });

  const parent = client.queuePath(project, location, queue);
  const task = {
    httpRequest: {
      httpMethod: 'POST',
      url,
    },
    scheduleTime: {
      seconds: Math.floor(Date.now() / 1000) + inSeconds
    }
  };

  if (payload) {
    task.httpRequest.body = Buffer.from(payload).toString('base64');
  }

  const request = {parent: parent, task: task};
  await client.createTask(request);
}

// 示例：创建一个最大重试5次的任务
createHttpTask(5);

对应的任务处理端核心逻辑参考：

async function taskHandler(req, res) {
  const { content, max_attempts, current_attempt } = req.body;
  // 先判断是否超过最大重试次数
  if (current_attempt > max_attempts) {
    console.log(`任务已超过最大重试次数${max_attempts}，终止执行`);
    return res.status(200).send('跳过执行');
  }
  try {
    // 执行你的业务逻辑
    await doBusinessLogic(content);
    return res.status(200).send('执行成功');
  } catch (err) {
    console.error(`任务执行失败，当前重试次数${current_attempt}/${max_attempts}`);
    // 未达重试上限则重新投递任务
    await createHttpTask(max_attempts, current_attempt + 1, content);
    return res.status(200).send('已触发重试');
  }
}

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