質問事項
GASの実行ログを見ていると、通常ならありえないはずの状態になっていました。
まるでGASが再起動したかのように、処理途中で起動時にしか出力していない実行ログが出力されていました。
GASのプログラムが再起動するようなことは発生しうるのでしょうか?
また、発生するとすればどのようなケースが考えられるのでしょうか?
内容
所定のフォルダ内にあるファイルを順に読み込んでデータをBigQueryのテーブルにinsertする、という処理を行っています。
その複数ファイルの処理の最中に、突然プログラムが先頭から再起動したような現象が発生しました。
以下のコードで、★★のログの後、☆☆のログ出力は無く、◆◆のログが出力されていました。
◆◆は起動時1回しか出力されない為、何らかの理由で再起動したのかと思ったのですが、そのようなことが起こる可能性はあるのでしょうか?
(変数名、メソッド名、定数は置き換えています)
const FOLDER_ID = 'xxxxxxxx'
function myFunction ()
{
try
{
console.log("処理開始") //◆◆
var start_time = new Date() //25分で処理を止めるための処理開始時刻取得
var BSfolder = DriveApp.getFolderById(FOLDER_ID)
var Sfiles = BSfolder.getFiles()
var Sfile
var contents = new Array()
var Format
var date = new Date()
while (Sfiles.hasNext())
{
Sfile = Sfiles.next()
console.log("ファイル読み込み")
contents = ReadFile(Sfile.getId()) //ファイルを読み込んでString配列に
Logger.log("ファイル読み込み完了 " + Sfile.getName() + " / " + Sfile.getSize() + "byte")
Format = FormatCheck(contents) //フォーマットチェック
Logger.log("フォーマットチェック完了")
switch (Format) {
case "A":
if (!FunctionA(contents)) {
throw new Error("ファイルインポート中にエラー発生")
}
break
//未使用
// case "Z":
// FunctionZ()
// break
default:
throw new Error("不明なフォーマット")
}
}
var current_time = new Date() //25分で処理を止めるための現在時刻取得
var difference = parseInt((current_time.getTime() - start_time.getTime()) / (1000 * 60)) //経過時間計算
if (difference >= 25) {
return //25分を超えていたら終了
}
console.log("処理完了")
}
catch(e) {
console.error(e)
throw new Error("myFunctionでエラーが発生しました")
}
}
function FunctionA (contents)
{
var aryContents = new Array();
var accId;
var AccIds = new Array();
var bAccIds = new Array();
aryContents = contents;
console.log("aryContents開始");
for (var i = 0; i < aryContents.length; i++)
{
if (aryContents[i].substr(0,3) == ":P:") {
accId = aryContents[i].substr(3,20).replace(/[\r\n]+/g,"");
}
if (aryContents[i].substr(0,3) == ":A:") {
AccIds.push(accId);
}
if (aryContents[i].substr(0,3) == ":B:") {
bAccIds.push(accId);
}
if (aryContents[i].substr(0,3) == ":C:") {
flagC = true;
AccIds.push(accId);
}
}
console.log("aryContents読込完了");
console.log("TableB書込開始"); //★★
if (!AddTableB(bAccIds, balanceCcy, balanceDt, balanceCBalance)) {
return false;
}
console.log("TableB書込完了"); //☆☆
console.log("TableC書込開始");
if (flagC == true){
if (!AddTableC()) {
return false;
}
}
console.log("TableC書込完了");
return true;
}
function AddTableB (AccIds)
{
var strData = "";
for (var i = 0; i < AccIds.length; i++) {
var strRowData =
"" + "\t" +
AccIds[i] + "\t" +
"" + "\t" +
"" + "\t" +
".";
if (strData != "") {
strData = strData + "\r\n";
}
strData = strData + strRowData;
}
// バイナリに変換
var blob = Utilities.newBlob("", 'application/octet-stream').setDataFromString(strData, "utf-8");
// テーブル登録情報定義
var job = {
configuration: {
load: {
destinationTable: {
projectId: "Project-999999",
datasetId: "DataSet-999999",
tableId: "TableB"
},
fieldDelimiter: '\t',
// データ追加登録
writeDisposition: 'WRITE_APPEND'
}
}
};
// ファイルの内容をテーブルに登録
job = BigQuery.Jobs.insert(job, "Project-999999", blob);
// JOBの完了待ち
var jobId = job.jobReference.jobId;
var sleepTimeMs = 100;
while (job.status.state != 'DONE') {
job = BigQuery.Jobs.get("Project-999999", jobId);
Utilities.sleep(sleepTimeMs);
}
if (job.status.errorResult != null) {
console.error("TableBの登録中にエラーが発生しました。\r\n" + strRowData);
console.error(job.status.errorResult);
console.error(job.status.errors);
return false;
}
return true;
}
function AddTableC (AccIds)
{
//テーブル名以外はAddTableBと同じ
}