### Cassandra 安装与配置 #### 1. 环境准备 为了使 Cassandra 正常工作，在安装前需确保系统已准备好所需的Java开发工具包(JDK)[^3]。对于Python的支持，由于Cassandra特定版本的需求，建议安装Python2.x而非3.x版本，并且需要安装`pip`以便后续管理Python库。 ```bash # 更新yum源并安装必要组件 sudo yum update -y sudo yum groupinstall "Development Tools" -y sudo yum install java-1.8.0-openjdk-devel -y ``` #### 2. Python 版本确认与安装 鉴于某些情况下默认的Python版本可能不符合需求，因此有必要验证现有Python版本是否满足条件；如果不符，则应按照官方指导完成相应版本的安装[^5]： ```bash # 查看当前Python版本 python --version # 如果不是期望的2.x版本则继续下面的操作 cd /usr/src wget https://www.python.org/ftp/python/2.7.12/Python-2.7.12.tgz cd Python-2.7.12 ./configure --prefix=/usr/local/python2.7 make altinstall ln -s /usr/local/python2.7/bin/python2.7 /usr/bin/python2.7 curl https://bootstrap.pypa.io/get-pip.py | python2.7 - ``` #### 3. Cassandra 的安装过程 针对不同操作系统有不同的安装方式，这里主要介绍基于CentOS系统的安装方法[^1]： ##### 3.1 使用YUM仓库安装 这是最简便的方式之一，只需几条简单的命令即可完成整个流程: ```bash echo "[cassandra]" | sudo tee -a /etc/yum.repos.d/cassandra.repo echo "name=Apache Cassandra" | sudo tee -a /etc/yum.repos.d/cassandra.repo echo "baseurl=https://downloads.apache.org/cassandra/redhat/311x/" | sudo tee -a /etc/yum.repos.d/cassandra.repo echo "gpgcheck=1" | sudo tee -a /etc/yum.repos.d/cassandra.repo echo "repo_gpgcheck=1" | sudo tee -a /etc/yum.repos.d/cassandra.repo echo "gpgkey=https://downloads.apache.org/cassandra/KEYS" | sudo tee -a /etc/yum.repos.d/cassandra.repo sudo yum clean all sudo yum install cassandra -y ``` ##### 3.2 手动下载安装包 如果无法通过网络访问上述资源，可以选择手动下载适合操作系统的安装文件[^4]: ```bash # 假设已经下载好了对应的.tar.gz文件至/home/user/downloads/ tar zxvf apache-cassandra-X.Y.Z-bin.tar.gz -C /opt/ export CASSANDRA_HOME=/opt/apache-cassandra-X.Y.Z $CASSANDRA_HOME/bin/cassandra -f ``` #### 4. 启动服务与初始化设置 一旦成功安装完毕，可以通过如下指令来启动或重启Cassandra服务： ```bash sudo systemctl start cassandra sudo systemctl enable cassandra ``` #### 5. Python 编程接口接入 最后一步就是利用Python对接Cassandra数据库了。这通常涉及到使用专门设计用于此目的的数据驱动程序——`cassandra-driver`[^2]。可以借助于前面提到过的`pip`来进行快速安装： ```bash pip install cassandra-driver ``` 随后便可以在项目里引入相应的模块并与远端实例建立连接： ```python from cassandra.cluster import Cluster cluster = Cluster(['127.0.0.1']) session = cluster.connect() rows = session.execute('SELECT * FROM system_schema.keyspaces') for row in rows: print(row.name) ```