Developer Interface

Client

class pysandra.Client(host=None, use_tls=False, no_compress=False, debug_signal=None)

A Cassandra driver, with an asyncio interface

Usage:

>>> client = pysandra.Client((host,port))
>>> resp = await client.execute("SELECT * FROM uprofile.users")

close(self)

connect(self)

If you wish to start the connection explicitely you can call this method. However, it is not necessary, as the driver will attempt to create a connection at any time if it is needed and not already connected.

execute(*args, **kwargs)

is_connected

is_ready

page_(*args, **kwargs)

prepare(*args, **kwargs)

register(*args, **kwargs)

Rows

class pysandra.Rows(col_specs=None)

This is the container for data queried from cassandra

add_row(self, row)

col_specs