Cassandra

Cassandra 是一个 NoSQL、面向行、高度可扩展且高可用的数据库。从 5.0 版本开始，该数据库配备了向量搜索功能。

概览

Cassandra 文档加载器从 Cassandra 数据库返回一个 LangChain 文档列表。

您必须提供 CQL 查询或表名以检索文档。 Loader 接受以下参数：

• table:（可选）要从中加载数据的表。
• session:（可选）Cassandra 驱动程序会话。如果未提供，将使用 cassio 解析的会话。
• keyspace:（可选）表所在的键空间。如果未提供，将使用 cassio 解析出的键空间。
• query:（可选）用于加载数据的查询。
• page_content_mapper:（可选）一个将行转换为字符串页面内容的函数。默认情况下将行转换为 JSON。
• metadata_mapper：（可选）一个将行转换为元数据字典的函数。
• query_parameters: (可选) 调用 session.execute 时使用的查询参数。
• query_timeout:（可选）调用 session.execute 时使用的查询超时时间。
• query_custom_payload: (可选) 调用 session.execute 时使用的查询 custom_payload。
• query_execution_profile：（可选）调用 session.execute 时使用的查询执行配置文件。
• query_host：（可选）调用 session.execute 时使用的查询主机。
• query_execute_as:（可选）调用 session.execute 时使用的 query_execute_as。

使用文档加载器加载文档

from langchain_community.document_loaders import CassandraLoader

API 参考：CassandraLoader

从 Cassandra 驱动程序会话初始化

您需要创建一个cassandra.cluster.Session对象，如Cassandra 驱动程序文档中所述。具体细节会有所不同（例如网络设置和身份验证），但可能类似于：

from cassandra.cluster import Cluster

cluster = Cluster()
session = cluster.connect()

您需要提供现有 Cassandra 实例的键空间名称：

CASSANDRA_KEYSPACE = input("CASSANDRA_KEYSPACE = ")

创建文档加载器：

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 来配置会话和密钥空间。

import cassio

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

loader = CassandraLoader(
    table="movie_reviews",
)

docs = loader.load()

引用声明

Apache Cassandra, Cassandra and Apache are either registered trademarks or trademarks of the Apache Software Foundation in the United States and/or other countries.

相关

• 文档加载器 概念指南
• 文档加载器 操操作指南