問題タブ [highland.js]

次のスニペットで同じ出力 (配列値のストリーム) を返そうとしています。

最初のメソッドは配列から開始し、値を発行します。

2 番目のメソッドは、配列を解決する promise を入力として取得するため、各値を発行する代わりに、配列自体のみを発行します。

最初のメソッドと同じものを出力するには、2 番目のメソッドで何を変更すればよいですか?

Highland.js を使用してワークフローを設計しようとしています。Highland.js をどのように使用できるかわかりません。

以下のようなストリームベースのワークフロー(疑似コード)があります。

filterDuplicate はデータベースを検索して、(条件を使用して) 読み取りレコードが存在するかどうかを確認し、ブール値の結果を返します。フィルターが機能するには、ストリームが完了するまで再利用したいアクティブな DB 接続が必要です。1 つの方法は、読み取りの前に接続を開き、書き込みの「終了」イベントで閉じることです。これは、両方のメソッドが同じデータベースを使用する場合に機能する、フィルターと書き込みのパラメーターとして接続を渡す必要があることを意味します。

上記のワークフローでは、filterDuplicate と write も異なるデータベースを使用する場合があります。したがって、接続が各機能内に含まれて管理されることを期待します。これにより、自己完結型の再利用可能なユニットになります。

Highland を使用してこれをどのように設計できるかについての情報を探しています。

ありがとう。

現在、エンドポイントにカールしたときに応答を取得できますが、1 回だけです。私のサーバーへの追加のリクエストは、stream error: Stream already being consumed, you must either fork() or observe().

私のスタック: node、express、highlandjs、mongodb。

//私のエンドポイント関数

エンドポイントに到達するための 2 回目の試行後のサーバーの応答: curl -i -X GET http://localhost:3000/queries/

mongo db をクエリする高速 GET リクエストから取得した JSON 文字列があります。

res.write(string)私に与えます：

ただし、文字列から特定の情報のみをレンダリングしたいと考えています。たとえば、 epc、audit、ss.ts、v3.ts、およびv3.locationです。

どうすればいいですか？

Highland ストリームを使用する node.js アプリケーションがあります。データ ソースを消費し、複数の宛先にデータを送信する必要があります。問題は、データを読み取り、データに基づいて宛先ストリームを作成することによって、宛先が動的に検出されることです。

これは.fork、ストリームに宛先を追加できないことを意味します (消費を開始したストリームは分岐できないためですよね?)

他にできることはありますか？

私の現在のアプローチは、.consume宛先ストリームを作成し、宛先にデータを書き込む場所を持つことです。結果は醜くて厄介です。

splitbyメソッドを使用しhighland.jsて、開始区切り文字と終了区切り文字の間のデータを抽出しようとしています。

次のように、ファイルをストリームに読み込むことができます。

ただし、ファイルを処理して必要なデータを抽出する方法がわかりません。

highland.js に問題があります。ストリーム データから関数の配列を作成する必要がありますが、機能させることができません。これが私のコードですrequestsが、常に空です。

ストリームを使用highland.jsしてファイルを処理し、2 つの区切り記号の間の内容を読み取ります。async.jsまた、一連の http リクエストを順番に実行するために使用しています。

理想的にはx、ハイランドからの出力を最初の関数としてasyncシリーズ (チェーン) に渡し、ストリームから抽出されたチャンクごとに HTTP 要求が実行されるようにしたいと考えています。

これは可能ですか？もしそうなら、どうすればこれを達成できますか？

node.js以下の例に示すように、スタイル オブジェクト ストリームが与えられた場合、これhttpを Web ページのリクエストでどのように読み取って処理することができますか。