使用 pub/sub 读取消息并将其加载到 Google Cloud 上的 Datastax

Question

我在 Google 云上部署了一个 9 节点 Datastax 集群。

现在我被要求从 QUEUE 读取数据并加载到谷歌云上的 Datastax（继续流式传输）。

我知道 pub/sub 可以从 QUEUE 读取数据，但不确定是否可以直接加载到 Datastax。

发布/订阅是否可以将数据加载到谷歌云上的Datastax 中？

我是 pub/sub 新手，所以不知道从哪里开始或如何开始。

谢谢，

Answer 1

您可能需要自定义代码来执行此操作。您将拥有一个消费者来从您感兴趣的主题中获取消息，然后您将拥有自定义代码来转换这些消息并将它们加载到 Datastax 上。我假设 Datastax 有一个 API。