Nodejsでの同期処理

Question

前提

APiリクエストを複数実行する時に一度にたくさんのリクエストを送って制限がかからないようにしたい。

実現したいこと

await Promise.allで中にmap化したものを入れてやったがうまくいかなかった

発生している問題・エラーメッセージ

該当のソースコード

const sleep = waitTime => new Promise(resolve => setTimeout(resolve, waitTime));


const all = await g.members.fetch();
await Promise.all(all.map(async m => {
    console.log("request");
    request();
    await sleep(1000);
}));

試したこと

1秒ごとにrequestと表示されていくことを期待していたがやっぱりうまくいかなかった。おそらく何かが違う気がします。

Answer 1

Promiseを順次実行したいのであれば、for（for-inやfor-ofでもOK）のループ内でPromiseを作ってawaitしていくのが一番手っ取り早いです。

Promiseは作成した瞬間にスタートするので、Promise.allを使っても引数を渡す時点ですべてのPromiseが動き出しています。Promise.allは、引数のPromiseが全部resolveした瞬間を拾う、という役割の関数です。

Comments

[Sosupe1123]

ありがとうございます！無事に順次実行できました.

Answer 2

for await ･･･ of ･･･構文の利用を検討するのもありかもしれません。

以下は簡単に試すコードです。HTTPリクエストにaxios、データの取得元にjsonplaceholderの GET /users/:id を使っています。

main.js

import axios from 'axios';

const sleep = waitTime => new Promise(resolve => setTimeout(resolve, waitTime));

const fetchMember = (id) =>
  axios(`https://jsonplaceholder.typicode.com/users/${id}`).then(res => res.data);

async function* fetchMembersGen(ids) {
  for (let i=0; i < ids.length; ++i) {
    yield await fetchMember(ids[i]);
  }
}

for await (const m of fetchMembersGen([1, 2, 3])) {
  console.log(m.id, m.name);
  await sleep(1000);
}

package.json

{
  "dependencies": {
    "axios": "^1.0.0"
  },
  "type": "module"
}

yarn install
node main.js
1 Leanne Graham
2 Ervin Howell
3 Clementine Bauch

追記

上記の回答コードに対する修正です。次のリクエストまでに一秒間待つPromiseのawaitをジェネレータ関数のほうに移動し、かつ最後のリクエスト完了後には1秒待たないようにします。

 async function* fetchMembersGen(ids) {
   for (let i=0; i < ids.length; ++i) {
     yield await fetchMember(ids[i]);
+    if (i < ids.length - 1) {
+      await sleep(1000);
+    }
   }
 }
 
 for await (const m of fetchMembersGen([1, 2, 3])) {
   console.log(m.id, m.name);
-  await sleep(1000);
 }

Answer 3

サンプルプログラム

const sleep = waitTime => new Promise(resolve => setTimeout(resolve, waitTime));

async function main(all) {
    for (const m of all) {
        console.log("request", m);
        await sleep(1000);
    }
}

main([1, 2, 3, 'ダー']);