問題タブ [highland.js]

私は node.js から大きな価値を得ており、ストリーム処理モデルが大好きです。私は主に、データ エンリッチメントと ETL のようなジョブを使用したスト​​リーム処理に使用しています。

充実のために、こんな記録もあるかもしれません…

おそらく製品の詳細を追加して、これを充実させたいと思います

説明のデータと価格のデータは、どちらも別々のストリームから取得されます。ハイランドでそのような依存関係にアプローチする最良の方法は何ですか?

何かご意見は？

NoFlo.js に触発されてから、highland.js を学んでいます。ストリームを再帰的に操作できるようにしたい。この不自然な例では、2 を掛けた数値を提供し、結果 <= 512 をフィルタリングします。数値が掛けられると、システムにフィードバックされます。私が持っているコードは機能しますが、パイプラインで doto 関数を取り出すと、数字は処理されません。データを returnPipe に間違って送り返していると思われます。データをシステムに戻すより良い方法はありますか? 私は何が欠けていますか？

ハイランド ストリームを使用して、別のデータ ストリームとメタデータ オブジェクトの 2 つのオブジェクトを返そうとしています。ストリームを作成します。

後で、次を使用してこれを消費します。

問題は、apply によって呼び出された関数がhstream終了する前に動作し、「メタ」オブジェクトが表示されないことです。hstream に両方のオブジェクトが含まれるまで apply が呼び出されないように、これを再構成するにはどうすればよいですか?

heroku-clientと組み合わせてハイランドを使用しようとしています。しかし、それが使用するherokuクライアントの内部では、これをバインドしようとしても、機能が動作しないという言及があるエラーメッセージが表示されます。 thisbindthis

いいえ、コードは次のようになります

そのため、このコード スニペットは次のエラー メッセージで失敗します。

SO では主観的な回答は避けるべきなので、具体的に質問します。これらの 3 つの機能的/反応的なライブラリの機能的および/またはパフォーマンスの違いは何ですか? BaconJS は jQuery に依存しているため、削除しました。私は JS ストリームに慣れていないので、最初は NodeJS で、次に AngularJS のコンテキストでそれらに慣れることに主な関心があります。他のものよりもこれらのいずれかを選択した場合、選択につながる基準は何ですか?

入力ファイルから行を送り出し、変換して出力ファイルに入れる必要があります。

入力ファイルが大きいので、HighlandJS でストリーミングしています。

変換ステップには、(node-mysql を介して) MySQL DB に非同期クエリが含まれており、ストリームで非同期クエリを管理する方法がわかりません。私のさまざまな試行では、エラーが発生するか、何も発生しません。

私の最後の試みはそれです：

それを行う方法に関するヒントはありますか？

ありがとう。

値を繰り返すストリームを作成する必要があります。ベーコンを使用すると、繰り返しプリミティブでこれを行うことができます