gistfile1.py

from twisted.application.internet import TCPClient
from telephus.protocol import ManagedCassandraClientFactory
from telephus.client import CassandraClient

class Service(TCPClient):
    
    def __init__(self, keyspace=None, host="localhost", port=9160, delegate=None):
        f = ManagedCassandraClientFactory(keyspace)
        delegate.set_client(CassandraClient(f))
        TCPClient.__init__(self, host, port, f)