在谷歌协作平台上使用Apache Cassandra
我只需要一种选项,
我使用它在我的Colaboratory上进行练习的设置备忘录。
参考资料
安装Cassandra
ipynb的描述要怎么样才会感觉好呢?
通过运行 !java -version 命令确认,得知安装了 openjdk version “11.0.11” 2021-04-20 版本,因此还需要安装 OpenJDK 8。
import os
#apt-getで入れた場合、ディレクトリ作成されない場合があるので、追加
new_dir = '/run/cassandra'
os.makedirs(new_dir, exist_ok=True)
!apt-get install openjdk-8-jdk-headless -qq > /dev/null
!echo "deb http://downloads.apache.org/cassandra/debian 40x main" | sudo tee -a /etc/apt/sources.list.d/cassandra.sources.list
!curl https://downloads.apache.org/cassandra/KEYS | sudo apt-key add -
!sudo apt-get update -qq
!sudo apt-get install -qq cassandra > /dev/null
!pip install -q -U cassandra-driver
import os
os.environ["JAVA_HOME"] = "/usr/lib/jvm/java-8-openjdk-amd64"
#colabratoryだとユーザはrootなのでオプション付きで起動する。
!cassandra -R -p /run/cassandra/cassandra.pid > /dev/null
!nodetool status
成效、終點、結局、結論、結過去、終於、結果、果實、果然、居因果、衍生、發揮、至結、到頭來、到底、結尾、決定
Datacenter: datacenter1
=======================
Status=Up/Down
|/ State=Normal/Leaving/Joining/Moving
-- Address Load Tokens Owns (effective) Host ID Rack
UN 127.0.0.1 68.9 KiB 16 100.0% 8d69312c-7b81-4543-a6c6-e8abf3a0a85c rack1
停下来
!kill `cat /run/cassandra/cassandra.pid`
数据库创建等
import cassandra
from cassandra.cluster import Cluster
try:
cluster = Cluster(['127.0.0.1']) #If you have a locally installed Apache Cassandra instance
session = cluster.connect()
except Exception as e:
print(e)
try:
session.execute("""
CREATE KEYSPACE IF NOT EXISTS my_db
WITH REPLICATION =
{ 'class' : 'SimpleStrategy', 'replication_factor' : 1 }"""
)
except Exception as e:
print(e)
try:
session.set_keyspace('my_db')
except Exception as e:
print(e)
接下来,继续执行”CREATE TABLE IF NOT EXISTS my_db”语句,创建表。
概述
我认为,由于Cassandra的启动需要一点时间,所以这样的轻松感觉还是挺好的。