Table of Contents
List of Examples
host and port parametersTable of Contents
Apache Cassandra is an open source distributed database management system. It is designed to handle very large amounts of data spread out across many servers. It is a NoSQL solution.
The module allows the insertion and retrieval of information from Cassandra clusters. This is not a DB driver module.
Inserts the value for the given key, column, column_family and keyspace. There must be an existing keyspace called 'keyspace' with a column_family called 'column_family' in the targeted Cassandra node.
Return integer needs to be checked:
ret < 0, error
ret > 0, success
Retrieves the value for the given key, column, column_family and keyspace. There must be an existing keyspace called 'keyspace' with a column_family called 'column_family' in the targeted Cassandra node.
value will be returned as well as a integer return code.
Return integer needs to be checked:
ret < 0, error
ret > 0, success
Example 1.2. Example usage
...
loadmodule "ndb_cassandra.so"
# (...)
modparam("ndb_cassandra", "host", "10.22.22.190")
modparam("ndb_cassandra", "port", 9160)
# (...)
xlog("L_DBG", "Testing ndb_cassandra module.");
# Inserting to cassandra
$var(keyspace) = "indigital";
$var(column_family) = "employees";
$var(column) = "name";
$var(val_write) = "TestMyName"; # To be written
if (cass_insert("$var(keyspace)", "$var(column_family)", "$ru", "$var(column)", "$var(val_write)") > 0) {
xlog("L_DBG", "ndb_cassandra. Sucess while inserting to Cassandra. val_write: \"$var(val_write)\"");
} else {
xlog("L_DBG", "ndb_cassandra. Error while inserting to Cassandra");
}
# Retrieving from cassandra
$var(keyspace) = "indigital";
$var(column_family) = "employees";
$var(key) = "sip:10.22.22.110"; # Before we saved our $ru, which was 'sip:10.22.22.110'
$var(column) = "name";
$var(val_read) = ""; # To be read
if (cass_retrieve("$var(keyspace)", "$var(column_family)", "$var(key)", "$var(column)", "$var(val_read)") > 0) {
xlog("L_DBG", "ndb_cassandra. Sucess while reading from Cassandra. val_read: \"$var(val_read)\"");
} else {
xlog("L_DBG", "ndb_cassandra. Error while reading from Cassandra");
}
...