問題タブ [wso2cep]

カスタム関数に params を渡し、それを取得したい場合は、次のようにする必要があります。

しかし、30 個のパラメーターがある場合、このプロセスをほぼ 30 回繰り返す必要があり、入力パラメーターで何かが変更された場合は、インデックスも変更する必要があります。だから私の質問は、彼らの名前でカスタム機能でパラメータを取得することは可能ですか? たとえば、次のようにします。

Transformerでも同様のことができますが、Functionでは可能ですか？

1 時間あたりのイベント数を持つ timeseries を実装しようとしています。CEP で 1 時間ごとのカウントを行い、出力を datastore/nosql に保存したいと考えていました。不足しているのは、特定の日の 1 時間ごとのカウントを保存したかったことです。

このためには、タイムバッチ ウィンドウが期限切れになるたびに、CEP から現在のタイムスタンプを出力する必要があります。

誰かがWSO2 CEPでこれを達成する方法を説明できますか??

ありがとうRP

私は userStream を持っていますusername,ipaddress,timestamp

UserDetailsTableこの詳細を（メモリ内テーブルに）保存したいので、 upsertを実行する必要があります。ユーザー名と ipaddress が同じ場合に行を更新し、それ以外の場合は新しい行として挿入するにはどうすればよいでしょうか。

例えば：

UserDetailsTable の結果は以下のとおりです

(CEP) WSO2 アダプタのログインとパスワードでは、次のように記述する必要があります。

ログインとパスワードをエンコードし、管理者/管理者の代わりにMD5などのエンコードされたパラメーターを書き込むことは可能ですか?

Wso2 CEP (3.1.0) で新しいユーザーを追加する必要があります。コンソールでいくつかの手順を「クリック」することでそれが可能であることを知っています (ドキュメントの例)。コンソールにログインせずに新しいユーザーを追加できるかどうか疑問に思っていますが、H2 データベースに接続してそこにユーザーを挿入しますか?

新しいユーザーが「UM_USER」テーブルに保存されることはわかっています。たぶん、誰かがH2にユーザーを書き込むクラス、パスワードが暗号化される方法、「UM_SALT_VALUE」とは何か、そしてなぜそれが必要なのかを知っているでしょうか?

Solace メッセージング システムと WS02 CEP の統合を実装しようとしています。

既存の直接接続統合はありますか? または、これら 2 つを統合するために別のレイヤー (Active MQ) を使用できますか? 可能であれば、ドキュメントを共有していただけますか。

MQTT パブリッシャーがあるシナリオがあります。

MQTT クライアント --> メッセージ ブローカ --> WSO2 CEP (JMS 入力アダプタ)

この公開された MQTT メッセージを WSO2 CEP への入力として取得するには、どのような方法がありますか?

ActiveMQ をメッセージ ブローカーとして使用し、JMS メッセージをリッスンする CEP JMS 入力アダプターを使用しようとしましたが、ActiveMQ は MQTT メッセージを ByteMessage として変換します。同じセットアップで公開された JMS メッセージが正常に動作しているため、現時点では CEP はそれを処理しないと思います。
WSO2 CEP 4.0.0 には MQTT 入力アダプターの機能があることは知っています。CEP 3.1.0 でどのように処理できますか?

現在、私はアーキテクチャを構築するためにオープン ソースのエンティティ サービス バス (ESB) を見つけたいと思っています。Google で検索したところ、WSO2 ESB で十分であることがわかりました。すべての WSO2 関連製品の中で、WSO2 ESB 製品のみがベンチマークされています。製品の性能が残っています。リアルタイムの世界で最新の ESB の性能についてアドバイスをいただければと思います。