What is Reaqtor?

Reaqtorとは何か？

Reaqtorは、Reactive Extensions（Rx）の構成要素と代数的特性を用いて構築された、分散型リアクティブイベント処理システムです。このシステムは、サービスへの永続的なクエリ（サブスクリプションとして知られています）の送信をサポートしており、このようなクエリは分散型の方法で確実に実行されます。サブスクリプションは、イベントのデータソースとして機能するオブザーバと、イベントのシンクとして機能するオブザーバで構成されます。

Reaqtor is a distributed reactive event processing system built using the constructs and algebraic properties of Reactive Extensions (Rx). It supports the submission of standing queries (known as subscriptions) to a service where such queries are reliably executed in a distributed manner. Subscriptions consist of observables which act as data sources of events, and observers which act as sinks for events.

一般的に使用されるオブザーバには、タイマーやストリームがあり、一般的に使用されるオブザーバには、外部サービスへのHTTPコールを実行したり、イベントをストアに挿入したり、イベントをストリームにパブリッシュしたりするアクションがあります。豊富なクエリ演算子を使って、フィルタリング、プロジェクション、アグリゲーション、マージ、ジョインティング、ウィンドウウィングなどの構成を適用し、データソースを変換することができます。

Commonly used observables include timers and streams; commonly used observers include actions that perform HTTP calls to external services, that insert events into stores, or publish events to streams. A rich set of query operators can be used to transform data sources by applying constructs such as filtering, projection, aggregation, merging, joining, windowing, etc.

Reaqtorの最初の開発は、検索エンジンBingやMSNサービスなども担当しているMicrosoftのオンラインサービス部門で2013年頃から始まりました。Reaqtorは、Cortana、MSN、Office 365などのファーストパーティのお客様の様々なシナリオを実現してきました。Reaqtorのサービス展開の中には、毎秒数千のイベントを処理する数十億のイベント処理クエリを処理するものもあり、多くの場合、数100台の物理ノードを持つ比較的小規模なクラスタを使用しています。

The first development of Reaqtor started around 2013 in the Online Services Division at Microsoft, which also is responsible for the Bing search engine, MSN services, etc. Reaqtor has powered a variety of scenarios for first party customers such as Cortana, MSN, Office 365, and more. Some of the Reaqtor service deployment handle upwards of billions of standing event processing queries processing thousands of events per second, often using relatively small clusters with a few 100s of physical nodes.

Reaqtorの最大の強みは、高密度のアドホックなイベント処理をサポートしていることです。何十億ものユニークなクエリがほぼリアルタイムでイベントを処理していますが、これらはすべて、オブザーバブル・シーケンスとRxスタイルのクエリ演算子というシンプルかつ強力な代数に基づいています。カスタムのオブザーバやオブザーバの実装による拡張性により、他の "リアクティブ "なクラウドサービスとの橋渡しが可能です。

One of the biggest strengths of Reaqtor is its support for high-density adhoc event processing, where billions of unique queries are processing events in near real-time, all based on the simple but powerful algebra of observable sequences and Rx-style query operators. Its extensibility with custom observable and observer implementations enables bridging with other “reactive” cloud services.