Google Cloud Pub/Sub 到 Datastax Cassandra（在 Google Cloud 中）答案

【问题标题】：Google Cloud Pub/Sub to Datastax Cassandra( In Google Cloud)Google Cloud Pub/Sub 到 Datastax Cassandra（在 Google Cloud 中）
【发布时间】：2016-11-17 13:50:30
【问题描述】：

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

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

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

Pub/Sub 是否可以将数据加载到 Google Cloud 上的 Datastax 中？

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

谢谢，

【问题讨论】：

Read the messages using pub/sub and load it into Datastax on Google Cloud的可能重复

标签： google-cloud-platform google-cloud-pubsub

【解决方案1】：

没有自动方式将数据从 Google Cloud Pub/Sub 加载到 Datastax。您必须创建一个订阅并编写从该订阅获取消息的订阅者代码，然后将它们写入 Datastax。 quickstart guide 可能是开始执行必要步骤的好地方。

【讨论】：

【解决方案2】：

一种方法是让 Dataflow 管道（以流模式运行）从 Pub/Sub 读取并写入 Cassandra。 Dataflow 还没有内置的 Cassandra 接收器（尽管 one is in the works 作为 Apache Beam 的一部分），但您的用例在 Dataflow ParDo 中写入 Cassandra 可能就足够了。

【讨论】：