問題タブ [highland.js]

requestすでに空の配列であることをマップするために渡しているため、nodejs ストリームを処理する際に問題が発生しています。

この機能

ログ

私はそれがログに記録されることを期待していました

highland.js でエラーを正しく使用するにはどうすればよいですか?

ノード ストリーム マネージャーであるhighland.jsのコツを学びます。

かなり基本的なことをしようとしています：

出力が得られない

代わりに実行すると

次の出力が得られます。

コンテンツを含まないストリームのように見えます。

ここで何が間違っていますか？

これはおそらく初心者の質問ですが、検索しても満足のいく答えが見つかりませんでした。

node.js アプリケーションが大量のメモリを消費しているようです。各プロセスは約 100MB を消費します。nodejs 自体は、プロセスごとに最大 30MB のメモリ フットプリントを持っていると聞きました。

アプリケーションは、MongoDB を基盤とする JSON API です。多くの場合、1 つの API リクエストが多くのデータベース リクエストを引き起こし、主に子関係を設定します。典型的なクエリは次のようなものです: (1) クエリ条件に基づいて objectId の配列を取得し、(2) 各 objectId を繰り返し、データベースにクエリを発行してデータを入力します (ハイドレーションと呼ばれるものもあります)。

コードは async.js を多用しています。メモリ使用量をプロファイリングしようとしましたが、async.js が多くのメモリを使用しているようですが、メモリ リークの兆候はありません。async.js の作成者は、ストリーム ライブラリ highland.js ( http://highlandjs.org/ ) も発表しました。私は nodejs ストリームを初めて使用しますが、これが async.js を置き換える可能性のあるツールであるかどうかに興味がありますか? Webサイトに記載underscoreがあるようですが、私は主async.jsに非同期処理に使用しています。

ありがとう！

だから私はハイランドストリームを持っています:

からの読み方はfileStream？Highland docsによると、read()ストリームにはメソッドがありません。

ファイルを 1 行ずつ読み取るハイランド ストリームがあり、その速度を 1 秒あたり 1 チャンクに落としたいと考えています。ドキュメントを調べたところ、見つかった関数は と だけでしthrottle()たdebounce()。これらは両方とも値を落とします。すべての値を保持し、速度を遅くする必要があります。

を使用して、このスニペットを正常に動作させていasync.applyEachSeriesます。

私はそれをhighland.jsに変換しようと何度か試みましたが、そこの配管を理解していません。_.wrapCallback(firstThing)firstThing と secondThing の両方に対して行う必要があると確信していますが、必要かどうか、または何が必要_.pipelineかはわかりません.series()。