听听Cassandra数据存储区的变化?
我想知道是否有可能为Cassandra添加一个监听器来获取表和更改条目的主键? 拥有这样一个机制会很棒。
检查Cassandra文档我只发现将StateListener添加到Cluster实例。
有没有人知道如何在不破解Cassandras数据存储的情况下执行此操作或封装驱动程序并自行执行某些操作?
看看这个未来的jira – https://issues.apache.org/jira/browse/CASSANDRA-8844
如果你喜欢它投票支持:)
CDC
“在数据库中,变更数据捕获(CDC)是一组软件设计模式,用于确定(和跟踪)已更改的数据,以便可以使用更改的数据执行操作。此外,更改数据捕获(CDC)是一个基于对企业数据源所做更改的识别,捕获和交付的数据集成方法。“ -Wikipedia
随着Cassandra越来越多地被用作大型企业中关键任务数据的记录源(SoR),它越来越多地被要求充当其他系统的流量和数据流的中心枢纽。 为了尝试解决一般需求,我们建议实现一种简单的数据记录机制来启用每个表的CDC模式。
你在寻找像触发器这样的东西吗?
https://github.com/apache/cassandra/tree/trunk/examples/triggers
数据库触发器是过程代码,它自动执行以响应特定表或数据库中的视图上的某些事件。 触发器主要用于维护数据库上信息的完整性。 例如,当一个新记录(代表一个新工人)被添加到雇员表时,还应该在税收,假期和工资表中创建新记录。
如果客户需要了解变化,那么世界大多数都会转向消息代理模型 – 一个连接生产者和消费者任意数据的中间人。 你可以在这里阅读Kafka,RabbitMQ和NATS。 这里有一篇较旧的DZone文章。 在您的情况下,写入数据库的客户端也会发送更改消息。 这个模型有什么好处,你可以从数据库中提取你需要的任何东西。
Kafka很有趣,因为它也可以存储数据。 在某些情况下,您可能完全可以处置数据库。
- 使用Datastax Cassandra驱动程序时重用PreparedStatement?
- cassandra的cqlsh控制台中的操作超时错误
- 防止Cassandra转储hprof文件
- 如何使用Datastax Java驱动程序的异步/批量写入function
- 如何在Cassandra中执行批处理语句和LWT作为事务
- 使用Datastax API(使用新的二进制协议)升级/读入/读取Cassandra数据库
- Apache Spark需要5到6分钟才能从Cassandra中简单计算1亿行
- 考虑将序列化的java对象存储为cassandra作为JSON。 捕获量是多少?
- 为什么Cassandra客户端在没有epoll的情况下失败?