問題タブ [spring-xd]

センサーデータを継続的に取り込むためにSpring XDをしばらく使用していますが、完全に機能しています。

私が持っている新しい要件は、そのデータの一部を「再生」する機能です。私の特定のケースでは、(特定のクエリを使用して) MongoDB から読み取り、エントリの特定のフィールドで UDP パケットを生成し、一定の時間間隔で SocketAddress に送信します。

私が実装している最初の試みは、スプリング バッチ ジョブによるものです。リーダーは MongoDB にデータをクエリするだけなので単純ですが、UDP の部分が気になります。UDP パケットの送信に spring-batch を使用するのは自然なことではありません。そのため、これを実装するためのアイデアを提案できる人がいるかどうかを知りたいです。

ありがとう

MS SqlSpring XDのDAOでHibernateentityManagerFactoryを使用することは可能ですか??

DataSource私のプロジェクトには構成クラスがあり、私のプロジェクトに必要な構成に必要な Bean を書いていますJDBCTemplate。

私もビーンズのようなものを持っています

プロジェクトを Spring XD にデプロイすると、

私は例外を取得します:

次に、spring-boot-starter-data-jpa の依存関係を追加すると、次のような例外が発生しました

提供されるスコープの有無にかかわらず、Spring Boot の依存関係を含めようとしました。依存関係を追加しようとしました

ローカルPOMに。

また、依存関係をSpring XD libフォルダーに直接移動しましたが、それを行った後、例外が発生しました:

そして、hibernate.dialect を設定すると、例外は次のようになります。

16:39:23,344 エラー DeploymentsPathChildrenCache-0 server.ContainerRegistrar - モジュール java.lang.IllegalArgumentException をデプロイする例外: インターフェイス org.springframework.boot.SpringApplicationRunListener をインスタンス化できません: org.springframework.boot.context.event.EventPublishingRunListener org.springframework.boot.SpringApplication.getSpringFactoriesInstances(SpringApplication.java:381) で org.springframework.boot.SpringApplication.getRunListeners(SpringApplication.java:352) で org.springframework.boot.SpringApplication.run(SpringApplication.java:274) ) org.springframework.boot.builder.SpringApplicationBuilder.run(SpringApplicationBuilder.java:142) で org.springframework.xd.module.core.SimpleModule.initialize(SimpleModule.java:203) で org.springframework.xd.dirt. module.ModuleDeployer.deploy(ModuleDeployer.java:98) at org.springframework.xd.dirt.module.ModuleDeployer.deployAndStore(ModuleDeployer.java:88) at org.springframework.xd.dirt.module.ModuleDeployer.deployAndStore(ModuleDeployer. java:78) org.springframework.xd.dirt.server.ContainerRegistrar.deployModule(ContainerRegistrar.java:231) org.springframework.xd.dirt.server.ContainerRegistrar.deployJobModule(ContainerRegistrar.java:530) で org.springframework.xd.dirt.server.ContainerRegistrar.onChildAdded(ContainerRegistrar.java:447) で org.springframework.xd org.springframework.xd.dirt.server.ContainerRegistrar$DeploymentListener.childEvent(ContainerRegistrar.java:826) の .dirt.server.ContainerRegistrar.access$800(ContainerRegistrar.java:95) cache.PathChildrenCache$5.apply(PathChildrenCache.java:509) at org.apache.curator.framework.recipes.cache.PathChildrenCache$5.apply(PathChildrenCache.java:503) at org.apache.curator.framework.listen.ListenerContainer$1 .run(ListenerContainer.java:92) at com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:297) at org.apache.curator.framework.listen.ListenerContainer.forEach(ListenerContainer.java:83) org.apache.curator.framework.recipes.cache.PathChildrenCache.callListeners(PathChildrenCache.java:500) org.apache.curator.framework. Recipes.cache.EventOperation.invoke(EventOperation.java:35) org.apache.curator.framework.recipes.cache.PathChildrenCache$10.run(PathChildrenCache.java:762) で java.util.concurrent.Executors$RunnableAdapter.call (Executors.java:471) で java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) で java.util.concurrent.FutureTask.run(FutureTask.java:166) で java.util.concurrent で。 Executors$RunnableAdapter.call(Executors.java:471) で java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) で java.util.concurrent.FutureTask.run(FutureTask.java:166) で java .util.concurrent.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) の ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) java.lang.Thread.run(Thread.java:722) の原因: java.lang .IllegalArgumentException: クラス org.springframework.boot.context.event.EventPublishingRunListener は、org.springframework.util.Assert.isAssignable(Assert.java:369) で org.springframework.util.SpringApplicationRunListener のインターフェイス org.springframework.boot.SpringApplicationRunListener に割り当てられません。 .Assert.isAssignable(Assert.java:352) at org.springframework.boot.SpringApplication.getSpringFactoriesInstances(SpringApplication.java:375) ... 29 詳細lang.IllegalArgumentException: クラス org.springframework.boot.context.event.EventPublishingRunListener は、org.springframework の org.springframework.util.Assert.isAssignable(Assert.java:369) のインターフェース org.springframework.boot.SpringApplicationRunListener に割り当てられません。 util.Assert.isAssignable(Assert.java:352) at org.springframework.boot.SpringApplication.getSpringFactoriesInstances(SpringApplication.java:375) ... 29 詳細lang.IllegalArgumentException: クラス org.springframework.boot.context.event.EventPublishingRunListener は、org.springframework の org.springframework.util.Assert.isAssignable(Assert.java:369) のインターフェース org.springframework.boot.SpringApplicationRunListener に割り当てられません。 util.Assert.isAssignable(Assert.java:352) at org.springframework.boot.SpringApplication.getSpringFactoriesInstances(SpringApplication.java:375) ... 29 詳細getSpringFactoriesInstances(SpringApplication.java:375) ... 29 もっと見るgetSpringFactoriesInstances(SpringApplication.java:375) ... 29 もっと見る

