問題タブ [complex-event-processing]

2 ノードの WSO2 CEP クラスターがあります。

イベントを thrift 経由で CEP クラスターに送信したいと考えていました。クライアント側で Wso2 データブリッジ - DataPublisher を使用しています。thrift over 1 つの CEP にイベントを送信することはできますが、イベントをクラスターに送信する方法がわかりません。

コンマ区切りのリサイクル URL を使用してみましたが、DataPublisher は MalformedURLException で失敗しますか?

助言がありますか ？

ありがとうラジブ・パチル

BAMに表示したいCEPを使用してデータを分析しました。

KPIアナライザーサンプルを使用しています

BAMで表示することはできますか？はいの場合、どのように進めればよいですか？

注文が成功したかどうかを示す EPL ステートメントを作成しようとしています。

ステートメントは、購入の ID に基づいて、購入と支払いを照合する必要があります。結果には、購入の ID と、購入が支払いと一致したかどうかを示すブール値が含まれている必要があります。

以下のステートメントは、一致が成功したときに true を返します。ただし、購入が支払いに一致せずに 30 秒の時間枠を終了した場合にも false を返したいと思います。

また、イベントが発生する順序が問題にならないのもいいでしょう。たとえば、支払いが購入前に行われた場合。

BrokerType と BrokerTypeFactory を拡張して、新しい Broker を実装しました。この新しい Broker を WSO2 CEP にデプロイしたかったのです。broker.xml を作成し、repository/conf ディレクトリに配置しました

ただし、これにより、Web コンソールの Broker List ページを参照すると NullPointer 例外 (BrokerManagerAdminServer の 149 行目) が発生し、ブローカーが表示されません。既存のブローカーに影響を与えずに新しいブローカーを展開する方法を理解するのを手伝ってくれませんか?

backEND-Runtime として esper で WSO2 CEP-Server を使用しています。WSO2 は cassandra を使用して siddhi(backEnd-runtime) で永続性を提供しています。ESPER-CEP エンジンで永続性を実装する必要があります。どんな考えでもいただければ幸いです。

私は、SOA でのイベント処理とビジネス アクティビティの監視に取り組んでいます。WSO2-BPS の実行中に、WSO2-CEP や WSO2-BAM を実行したいと考えています。しかし問題は、ビジネス プロセスを実行するために WSO2-BPS を実行すると、WSO2-CEP や WSO2-BAM を実行できず、それらの管理コンソールにアクセスできないことです。私を助けてください。ありがとう！

Maninda さん、素早い対応に感謝します。実は、私はルール エンジンを監視したくありません。私がやりたいことは、BPEL プロセス (サービス構成レイヤー) と、サービス インフラストラクチャ レイヤーと呼ばれる基礎となるサービス インフラストラクチャ (Tomcat、Web サービス自体、BPEL エンジンなど) を監視し、KPI を分析することです。 (BAM を使用) およびプロセス メトリック (CEP を使用) を使用して、KPI とメトリックの間の相関関係を見つけ、ビジネス プロセス (この場合は BPEL) をプロアクティブまたはリアクティブに適応させようとします。ビジネス ルールの管理 (Rules Esngine を使用)。
それらすべてまたは少なくともそれらのほとんどをカバーするサンプルはありますか? または他のアイデア？お時間とご関心をお寄せいただきありがとうございます。

BPEL プロセスを監視し、実行中の BPEL プロセスで BAM、ルール処理、および CEP を実行し、必要に応じて適応させたいと考えています。BPEL、BAM、CEP、およびルール エンジンをカバーするケース スタディまたはサンプルはありますか? 私は何をすべきか？前もって感謝します。

私はWSO2-CEPをEsper（ランタイムとして）で使用しています。Esperはマップ上のクエリをタプルのsiddhiとして処理しました。「入力マッピングタイプ」は基本的に、XMLマッピング：XMLからマップまたはタプルなどに必要な入力変換のタイプを宣言します。 xmlイベントをマップに変換してサンプルを実行しますが、「入力イベントとしてマップ」があり、それらをマップのみとして処理したい場合はどうなりますか？どんな助けでもいただければ幸いです!!

シーケンスで欠落しているイベントを検出するクエリをcep/siddhiで定義したいと思います。

5分以内に発生しなければならない4つのイベントがあります。（3000以内のp1-> p2-> p3-> p4）

p1が発生してから5分以内にp2、P3、またはP4のいずれかが欠落している場合にアラートイベントを挿入する条件を作成するにはどうすればよいですか？

ありがとう。

私は Drools の初心者です。ここでは、プロセスが一定時間以上実行されている場合に通知を生成しようとしています - 5 分としましょう。

上記を実現するために、DRL ファイルに次のコードを記述しています。しかし、それは機能していないようです。

drl ファイル

上記の.drlファイルには、Message宣言されたという名前のイベントがあります。ルールは 5 分間実行されているかどうかをチェックmsgtextし1st messageています。その場合は、通知を生成する必要があります。この例では、結果を出力しているだけです。

前もって感謝します。私はあなたの助けに感謝します。

このサンプルのデプロイに問題があります: 「SOA を使用した複雑なイベント処理とビジネス ルール管理」(リンク: http://wso2.org/library/articles/2011/07/complex-event-processing-business-rule-management ) -ソア)

"cepSample.xml"すべての詳細を実行しましたが、ファイルをその場所にコピー"wso2esb-4.6.0/repository/deployment/server/synapse-configs/default/proxy-services"すると、コンソールに次のエラーが表示され、デプロイされません: /WSO2/wso2esb-4.6.0/repository/deployment/server/synapse-configs/default/proxy-services/cepSample.xml failed - Continue in fail-safe mode org.apache.synapse.SynapseException: The 'name' attribute is required for a Proxy service definition