Skip to main content
Cassandra는 NoSQL, 행 지향, 확장성과 가용성이 높은 데이터베이스입니다. 버전 5.0부터 데이터베이스는 벡터 검색 기능과 함께 제공됩니다.

​
개요

Cassandra Document Loader는 Cassandra 데이터베이스에서 LangChain Document 목록을 반환합니다. 문서를 검색하려면 CQL 쿼리 또는 테이블 이름을 제공해야 합니다. 로더는 다음 매개변수를 사용합니다:
  • table: (선택 사항) 데이터를 로드할 테이블입니다.
  • session: (선택 사항) Cassandra 드라이버 세션입니다. 제공되지 않으면 cassio가 해결한 세션이 사용됩니다.
  • keyspace: (선택 사항) 테이블의 keyspace입니다. 제공되지 않으면 cassio가 해결한 keyspace가 사용됩니다.
  • query: (선택 사항) 데이터를 로드하는 데 사용되는 쿼리입니다.
  • page_content_mapper: (선택 사항) 행을 문자열 페이지 콘텐츠로 변환하는 함수입니다. 기본값은 행을 JSON으로 변환합니다.
  • metadata_mapper: (선택 사항) 행을 메타데이터 dict로 변환하는 함수입니다.
  • query_parameters: (선택 사항) session.execute를 호출할 때 사용되는 쿼리 매개변수입니다.
  • query_timeout: (선택 사항) session.execute를 호출할 때 사용되는 쿼리 타임아웃입니다.
  • query_custom_payload: (선택 사항) session.execute를 호출할 때 사용되는 쿼리 custom_payload입니다.
  • query_execution_profile: (선택 사항) session.execute를 호출할 때 사용되는 쿼리 execution_profile입니다.
  • query_host: (선택 사항) session.execute를 호출할 때 사용되는 쿼리 호스트입니다.
  • query_execute_as: (선택 사항) session.execute를 호출할 때 사용되는 쿼리 execute_as입니다.

​
Document Loader로 문서 로드하기

from langchain_community.document_loaders import CassandraLoader

​
Cassandra 드라이버 Session에서 초기화

Cassandra 드라이버 문서에 설명된 대로 cassandra.cluster.Session 객체를 생성해야 합니다. 세부 사항은 다양하지만(예: 네트워크 설정 및 인증), 다음과 같을 수 있습니다: 
from cassandra.cluster import Cluster

cluster = Cluster()
session = cluster.connect()
Cassandra 인스턴스의 기존 keyspace 이름을 제공해야 합니다: 
CASSANDRA_KEYSPACE = input("CASSANDRA_KEYSPACE = ")
Document Loader 생성: 
loader = CassandraLoader(
    table="movie_reviews",
    session=session,
    keyspace=CASSANDRA_KEYSPACE,
)

docs = loader.load()

docs[0]

Document(page_content='Row(_id=\'659bdffa16cbc4586b11a423\', title=\'Dangerous Men\', reviewtext=\'"Dangerous Men,"  the picture\\\'s production notes inform, took 26 years to reach the big screen. After having seen it, I wonder: What was the rush?\')', metadata={'table': 'movie_reviews', 'keyspace': 'default_keyspace'})

​
cassio에서 초기화

cassio를 사용하여 세션과 keyspace를 구성할 수도 있습니다. 
import cassio

cassio.init(contact_points="127.0.0.1", keyspace=CASSANDRA_KEYSPACE)

loader = CassandraLoader(
    table="movie_reviews",
)

docs = loader.load()

​
저작자 표시 성명

Apache Cassandra, Cassandra 및 Apache는 미국 및/또는 기타 국가에서 Apache Software Foundation의 등록 상표 또는 상표입니다.
Edit the source of this page on GitHub.
Connect these docs programmatically to Claude, VSCode, and more via MCP for real-time answers.
⌘I