Spark + cassandra: как создать пространство ключей?

Question

Я иду через pyspark_cassandra.

Но я не вижу никакого способа создать таблицу/keyspace => возможно ли вообще?

Если да, то как?

Answer 1

Возможно, вы сможете попробовать этот пакет?

Этот пакет от DataStax, который является драйвером Cassandra для python.

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 };')