from sentence_transformers import SentenceTransformer
model = SentenceTransformer('all-MiniLM-L6-v2')  # 384維小型模型

def process_short(text):
    """直接全文本編碼"""
    return model.encode(text, convert_to_tensor=True)

# 示例
short_text = "自然語(yǔ)言處理的基礎(chǔ)概念"  # 長(zhǎng)度約15 tokens
vector = process_short(short_text)

from langchain_text_splitters import RecursiveCharacterTextSplitter

def process_medium(text):
    """重疊分塊策略"""
    splitter = RecursiveCharacterTextSplitter(
        chunk_size=500,
        chunk_overlap=50,
        separators=["\n\n", "\n", "。", "！", "？"]
    )
    chunks = splitter.split_text(text)
    return [model.encode(chunk) for chunk in chunks]

# 示例
medium_text = "機(jī)器學(xué)習(xí)發(fā)展歷史...（約1500字）"  # 約1800 tokens
chunk_vectors = process_medium(medium_text)

import spacy

def process_long(text):
    """語(yǔ)義分塊+摘要增強(qiáng)"""
    # 加載語(yǔ)義分割模型
    nlp = spacy.load("zh_core_web_sm") 
    doc = nlp(text)
    
    # 按段落分割
    chunks = [sent.text for sent in doc.sents]
    
    # 生成章節(jié)摘要
    summary_model = SentenceTransformer('uer/sbert-base-chinese-nli')
    summaries = [summary_model.encode(chunk[:200]) for chunk in chunks]
    
    return chunks, summaries

# 示例
long_text = "人工智能技術(shù)白皮書(shū)...（約2萬(wàn)字）"  # 約20000 tokens
text_chunks, summary_vecs = process_long(long_text)

import faiss
import numpy as np

class HierarchicalIndex:
    def __init__(self):
        # 兩級(jí)索引結(jié)構(gòu)
        self.summary_index = faiss.IndexFlatL2(384)
        self.chunk_index = faiss.IndexIVFPQ(
            faiss.IndexFlatL2(384), 384, 100, 16, 8
        )
        self.metadata = []

    def add_document(self, text):
        # 生成段落級(jí)摘要
        chunks, summaries = process_long(text)
        
        # 構(gòu)建索引
        summary_vecs = np.array(summaries).astype('float32')
        chunk_vecs = np.array([model.encode(c) for c in chunks]).astype('float32')
        
        self.summary_index.add(summary_vecs)
        self.chunk_index.add(chunk_vecs)
        self.metadata.extend(chunks)

    def search(self, query, k=5):
        # 先檢索摘要層
        query_vec = model.encode(query).astype('float32')
        _, sum_indices = self.summary_index.search(np.array([query_vec]), 10)
        
        # 精搜相關(guān)塊
        target_chunks = [self.chunk_index.reconstruct(i) for i in sum_indices]
        target_chunks = np.array(target_chunks).astype('float32')
        _, chunk_indices = self.chunk_index.search(target_chunks, k)
        
        return [self.metadata[i] for i in chunk_indices]

# 使用示例
hindex = HierarchicalIndex()
hindex.add_document("某領(lǐng)域技術(shù)文檔...（約15萬(wàn)字）")  # 約200000 tokens
results = hindex.search("深度學(xué)習(xí)在醫(yī)療影像的應(yīng)用")

import dask.dataframe as dd
from dask.distributed import Client

def process_extreme(file_path):
    """分布式處理方案"""
    client = Client(n_workers=4)  # 啟動(dòng)Dask集群
    
    # 分塊讀取
    df = dd.read_parquet(file_path, chunksize=100000)  
    
    # 并行編碼
    df['vector'] = df['text'].map_partitions(
        lambda s: s.apply(model.encode),
        meta=('vector', object)
    )
    
    # 構(gòu)建分布式索引
    df.to_parquet("encoded_data.parquet", engine="pyarrow")
    
# 示例（處理100萬(wàn)條文本）
process_extreme("massive_data.parquet")