This is the implementation of the Cassandra data handler for MindsDB.

Cassandra is a free and open-source, distributed, wide-column store, NoSQL database management system designed to handle large amounts of data across many commodity servers, providing high availability with no single point of failure.

​
Prerequisites

Before proceeding, ensure the following prerequisites are met:

  1. Install MindsDB locally via Docker or use MindsDB Cloud.
  2. To connect Apache Cassandra to MindsDB, install the required dependencies following this instruction.
  3. Install or ensure access to Apache Cassandra.

​
Implementation

As ScyllaDB is API-compatible with Apache Cassandra, the Cassandra data handler extends the ScyllaDB handler and uses the scylla-driver Python library.

The required arguments to establish a connection are as follows:

  • host is the host name or IP address of the Cassandra database.
  • port is the port to use when connecting.
  • user is the user to authenticate.
  • password is the password to authenticate the user.
  • keyspace is the keyspace to connect, the top level container for tables.
  • protocol_version is not required and defaults to 4.

​
Usage

In order to make use of this handler and connect to the Cassandra server in MindsDB, the following syntax can be used:

CREATE DATABASE sc
WITH
  engine = "cassandra",
  parameters = {
    "host": "127.0.0.1",
    "port": "9043",
    "user": "user",
    "password": "pass",
    "keyspace": "test_data",
    "protocol_version": 4
  };

You can use this established connection to query your table as follows:

SELECT *
FROM cassandra_datasource.example_table LIMIT 10;