Spring Batch 5 with Cassandra DB

kiz8lqtg  于 10个月前  发布在  Cassandra
关注(0)|答案(1)|浏览(119)

对不起,我是全新的“ Spring 批”。我的要求是,我需要创建Spring Batch 5项目,该项目从cassandra db读取行(以免说表中特定状态的记录),处理它(重新发送Kafka通知,更新状态和时间戳)并将其写回cassandra db。
除了这篇https://github.com/mohdnadeemakhtar/Spring-Batch-with-Cassandra,我找不到任何使用cassandra的spring batch的文章

我无法为cassandra db提供“数据源”。那真的有可能达到我的要求吗?除了“春批”,我们还有其他建议吗?

我需要创建这个应用程序的一个jar,并安排它作为一个工作,每15分钟/30分钟在服务器上运行。(目前没有太多关于这一部分的内容)
在此之前,我试图通过扩展Spring batch 3.. 版本的“AbstactCassandraConfiguration”来提供cassandra配置,但效果也不好!

yacmzcpb

yacmzcpb1#

真的有可能达到我的要求吗?

这是完全可能的。

除了“春批”,我们还有其他建议吗?

我会将第三方集成(Cassandra / Kafka)与运行时本身隔离开来。
对于运行时,Spring Batch将工作。您还可以考虑使用Spring camel应用程序。它提供所有连接和轮询器。

Cassandra连接

您将依赖Spring Data Cassandra。
您可以从AbstractCassandraConfiguration创建extend,或者创建自己的CqlSession bean,提供信息(ip,port,credentials,keyspace...)。Cassandra不是关系数据库,使用Datasources或JDBC绝对不是推荐的方法。
shared的链接非常好(除了不需要使用JDBC)。Cassandra连接上的AbstractCassandraConfiguration有什么错误?这里有些explanations
创建自定义CqlSession bean this article是一个很好的资源。

相关问题