2

私は Storm の初心者であり、CEP の要件に合わせてその機能を調査してきました。私がつまずいたさまざまな例は、メッセージブローカー、データベースからのポーリングサービスとしてスパウトを実装しています。プッシュ ベースのスパウト、つまりスパウト内で実行される Thrift サーバーを実装する方法は? スパウトが実行されている場所をクライアントに知らせて、スパウトにデータをプッシュできるようにするにはどうすればよいですか?

4

4 に答える 4

0

これは Storm の一般的な使用法ではありません。明らかに、同じマシン上のスパウトの複数のインスタンスを同じポートにバインドすることはできません。分散セットアップでは、API の現在の IP アドレスとポートを、たとえば ZooKeeper に保存してから、リクエストを API に転送するバランサーに保存することをお勧めします。

以下は、Storm で単純な REST API を使用したプロジェクトです。

https://github.com/timjstewart/restexpress-storm

于 2014-05-29T22:34:59.257 に答える