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

Question

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

Answer 1

它仍处于 alpha 阶段，但你可以看看这个：https://github.com/cloudspannerecosystem/spanner-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 中。