파이썬으로 카산드라 데이터베이스와 상호작용하기: cassandra-driver

cassandra-driver는 Apache Cassandra 데이터베이스와 상호작용하기 위한 파이썬 드라이버입니다. 이 드라이버를 사용하면 파이썬 애플리케이션에서 Cassandra 클러스터에 연결하여 데이터를 쿼리하고 조작할 수 있습니다. 아래는 cassandra-driver의 주요 기능과 사용법을 살펴보겠습니다.

기능 1: 클러스터에 연결

cassandra-driver를 사용하여 Cassandra 클러스터에 연결할 수 있습니다. 이를 통해 데이터베이스에 대한 쿼리 및 조작을 수행할 수 있습니다.

예제 1: 클러스터에 연결하기

from cassandra.cluster import Cluster

cluster = Cluster(['127.0.0.1'])  # 카산드라 클러스터 주소 설정
session = cluster.connect()  # 세션 생성

rows = session.execute("SELECT * FROM keyspace.table")  # 쿼리 실행
for row in rows:
    print(row)

기능 2: 데이터 쿼리 및 조작

cassandra-driver를 사용하여 Cassandra 데이터베이스에서 데이터를 쿼리하고 조작할 수 있습니다. SQL과 유사한 CQL(Cassandra Query Language)을 사용하여 데이터를 처리할 수 있습니다.

예제 2: 데이터 쿼리하기

from cassandra.cluster import Cluster

cluster = Cluster(['127.0.0.1'])  # 카산드라 클러스터 주소 설정
session = cluster.connect('keyspace')  # 세션 생성 및 키스페이스 선택

rows = session.execute("SELECT * FROM table WHERE id = %s", [1])  # 파라미터화된 쿼리 실행
for row in rows:
    print(row)

기능 3: 데이터 삽입 및 갱신

cassandra-driver를 사용하여 Cassandra 데이터베이스에 데이터를 삽입하고 갱신할 수 있습니다.

예제 3: 데이터 삽입하기

from cassandra.cluster import Cluster

cluster = Cluster(['127.0.0.1'])  # 카산드라 클러스터 주소 설정
session = cluster.connect('keyspace')  # 세션 생성 및 키스페이스 선택

session.execute("INSERT INTO table (id, name) VALUES (%s, %s)", [1, 'example'])  # 데이터 삽입 쿼리 실행