yumoqing/rag
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: _rag_ingest_async chunk INSERT加metadata列

Browse Source
This commit is contained in:
rag 2026-08-12 11:10:55 +08:00
parent 67c13f626d
commit b86883c1f8
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
rag/init.py
View File

@ -527,7 +527,7 @@ async def _rag_ingest_async(env, text, kb_id, doc_id):
async with get_sor_context(env, 'rag') as sor:
for i, (chunk_text, vid) in enumerate(zip(chunks, vector_ids)):
await sor.sqlExe(
"INSERT INTO document_chunks (id, doc_id, kb_id, chunk_index, content, vector_id, created_at) "
"INSERT INTO document_chunks (id, doc_id, kb_id, chunk_index, content, vector_id, metadata, created_at) "
"VALUES (${id}$, ${doc_id}$, ${kb_id}$, ${idx}$, ${content}$, ${vid}$, NOW())",
{"id": f"{doc_id}_c{i}", "doc_id": doc_id, "kb_id": kb_id,
"idx": i, "content": chunk_text[:2000], "vid": vid})