外部API呼び出しとfindOneAndUpdateを使用した結果のループ

通常の本番環境での使用は、それなしで行う必要があります：

Model.find({},{ _id: 1, tweet: 1}).then(tweets => 
  Promise.all(
    tweets.map(({ _id, tweet }) => 
      api.petition(tweet).then(result =>   
       TweetModel.findOneAndUpdate({ _id }, { result }, { new: true })
      )
    )
  )
)
.then( updatedDocs => {
  // do something with array of updated documents
})
.catch(e => console.error(e))

もう1つの「微調整」は、Promiseの「bluebird」実装を使用することです。 map（） 、どちらも一般的なを組み合わせたものです。 Array.map（） Promiseへ （s）実行中の並列呼び出しの「並行性」を制御する機能を備えた実装：

const Promise = require("bluebird");

Model.find({},{ _id: 1, tweet: 1}).then(tweets => 
  Promise.map(tweets, ({ _id, tweet }) => 
    api.petition(tweet).then(result =>   
      TweetModel.findOneAndUpdate({ _id }, { result }, { new: true })
    ),
    { concurrency: 5 }
  )
)
.then( updatedDocs => {
  // do something with array of updated documents
})
.catch(e => console.error(e))

「並列」の代替は、順番に実行されます。結果が多すぎると、API呼び出しや呼び出しが多すぎてデータベースに書き戻せない場合に、これが考慮される可能性があります。

Model.find({},{ _id: 1, tweet: 1}).then(tweets => {
  let updatedDocs = [];
  return tweets.reduce((o,{ _id, tweet }) => 
    o.then(() => api.petition(tweet))
      .then(result => TweetModel.findByIdAndUpdate(_id, { result }, { new: true })
      .then(updated => updatedDocs.push(updated))
    ,Promise.resolve()
  ).then(() => updatedDocs);
})
.then( updatedDocs => {
  // do something with array of updated documents
})
.catch(e => console.error(e))

そこで、Arrayを使用できます。 reduce（） 約束を「連鎖」させて、順番に解決できるようにします。結果の配列はスコープ内に保持され、最後の .then（）とスワップアウトされることに注意してください その「チェーン」のさまざまなポイントで解決するPromiseからの結果を「収集」するためのこのような手法が必要なため、結合されたチェーンの最後に追加されます。

非同期/待機

実際には現在のLTSリリースであり、しばらく前から存在しているNodeJS V8.x以降の最新の環境では、実際には async / awaitがサポートされています。 。これにより、フローをより自然に作成できます

try {
  let tweets = await Model.find({},{ _id: 1, tweet: 1});

  let updatedDocs = await Promise.all(
    tweets.map(({ _id, tweet }) => 
      api.petition(tweet).then(result =>   
        TweetModel.findByIdAndUpdate(_id, { result }, { new: true })
      )
    )
  );

  // Do something with results
} catch(e) {
  console.error(e);
}

または、リソースが問題になる場合は、順番に処理することもできます：

try {
  let cursor = Model.collection.find().project({ _id: 1, tweet: 1 });

  while ( await cursor.hasNext() ) {
    let { _id, tweet } = await cursor.next();
    let result = await api.petition(tweet);
    let updated = await TweetModel.findByIdAndUpdate(_id, { result },{ new: true });
    // do something with updated document
  }

} catch(e) {
  console.error(e)
}

findByIdAndUpdate（） _idの照合としても使用できます はすでに暗示されているため、最初の引数としてクエリドキュメント全体を必要としません。

BulkWrite

最後に、実際に更新されたドキュメントがまったく必要ない場合は、 bullkWrite（） はより適切なオプションであり、通常、書き込みを1回のリクエストでサーバー上で処理できます。

Model.find({},{ _id: 1, tweet: 1}).then(tweets => 
  Promise.all(
    tweets.map(({ _id, tweet }) => api.petition(tweet).then(result => ({ _id, result }))
  )
).then( results =>
  Tweetmodel.bulkWrite(
    results.map(({ _id, result }) => 
      ({ updateOne: { filter: { _id }, update: { $set: { result } } } })
    )
  )
)
.catch(e => console.error(e))

またはasync/ await経由 構文：

try {
  let tweets = await Model.find({},{ _id: 1, tweet: 1});

  let writeResult = await Tweetmodel.bulkWrite(
    (await Promise.all(
      tweets.map(({ _id, tweet }) => api.petition(tweet).then(result => ({ _id, result }))
    )).map(({ _id, result }) =>
      ({ updateOne: { filter: { _id }, update: { $set: { result } } } })
    )
  );
} catch(e) {
  console.error(e);
}

bullkWrite（）として、上記のほとんどすべての組み合わせをこれに変えることができます。 メソッドは命令の「配列」を受け取るため、上記のすべてのメソッドから処理されたAPI呼び出しからその配列を構築できます。