eventmachine

1熱

1答えて

既存のEventMachineループ内から組み込みのSinatraアプリケーションを起動するきっかけがありますか？私は、EMループによって動かされるクライアント・サーバー・ジェム（チャット・ボット）を持っています。このシングル・ランニング・プロセスの中でSinatra管理インターフェースをスピンアップしたいと思います。これを行う最善の方法は何ですか？

0熱

2答えて

イベントマシンのメモリ管理

私はherokuでイベントマシンプロセスを実行していますが、1時間ほど後にメモリの制限値が512MBに達しているようです。 Error R14 (Memory quota exceeded) Process running mem=531M(103.8%) 私が反応器を通って、イベントの多くを実行しているので、私は多分、原子炉が（私は大きなキューとしてそれを想像しています）バックアップなって

0熱

2答えて

このEventMachine Synchronyのhiredisサンプルが、リクエストの値ではなくDefaultDefferableを返すのはなぜですか？

は、私はこのコードのビットを持っている：DefaultDeferrableが返され、両方のケースで $ ruby /tmp/reddy.rb EventMachine::Hiredis::Client false false ：あなたは/tmp/reddy.rbでのファイルシステムに保存した場合、これを行い、 require 'em-synchrony' require 'em-syn

2熱

1答えて

EM :: Synchrony＃syncを使用すると、「ルートファイバー」FiberErrorが発生します。

このプログラム require 'em-synchrony' ## v1.0.0 require 'em-hiredis' ## v0.1.0 module EventMachine module Hiredis class Client

0熱

1答えて

EventMachine EM :: Iteratorがrabbitmq RPCでブロックされています

RabbitMQ rpcを設定しようとしています。 1つのキューにリッスンしたい場合は、メッセージを受信したときにreply_toヘッダーで複数のメッセージで指定されている匿名キューに返信します。私は以下のトールタスクがキューを作成し、EMを使用してい：イテレータはバックreplyt_toがキールーティングで指定されたキューへのメッセージの数を送信するために： desc "start_consu

3熱

1答えて

EM内のファイバ：接続（em-synchrony）

なぜ、Redis（redis-rb）同期ドライバがEM.synchronyブロックで直接動作しますが、EM内では動作しないのですか？ receive_data以内に使用しているとき、私は can't yield from root fiber (FiberError) を取得しています次の例 EM.synchrony do redis = Redis.new(:path => "/

0熱

1答えて

イベントマシンとRailsを使用する複数の作業者

EventMachineとamqpとrailsを使用する方法がわかりません。私が見つけたチュートリアルのほとんどは、キューに追加できる「プロデューサ」を設定するためのものでした。私は逆を実行する必要があります、私はキューにアイテムを提出するPythonアプリケーションがあり、私は、キューからアイテムをピックアップし、それらを処理するために、レールアプリケーションが必要です。複数のキューが処理さ

3熱

1答えて

Sinatra Synchrony with Redis接続プール

これは、Redis接続プールをSinatra Synchronyで処理する正しい方法ですか？マイgemfileは次のようになります。 gem 'sinatra-synchrony' gem 'hiredis' gem 'redis' シナトラサーバファイルは、古典的なスタイルのアプローチを使用し、一般的にそのように見える： require 'sinatra' require 'sina

2熱

1答えて

EventMachineはチャンク内のファイルを読み書きします

私はEventMachineとEM-SynchronyをREST APIサーバーで使用しています。本体の大きなバイナリファイルを持つPOSTリクエストを受信すると、チャンクで受信し、そのチャンクをTempfileに書き込み、リアクタはブロックしません。その後、ある時点で、このファイルをチャンクで読み込み、そのチャンクを最終的なファイルに書き込む必要があります。これは機能していますが、期待通りに原

5熱

1答えて

EventMachineとTwitterストリーミングAPI

私は、TwitterストリーミングAPIを使用してEventMachineプロセスを実行しています。ストリームのコンテンツが頻繁ではない場合は、常に問題があります。ここでは、スクリプトの最小バージョンです： require 'rubygems' require 'eventmachine' require 'em-http' require 'json' usage = "#{$0}