Node：非同期処理の中で、大量の要素すべてに対してそれぞれ処理を行いたい。飛び飛びに処理してしまう。

Question

前提

【DB Models】
day_info_today: 指定日の情報が格納されているテーブル。実装済み。
day_info_diff: 指定日とその前日の情報との差分が格納されているテーブル。未実装。

実現したいこと

day_info_todayから指定日とその前日の情報を取得し、差分を計算。その後、day_info_diffに計算結果を格納したい。

試したこと

試してみた処理は以下のようなものです
①day_info_todayから全情報を取得（配列化）
②配列からインデックスで当日と前日の情報を取得し処理
③処理結果をday_info_diffへ格納
④インデックスを+1し次の情報へ→①へ戻る

生じた問題

forでインデックスを回していたのですが、非同期処理であるため、処理が終了する前にforがループしてしまいました。結果、全要素を処理することができませんでした。

質問

実現目標を達成するためには、どのような処理が必要でしょうか？
また、もっとスマートな方法をご存じであるならば、教えていただければ助かります。
よろしくお願いいたします。

DB1を更新したのち全情報を取得、それらを処理するコード

'use strict';
/** TotalとDiff、2つのDBに初期値をセットするプログラムです */
const fs = require('fs');
const csvParse = require('csv-parse');

// モデルの読み込み
const Day_info_total = require('../models/day_info_total');
const Day_info_diff = require('../models/day_info_diff');
Day_info_total.sync();
Day_info_diff.sync();

// DBに格納する情報の大本。要素数約5000個
const path = './downloads/all/total/all.tsv';

function setTotalDatas(path) {
  return new Promise((resolve) => {
　　// tsvをJsonに変換する処理
    var rs = fs.createReadStream(path, 'utf-8');
    var parser = csvParse({
      delimiter: '\t',
      columns: ['date', 'time', 'unixTime', 'videos', 'views', 'comments'],
    });
    rs.pipe(parser).on('data', (data) => {
      // Day_info_totalを更新する
      Day_info_total.create({
        date: data['date'],
        time: data['time'],
        unixTime: data['unixTime'] ,
        totalVideos: data['videos'],
        totalViews: data['views'],
        totalComments: data['comments'],
      });
    }).on('end', () => {
      resolve();
    });
  });
}

setTotalDatas(path).then(() => {
  Day_info_total.findAll().then((datas) => {
    // 【問題箇所】全要素に対して処理を行いが、非同期であるため処理が終わる前にループする。
    for (let i = 1; i < datas.length; i++) {
      　// 処理内容
        console.log(datas[i]);
    }
  }).catch((err) => {
    console.info('err', err);
  });
});

補足情報（FW/ツールのバージョンなど）

Node
DB操作はsequelizeで行っています。

Answer 1

async/await記法を使えば比較的簡単に処理できます。
下記のようにして、someFunctionをasync関数として実装すれば、処理が終わった後に、for文を抜けるようになります。

for (let i = 1; i < datas.length; i++) {
   await someFunction();
}

async/awaitに関しては、下記の記事などが分かりやすいです。
https://qiita.com/soarflat/items/1a9613e023200bbebcb3