Googleクラウドpub/subからDatastax Cassandra（Googleクラウド）

Question

Google Cloudに9ノードDatastax Clusterを導入しました。

私はQUEUEのデータを読み込み、GoogleクラウドのDatastax（読み込み続行）に読み込む必要があります。

私はpub/subがQUEUEからデータを読み取ることができますが、Datastaxに直接ロードできるかどうかはわかりません。

pub/subがGoogleクラウドのDatastaxにデータを読み込むことは可能ですか？

私はどこから始めればまたは起動する方法をパブリッシュ/サブスクライブに新しいので、確認していません。

おかげで、

Answer 1

DatastaxにGoogleクラウドパブ/サブからデータをロードするための自動的な方法はありません。サブスクリプションを作成し、このサブスクリプションからのメッセージを取得してDatastaxに書き込むサブスクライバコードを記述する必要があります。 はおそらく、必要な手順を開始するのに適しています。

Answer 2

1つの方法は、Pub/Subから読み込んでCassandraに書き込むDataflowパイプライン（ストリーミングモードで実行）を作成することです。データフローのための組み込みのCassandraシンクはありません（ただしApache Beamの一部としてone is in the works）が、データフローParDoのCassandraに書き込むだけで十分です。