파이썬 Django에서 Cassandra 데이터베이스 사용하기: django-cassandra-engine 활용 가이드

django-cassandra-engine은 Django 웹 애플리케이션에서 Cassandra 데이터베이스를 사용하기 위한 도구입니다. 이를 통해 Django 프레임워크의 ORM(Object-Relational Mapping) 기능을 사용하여 Cassandra 데이터베이스에 접근하고 관리할 수 있습니다. 아래에서 django-cassandra-engine의 기능과 사용법을 상세히 소개하겠습니다.

기능 1: 모델 정의 및 데이터베이스 마이그레이션

django-cassandra-engine을 사용하여 Django에서 모델을 정의하고 Cassandra 데이터베이스와 연동할 수 있습니다. 모델은 Cassandra 데이터베이스의 테이블을 정의하고, 데이터베이스 마이그레이션을 통해 변경 사항을 적용할 수 있습니다.

예제 1: 모델 정의 및 마이그레이션

# models.py
from django_cassandra_engine.models import DjangoCassandraModel
from cassandra.cqlengine import columns

class Product(DjangoCassandraModel):
    id = columns.UUID(primary_key=True)
    name = columns.Text()
    price = columns.Decimal()

# 마이그레이션
python manage.py sync_cassandra

기능 2: 쿼리 및 필터링

django-cassandra-engine을 사용하여 Cassandra 데이터베이스에 쿼리를 수행하고 필터링할 수 있습니다. Django ORM의 QuerySet과 유사한 방식으로 데이터를 조회할 수 있습니다.

예제 2: 쿼리 및 필터링

from myapp.models import Product

# 모든 제품 조회
products = Product.objects.all()

# 가격이 100 이상인 제품 조회
expensive_products = Product.objects.filter(price__gte=100)

기능 3: 세션 관리

django-cassandra-engine을 사용하여 Cassandra 세션을 관리할 수 있습니다. 세션을 통해 Cassandra 데이터베이스에 대한 접속 설정 및 연결을 관리할 수 있습니다.

예제 3: 세션 관리

from django_cassandra_engine.sessions import cassandra_session

# 세션을 사용하여 쿼리 수행
cql_statement = "SELECT * FROM mykeyspace.product"
result = cassandra_session.execute(cql_statement)
for row in result:
    print(row)