問題タブ [node-streams]

次のやや単純なミドルウェアを考えてみましょう:

対処方法がわからない問題がいくつかあります。

• このミドルウェアが実行される前に res が既に 'close' を出力している場合、スタックします。
• res が発行された場合、closeまたはerrorソース ストリームはどのようにクリーンアップされますか? すべてのデータが読み取られた場合にのみ実行されますautoClose。endしかし、ターゲットが失敗した場合、それはどのようにソースに伝播されるのでしょうか? destroy常にソース ストリームを呼び出す必要がありますか?

Class:child_process.stdin が書き込み可能なストリームなのはなぜですか? これをどのように理由付ける必要がありますか？ https://nodejs.org/api/child_process.html#child_process_child_stdin

バックグラウンド：

ここの初心者。nodeschool stream-adventure の問題「duplex」をやっています。

私は（間違って）インターフェースrequire('duplexer2')([Writable Stream],[Readable Stream])をrequire('duplexer2')(child.stdout, child.stdin)

リクエストが終了したときに自動的にログを記録しようとしています。

私はこのようなものを持っています:

• それはすべてのケースをカバーしていますか？(例: リクエストが中断された場合)
• リクエストごとに最大 1 回呼び出されますか?

いずれかの答えが「いいえ」の場合は、その方法を含めてください。

SFTB、POSTサーバーに でリクエストが来ましたmultipart/form-data。そのリクエストから、ファイルの内容を取得したいと思います。

私は提供されたファイルstreamsとパイプを読んでいます。これは、 [私がそのために使用している]を使用してリソースをフェッチするカスタム関数にコンテンツを渡していることcvsParserの単なるインスタンスであり、それをフェッチした後、画像を圧縮しています.csv-streamifyTransformhttpgot

今問題は、初めてファイルを送信するとチャームのように機能しますが、同じファイルを2回目に送信しようとすると、部分全体がスキップされ、イベントハンドラーstreamに直接ジャンプします。finish

初めてのログ:-

同じファイルを 2 回目に送信したときのログ [フロントエンドでの更新の有無にかかわらず]

参考までに、フロントエンドではfetchAPI を使用してPOSTリクエストを行っています。

私のサーバーコード:-

ありがとう。

(JSON ドキュメントを含むファイルから) 読み取り可能なストリームの配列を作成しており、それらを別のストリームにパイプしようとしています。

ファイル内のデータは通過していますが、パイプでストリームに受信したすべてのオブジェクトについて、このデータがどのファイルからのものかを知りたいです。

出力:

( で) 読み取ったオブジェクトをさらに処理するには、ファイル パスが必要ですが、jsonStream.on('data') callbackこの追加データを渡す方法がわかりません。

「multiparty」パーサーを使用して、アプリケーションで multipart-form-data を読み取って処理しています。私のアプリのミドルウェアは、アップロードされたファイルの内容を読み取り、オンザフライで解析し、成功した場合は次のミドルウェアに送信します。そうでない場合は、リクエストを中止してエラーを返す必要があります。

解析中 (つまり readFile()) にエラーが発生した場合、残りのパーツ バッファーを消費せずに HTTP エラーを返したいと考えています。これを行うための適切な方法があると確信していますが、正しくありません。

readFile() 内から例外をスローして、form.on('part', ...) でキャッチしようとしました。例外をキャッチできたにもかかわらず、フローを中止しませんでした。form.on(part,..) からの return() は、この evt ハンドラ関数から返されますが、外側の関数からは返されません。

nodejsストリームのドキュメントに従って、readFile()内からエラーイベントを発行して、part.on('error', ...)でエラーを処理しようとしました。これも同じ動作になり、処理は終了しません。

ここで何が欠けていますか？これ以上処理したくないことをストリームに伝える適切な方法はありますか..?

mp3 をカットしてブラウザにストリーミングしようとしていますが、ブラウザで破損したファイルが表示されます

私はexceljs、Excel ファイルを生成するために使用している帆アプリケーションを持っています。彼らのドキュメントを見る：

https://www.npmjs.com/package/exceljs#writing-xlsx

ストリームへの書き込みを許可しているようです。

ユーザーが応答を期待しているときにこれを行うにはどうすればよいですか?

私は以下を読みました：

http://sailsjs.org/documentation/concepts/custom-responses/adding-a-custom-response

http://sailsjs.org/documentation/concepts/custom-responses/default-responses

res.attachment()ファイルを保存した後にも試しましたが、成功しませんでした。足りないものはありますか？

編集

以下の答えはほぼ正しいです。私は次のことを行いましたが、うまくいきました。以前のソリューションでは、ファイルが破損することがありました。

これは、EC2 インスタンスとローカルで機能しました。