insert the record in to Cassandra using by Pycassa

import pycassa
from pycassa.index import *
def connect():
"""Connect to a test database"""
connection = pycassa.connect('test', ['localhost:9160'])
db = pycassa.ColumnFamily(connection,'record')
return db

def random_insert(db):
"""Insert a record into the database. The record has the following format
ID timestamp
4 random strings
3 random integers"""
record = {}
record['name'] = 'hiox'
db.insert(str(time.time()), record)

Tagged in:

• cassandra
• pycassa connection
• python