この Exception の原因を特定できる人はいますか?

SPRING-XD を使用した上記の作業例に関するヘルプは、非常に高く評価されています。

ありがとう

多くのバッチ ジョブを Spring XD M5 から 1.0.0 リリースに移行しています。

ジョブを作成してデプロイするとき、Spring Data リポジトリ (この場合は Neo4J 用) を自動接続するときに、cglib プロキシ機能で問題が発生します。

スタック トレースの末尾:

Spring Data リポジトリ インターフェイスには、次のような注釈が付けられて@Repositoryいます。

そして、例外をトリガーする Bean クラスの対応する autowired 属性:

Bean 自体は、XD ジョブ XML で次のように定義されています。

構成 Bean (ジョブ cfg XML でスキャンされたコンポーネント):

XD lib フォルダーにデプロイする Spring Data Neo4J のバージョンは次のとおりです。

セットアップはすべて、XD が分散モードで実行されている開発用 PC で行われます (現時点では)。

• レディスサーバー
• Zookeeper サーバー (1x)
• Oracle ジョブ リポジトリ (現時点ではローカル XE インスタンス)
• 1x 管理者と 1x コンテナ

ジョブ、Spring Data リポジトリ、または XD コンテナーの構成に関するヘルプをいただければ幸いです。

ありがとう

POC を実行するために spring xd をインストールしました。私の最初の目標は、すべてのアプリケーション サーバーに spring xd をインストールし、その日のログを収集して、NFS マウント内の場所にダンプすることです。ディストリビューション モードで spring xd をセットアップしました。私のストリームは次のようになります

stream create --name teststream --definition "ファイル --dir= | ファイル --dir ="

現在の日付に基づいて、ファイル シンクをディレクトリにダンプする必要があります。例 /tmp/xd/output_9242014

どうすればこれを達成できますか? 今日利用できる日付関数はありますか? 助けてください

Spring XD の回復セマンティクスは何ですか。私は公開されているすべてのリソースを調べましたが、まだ明確な答えを得ることができません.

私の質問を詳しく説明し、簡単にします。

a) ソースに障害が発生するとどうなりますか?

b) プロセッサに障害が発生するとどうなりますか?

c) シンクに障害が発生するとどうなりますか?

Apache Spark ストリーミングが適しているユース ケースと、Spring XD ストリームが最適な状況を探しています。

ここに技術の重複はありますか？両方が使用されている状況に遭遇した人はいますか?

コネクテッドカーに関するこの Spring XD デモに出会いました - 興味深いと思いました ( https://www.youtube.com/watch?v=qkm2GV57hzY )。

ソース コードが OSS であるかどうか、github かどこかで入手できるかどうか。