Spark + cassandra:如何创建密钥空间？

Question

我正在经历pyspark_cassandra.

但是我没有看到任何创建表/键空间的方法=>有可能吗？

如果是这样,怎么样？

Answer 1

也许你可以试试这个包？

该软件包来自 DataStax，它是 Python 的 Cassandra 驱动程序。

Github： https: //github.com/datastax/python-driver

API文档： https://datastax.github.io/python-driver/api/cassandra/cluster.html

from cassandra.cluster import Cluster
cluster = Cluster(['your_cassandra_ip'])
session = cluster.connect()

session.execute('CREATE KEYSPACE IF NOT EXISTS mykeyspace WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 3 };')