Cassandra notes

1-setup.txt

sudo apt-get install -y openjdk-6-jdk
wget http://apache.tradebit.com/pub//cassandra/1.0.7/apache-cassandra-1.0.7-bin.tar.gz
openssl sha1 apache-cassandra-1.0.7-bin.tar.gz
# SHA1(apache-cassandra-1.0.7-bin.tar.gz)= 8ae535821b29eead5b7dc7788a0e66ecf1ac267e
tar xzf apache-cassandra-1.0.7-bin.tar.gz
rm apache-cassandra-1.0.7-bin.tar.gz
mv apache-cassandra-1.0.7 cassandra

cassandra/conf/cassandra.yaml
  RandomPartitioner -> ByteOrderedPartitioner
  listen_address: ...IP on local network...
  rpc_address: ...IP on local network...

sudo mkdir /var/lib/cassandra
sudo chown YOUR_USER /var/lib/cassandra

# try it in the foreground
bin/cassandra -f

# k, spawn it as a daemon
bin/cassandra

2-CREATE.txt

bin/cassandra-cli -host localhost -port 9160

CREATE KEYSPACE Events;
USE Events;
CREATE COLUMN FAMILY Events WITH comparator = BytesType AND compression_options = {sstable_compression:SnappyCompressor};

3-pycassa.py

# sudo pip install pycassa

# Automatic failover and operation retries
# Connection pooling
# Multithreading support
# A batch interface

import pycassa

pool = pycassa.ConnectionPool('SomeKeyspace', server_list=["192.168.123.456"])
cf = pycassa.ColumnFamily(pool, 'SomeColfam')
cf.insert('row1', {'col1':'val1'})
cf.get('r1')

# http://pycassa.github.com/pycassa/api/pycassa/columnfamily.html#pycassa.columnfamily.ColumnFamily.get_range
for k, cols in cf.get_range(...):