CassandraByteStore

這將幫助您開始使用 Cassandra 鍵值儲存庫。如需所有 CassandraByteStore 功能和配置的詳細文件，請前往 API 參考。

概述

Cassandra 是一個 NoSQL、面向列、高度可擴展且高度可用的資料庫。

整合細節

類別	套件	本地	JS 支援	套件下載次數	最新套件
CassandraByteStore	langchain_community	✅	✅

設定

CassandraByteStore 是 ByteStore 的實作，可將資料儲存在您的 Cassandra 實例中。儲存庫金鑰必須是字串，並將映射到 Cassandra 表格的 row_id 欄位。儲存庫 bytes 值會映射到 Cassandra 表格的 body_blob 欄位。

安裝

LangChain CassandraByteStore 整合位於 langchain_community 套件中。您還需要安裝 cassio 套件或 cassandra-driver 套件作為同級依賴，具體取決於您使用的初始化方法

%pip install -qU langchain_community
%pip install -qU cassandra-driver
%pip install -qU cassio

您還需要建立一個 cassandra.cluster.Session 物件，如 Cassandra 驅動程式文件中所述。詳細資訊各不相同（例如，網路設定和身份驗證），但可能類似於

實例化

您首先需要建立一個 cassandra.cluster.Session 物件，如 Cassandra 驅動程式文件中所述。詳細資訊各不相同（例如，網路設定和身份驗證），但可能類似於

from cassandra.cluster import Cluster

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

然後您可以建立您的儲存庫！您還需要提供 Cassandra 實例的現有 keyspace 名稱

from langchain_community.storage import CassandraByteStore

kv_store = CassandraByteStore(
    table="my_store",
    session=session,
    keyspace="<YOUR KEYSPACE>",
)

API 參考：CassandraByteStore

用法

您可以使用 mset 方法像這樣在金鑰下設定資料

kv_store.mset(
    [
        ["key1", b"value1"],
        ["key2", b"value2"],
    ]
)

kv_store.mget(
    [
        "key1",
        "key2",
    ]
)

您可以使用 mdelete 方法刪除資料

kv_store.mdelete(
    [
        "key1",
        "key2",
    ]
)

kv_store.mget(
    [
        "key1",
        "key2",
    ]
)

使用 cassio 初始化

也可以使用 cassio 來配置工作階段和 keyspace。

import cassio

cassio.init(contact_points="127.0.0.1", keyspace="<YOUR KEYSPACE>")

store = CassandraByteStore(
    table="my_store",
)

store.mset([("k1", b"v1"), ("k2", b"v2")])
print(store.mget(["k1", "k2"]))

API 參考

如需所有 CassandraByteStore 功能和配置的詳細文件，請前往 API 參考：https://langchain-python.dev.org.tw/api_reference/community/storage/langchain_community.storage.cassandra.CassandraByteStore.html

相關

• 鍵值儲存庫 概念指南