cronの多重起動を防ぎたい

あるフォルダの中から定期的にファイルを取得するプログラムを作成しています。
5分おきにcronが起動するような動きなのですが、
前回の処理が5分以上かかっている場合の多重起動を制御したいです。

js
1/**
2 * S3取込バッチ
3 */
4
5const cron = require('node-cron');
6const service = require('../services/sample_service');
7
8module.exports = {
9  /**
10   * cronを起動する
11   */
12  start_cron: function (timing) {　← 3分おき
13    cron.schedule(timing, () => {
14      this.start();
15    });
16
17  start: async function () {
18      service.execute_cron(); ← サービスの中に処理があります
19  },
20}

調べると起動中のプロセスを拾う、ロックファイルを作成するなどの記事が出てきましたが、
実際に上記のプログラムの中に組み込むにはどうすれば良いかが分かりませんでした。

node-cronモジュールを使った多重起動の制御を方法がお分かりになる方がいらっしゃいましたら、
ご教授お願い致します。

行動規範の内容に同意します

回答1件

ベストアンサー

js
1/**
2 * S3取込バッチ
3 */
4
5const cron = require('node-cron');
6const service = require('../services/sample_service');
7
8// ファイルの読み書きを司るfsモジュールをロード
9const fs = require("fs");
10
11module.exports = {
12  /**
13   * cronを起動する
14   */
15  start_cron: function (timing) {
16    cron.schedule(timing, async () => {
17      const path = "/tmp/start-func.lock"; // 相応しいパスを指定してね、MacOSやLinuxは/tmp/配下が良さげ
18      // fs.existsSync(path)はファイルが存在すればtrueになる
19      if (!fs.existsSync(path)) {
20        fs.writeFileSync(path, "");
21        // ここでthis.startの結果を待つ為に外の関数をasync関数にしてawaitで待つ
22        await this.start();
23        fs.unlinkSync(path);
24      }
25    });
26  },
27
28  start: async function () {
29    // 返り値はPromiseのインスタンスならawait指定をすることで完了まで待ってくれる
30    await service.execute_cron();
31  },
32}