問題タブ [event-stream]

Flask アプリケーションを使用して大きな PDF を生成しようとしています。pdf の生成では、10 個の長い pdf を生成し、それらをマージします。アプリケーションは、フラグ --worker-class gevent --workers 2 を指定して Gunicorn を使用して実行されます。

サーバー側のコードは次のようになります。

クライアント側のコードは次のようになります。

GUnicornなしで実行すると、コンソール ログから安定したリアルタイムの更新が提供されます。それらは次のようになります。

このコードをGunicorn で実行すると、定期的に更新されません。ワーカーは、Gunicorn のタイムアウトによって強制終了されるまで実行されます。その後、発生するはずだったすべてのメッセージのダンプが取得され、その後に最終エラーが発生します

Gunicorn のログは次のようになります。

Gunicorn がプロセスを強制終了しないようにするにはどうすればよいですか? 非常に大きなタイムアウトを設定することは良い考えではないと思います。おそらく、gunicorn のワーカー クラスには、プロセスが正しく処理されていることを確認するために使用できるものがありますか?

text/event-streamExpress.js エンドポイントから SSE 応答を送信しようとしています。私のルートハンドラは次のようになります:

後で私は電話します：

私のブラウザはリクエストを作成して保持します：

ブラウザーにプッシュされる応答はありません。私のイベントはどれも発生しません。Express.js サーバーを強制終了した場合。応答が突然排出され、すべてのイベントがブラウザーに一度にヒットします。

コードを更新res.end()して行の後に追加するres.write(message)と、ストリームは正しくフラッシュされますが、イベント ポーリングにフォールバックし、応答をストリーミングしません。

res.write(':' + Array(2049).join('\t') + '\n'); 他の SO 投稿から見たように、ブラウザーをトリガーして応答を排出できるように、応答の先頭にパディングを追加しようとしました 。

http以前にこのコードをノードのネイティブサーバーで使用していて、正しく機能していたため、これは Express.js の問題であると思われます。したがって、エクスプレスの応答オブジェクトのラッピングをバイパスする方法があるかどうか疑問に思っています。

pg コールバックのイベント ストリームに問題があります。この小さなコードでそれを減らすことができました：

そのコードを実行すると、期待どおり、k1 の割り当てによって配列が表示されます。しかし、k2 の割り当ては、同じコードであるため、何もしません。

sudo npm update ですべてを更新しました。ここに私の package.json があります

何か案が ？

チャネル ( https://github.com/ubolonton/js-csp ) とオブザーバブル ( https://rpominov.github.io/kefir/ )の違いは何ですか? 一方を使用する方が他方を使用するよりも理にかなっている特定のユースケースはありますか?

RxJava と RxNetty を使用して、Apache Mesos の新しい HTTP スケジューラ API のクライアントを作成中です。

RxNetty との接続を正常に作成しObservable<Event>、結果のチャンク ストリームから を作成することができました。

現在、リソースのオファーを要求/拒否したり、タスクステータスの更新を確認したりするために、Mesos にコールバックを送信するために使用できるシンクをモデル化しようとしています。

Mesos に送信されるメッセージはです。シンクに入るすべてのメッセージに対してまたはCallを提供できる必要があります。これは、Mesosが送信された に対して同期検証を実行するためです。onCompletedonErrorCallCall

私は基本的に次のことを許可しようとしています。

今、Subject を拡張し、Calland Action0foronCompletedとAction1<Throwable>forを指定するカスタム オブジェクト [1] を考え出しましたonError。ただし、可能であれば、RxJava の既存の構造を使用したいと思います。私が思いついたものの使用例[2]。

ガイダンスをいただければ幸いです。

[1] https://github.com/BenWhitehead/mesos-rxjava/blob/sink-operation/mesos-rxjava-core/src/main/java/org/apache/mesos/rx/java/SinkOperation.java#L17

[2] https://github.com/BenWhitehead/mesos-rxjava/blob/sink-operation/mesos-rxjava-example/mesos-rxjava-example-framework/src/main/java/org/apache/mesos/rx /java/example/framework/sleepy/Main.java#L117-L124

非同期関数によって開始されるタスクのリストがあります。ストリームの配列を約束することになります。これらのストリームを 1 つのストリームにマージし、それを Gulp に返す必要があります。以下は私が思いついたものです。それはちょっと不格好です。これを行うより良い方法はありますか？

PGにtsvファイル〜1.5 Gを入力する必要があります。ストリーミングとpg-copy-streamを使用する予定で、直接コピーで機能しました。次に、いくつかの変換を行う必要があり、貫通パイプを追加しましたが、失敗しました。おそらくバッファの問題であり、誰かがこれを行ったに違いないと思います。

元のtsvfile.txtの形式は次のとおりです。

コードは

エラーは でしたが error: extra data after last expected column、最初の 2 つのパイプを削除すると正常に動作します。