从Spanner读取数据到PubSub Queue的最佳方法是什么？

Question

我需要一个类似于监听器的东西来监听数据库中的变化。一旦发生变化，它就会将更新的行插入到pubSub队列中。最好的方法是什么？

Answer 1

它仍然处于alpha阶段，但你可以看看这个。https:/github.comcloudspannerecosystemspanner-change-watcher.

它是一个通用框架，通过轮询表的新提交时间戳来观察Spanner数据库的变化。它要求您要监视的表必须包含一列带有选项 ALLOW_COMMIT_TIMESTAMP=TRUE 并对这一栏进行填充。

它包含三个主要模块。

1. google-cloud-spanner-watcher: 这是一个观察Spanner数据库变化的通用框架。
2. google-cloud-spanner-publisher: 这使用了上一点的框架，并发布了一个或多个Pubsub主题的所有变化。
3. google-cloud-spanner-archiver: 这是一个从Publisher那里消费消息的例子，它将所有的变化都归档到Google Cloud Storage中。