在谷歌协作平台上使用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的启动需要一点时间,所以这样的轻松感觉还是挺好的。

广告
将在 10 秒后关闭
bannerAds