cassandra的安装与使用

1.安装cassandra

#下载bin包
wget http://apache.mirror.testserver.li//cassandra/0.6.5/apache-cassandra-0.6.5-bin.tar.gz
#解压
tar xzvf apache-cassandra-0.6.5-bin.tar.gz
#创建目录
sudo mkdir -p /var/log/cassandra
sudo chown -R `whoami` /var/log/cassandra
sudo mkdir -p /var/lib/cassandra
sudo chown -R `whoami` /var/lib/cassandra
#前台运行cassandra
bin/cassandra -f
#cli连接测试
bin/cassandra-cli --host localhost --port 9160
#出现如下信息表示安装成功
   Connected to localhost/9160
   Welcome to cassandra CLI.

   Type 'help' or '?' for help. Type 'quit' or 'exit' to quit.
   cassandra>

2.安装thrift

#下载源码包
wget http://apache.mirror.testserver.li//incubator/thrift/0.4.0-incubating/thrift-0.4.0.tar.gz
#解压
tar xzvf thrift-0.4.0.tar.gz
#安装需要的包
sudo apt-get install libboost-dev automake libtool flex bison pkg-config g++
#安装python包（因为我要用python开发）
sudo apt-get install python-dev
#安装
./bootstrap.sh
./configure
make
sudo make install
#安装python库
cd lib/py
sudo python setup.py install

3.安装python库

#安装setuptools
wget http://pypi.python.org/packages/source/s/setuptools/setuptools-0.6c11.tar.gz#md5=7df2a529a074f613b509fb44feefe74e
tar xzvf setuptools-0.6c11.tar.gz
cd setuptools-0.6c11/
sudo python setup.py install
#安装python-cassandra
wget http://pypi.python.org/packages/source/p/python-cassandra/python-cassandra-0.6.1.tar.gz#md5=cfffb96329dd2acc5a75d0f2126a38a6
tar xzvf python-cassandra-0.6.1.tar.gz
cd python-cassandra-0.6.1/
sudo python setup.py install

4.OK,现在可以用python来访问cassandra了

#编写测试程序CassanTest.py
#!/usr/bin/env python # encoding: utf-8
"""Sample Cassandra Client

Created by Chris Goffinet on 2009-08-26."""

from thrift import Thrift
from thrift.transport import TTransport
from thrift.transport import TSocket
from thrift.protocol.TBinaryProtocol import TBinaryProtocolAccelerated
from cassandra import Cassandra
from cassandra.ttypes import *
import time
import pprint

def main():

     socket = TSocket.TSocket("localhost", 9160)
     transport = TTransport.TBufferedTransport(socket)
     protocol = TBinaryProtocol.TBinaryProtocolAccelerated(transport)
     client = Cassandra.Client(protocol)
     pp = pprint.PrettyPrinter(indent=2)
     keyspace = "Keyspace1"
     column_path = ColumnPath(column_family="Standard1", column="email")
     key = "1"
     value = "foobar@example.com "
     timestamp = time.time()
     try:
         transport.open()
         #Insert the data into Keyspace 1
         client.insert(keyspace,
                       key,
                       column_path,
                       value,
                       timestamp,
                       ConsistencyLevel.ZERO)
         #Query for data
         column_parent = ColumnParent(column_family="Standard1")
         slice_range = SliceRange(start="", finish="")
         predicate = SlicePredicate(slice_range=slice_range)
        result = client.get_slice(keyspace,
                                   key,
                                   column_parent,
                                   predicate,
                                   ConsistencyLevel.ONE)
         pp.pprint(result)
   except Thrift.TException, tx:
       print 'Thrift: %s' % tx.message
     finally:
         transport.close()

if __name__ == '__main__':
main()

#运行它

python CassanTest.py
[ ColumnOrSuperColumn(column=Column(timestamp=1286382520, name='email', value='foobar@example.com '), super_column=None)]

参考：

http://wiki.woodpecker.org.cn/moin/ApacheCassandra

http://wiki.apache.org/thrift/GettingUbuntuPackages

http://wiki.apache.org/thrift/ThriftInstallation