GAS并行处理写入谷歌表格时如何避免行冲突丢失数据？

问题描述 #

部署了一个GAS Web应用，为规避GAS的6分钟执行限制采用并行处理方式向谷歌表格写入数据。使用sheet.appendRow(list)方法写入时，本该写入新行的数据被写入同一行，导致数据丢失。

相关代码 #

GAS 代码

//GAS code
function doGet() {
  return HtmlService.createHtmlOutputFromFile('webapp');
}

function myFunction(n) {
  let lists=[];
  //any process
  //an example
  lists.push([1000+n,2000+n,3000+n]);
  lists.push([4000+n,5000+n,6000+n]);
  lists.push([7000+n,8000+n,9000+n]);
  writedown(lists);
}

function writedown(list) {
  let sp=SpreadsheetApp.openById("~~~~~~~~~~");    
  let sheet = sp.getSheetByName("~~");
  for(var i = 0; i < list.length; i++){
    sheet.appendRow(list[i]);
  }
}

（注：原代码中list变量存在拼写错误，已修正为lists）

WebApp HTML代码

//webapp.html
<!DOCTYPE html>
<html>
  <head>
    <base target="_top">
  </head>
  <body>
    <button onClick="runInParallel()">DO IT !!</button>
    <script>
      const limit = 30;

      function runInParallel() {
        for (let i = 0; i < limit; i++) {
              google.script.run.myFunction(i);
        }
      }      
    
    </script>
  </body>
</html>

问题根源 #

并行请求下，多个myFunction实例同时调用appendRow时，会出现竞态条件：不同请求同时读取表格当前的最后一行位置，然后往同一位置写入数据，最终导致数据覆盖到同一行，造成丢失。

解决方案 #

两种方向都可以调整，更推荐组合方案彻底解决问题：

方案1：优化写入逻辑，批量写入替代逐行append

逐行调用appendRow会频繁触发Spreadsheet服务的读写，不仅效率低，还容易引发冲突。改为一次性批量写入所有数据：

function writedown(list) {
  let sp = SpreadsheetApp.openById("~~~~~~~~~~");    
  let sheet = sp.getSheetByName("~~");
  if (list.length === 0) return;
  
  // 获取最后一行的下一行，一次性写入所有数据
  const startRow = sheet.getLastRow() + 1;
  const numRows = list.length;
  const numCols = list[0].length;
  sheet.getRange(startRow, 1, numRows, numCols).setValues(list);
}

方案2：调整并行处理，加入锁机制

使用GAS的LockService确保同一时间只有一个请求在写入表格，避免并行冲突：

function writedown(list) {
  const lock = LockService.getScriptLock();
  // 等待最多30秒获取锁，超时则抛出错误（可按需调整时长）
  if (!lock.tryLock(30000)) {
    throw new Error("无法获取写入锁，操作失败");
  }
  
  try {
    let sp = SpreadsheetApp.openById("~~~~~~~~~~");    
    let sheet = sp.getSheetByName("~~");
    for(var i = 0; i < list.length; i++){
      sheet.appendRow(list[i]);
    }
  } finally {
    // 无论成功失败，必须释放锁
    lock.releaseLock();
  }
}

组合方案（推荐）

将批量写入和锁机制结合，既提升写入效率，又彻底避免并行冲突：

function writedown(list) {
  const lock = LockService.getScriptLock();
  if (!lock.tryLock(30000)) {
    throw new Error("无法获取写入锁，操作失败");
  }
  
  try {
    let sp = SpreadsheetApp.openById("~~~~~~~~~~");    
    let sheet = sp.getSheetByName("~~");
    if (list.length === 0) return;
    
    const startRow = sheet.getLastRow() + 1;
    const numRows = list.length;
    const numCols = list[0].length;
    sheet.getRange(startRow, 1, numRows, numCols).setValues(list);
  } finally {
    lock.releaseLock();
  }
}

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