Spark + cassandra:如何创建键空间?

Posted

技术标签:

【中文标题】Spark + cassandra:如何创建键空间?【英文标题】:Spark + cassandra : how to create a keyspace? 【发布时间】:2017-04-28 19:00:18 【问题描述】:

我正在通过pyspark_cassandra。

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

如果是这样,怎么做?

【问题讨论】:

【参考方案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 ;')

【讨论】:

以上是关于Spark + cassandra:如何创建键空间?的主要内容,如果未能解决你的问题,请参考以下文章

如果键空间不存在,Cassandra 连接到集群

如何使用 R 在 cassandra 中创建键空间和表?

如何动态设置 Spring Data Cassandra 键空间?

Cassandra system_schema 键空间在创建表时不是用户可修改的

Cassandra 多个键空间或列族?

Spark Cassandra 连接器 - 分区键上的范围查询