How to Use Cassandra DB with Python: A Beginners Guide

21.11.2024

Getting Started with Cassandra DB and Python

Cassandra is a popular NoSQL database that is known for its scalability and high availability. In this guide, we will walk you through the process of using Cassandra with Python, a powerful programming language that is commonly used for web development.

CPDC Class 01 | Cassandra Database | Creating Application in PEGA ...

1. Installing Cassandra

The first step is to install Cassandra on your machine. You can download the latest version of Cassandra from the official website and follow the installation instructions provided. Make sure to start the Cassandra service before proceeding.

End To End LLM Langchain Project using Pinecone Vector …
Dec 4, 2023 … Build a PDF Document Question Answering LLM System With Langchain,Cassandra,Astra DB,Vector Database … Vector Database Tutorial FOR Beginners …

2. Connecting to Cassandra with Python

Next, you will need to install the cassandra-driver package, which is the official Python driver for Cassandra. You can install it using pip:

pip install cassandra-driver

Once the driver is installed, you can connect to your Cassandra cluster using the following code:

from cassandra.cluster import Cluster  cluster = Cluster(['localhost']) session = cluster.connect('your_keyspace')

3. Creating a Keyspace and Table

Before you can start storing data in Cassandra, you need to create a keyspace and a table. Here is an example of how you can do this:

session.execute("CREATE KEYSPACE IF NOT EXISTS my_keyspace WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}") session.execute("USE my_keyspace") session.execute("CREATE TABLE IF NOT EXISTS my_table (id UUID PRIMARY KEY, name TEXT, age INT)")

4. Inserting Data

Now that you have created a table, you can start inserting data into it. Here is an example of how you can insert a row into the table:

from uuid import uuid4  id = uuid4() name = "Alice" age = 30  session.execute("INSERT INTO my_table (id, name, age) VALUES (%s, %s, %s)", (id, name, age))

5. Querying Data

Once you have inserted data into your table, you can query it using CQL (Cassandra Query Language). Here is an example of how you can retrieve all rows from the table:

rows = session.execute("SELECT * FROM my_table")  for row in rows:     print(row.id, row.name, row.age)

6. Updating and Deleting Data

You can also update and delete data in Cassandra using CQL. Here are examples of how you can update and delete a row in the table:

session.execute("UPDATE my_table SET age = 31 WHERE id = %s", [id]) session.execute("DELETE FROM my_table WHERE id = %s", [id])

7. Handling Errors

When working with Cassandra, it is important to handle errors properly. You can use try-except blocks to catch and handle exceptions that may occur during database operations.

8. Closing the Connection

Finally, make sure to close the connection to Cassandra once you are done with your operations:

cluster.shutdown()

By following this guide, you should now have a good understanding of how to use Cassandra with Python to build scalable and reliable applications.

Yan Hadzhyisky

fullstack PHP+JS+REACT developer