Update sample code in README.md

This commit is contained in:
yangdx
2025-04-21 01:22:04 +08:00
parent 908953924a
commit bd18c9c8ad
3 changed files with 48 additions and 50 deletions

View File

@@ -107,42 +107,42 @@ from lightrag.utils import setup_logger
setup_logger("lightrag", level="INFO") setup_logger("lightrag", level="INFO")
if not os.path.exists(WORKING_DIR):
os.mkdir(WORKING_DIR)
async def initialize_rag(): async def initialize_rag():
rag = LightRAG( rag = LightRAG(
working_dir="your/path", working_dir=WORKING_DIR,
embedding_func=openai_embed, embedding_func=openai_embed,
llm_model_func=gpt_4o_mini_complete llm_model_func=gpt_4o_mini_complete,
) )
await rag.initialize_storages() await rag.initialize_storages()
await initialize_pipeline_status() await initialize_pipeline_status()
return rag return rag
def main(): def main():
# 初始化RAG实例 try:
rag = asyncio.run(initialize_rag()) # Initialize RAG instance
# 插入文本 rag = await initialize_rag()
rag.insert("Your text") rag.insert("Your text")
# 执行朴素搜索 # Perform hybrid search
mode="naive"
# 执行本地搜索
mode="local"
# 执行全局搜索
mode="global"
# 执行混合搜索
mode="hybrid" mode="hybrid"
# 混合模式集成知识图谱和向量检索 print(
mode="mix" await rag.query(
"What are the top themes in this story?",
rag.query(
"这个故事的主要主题是什么?",
param=QueryParam(mode=mode) param=QueryParam(mode=mode)
) )
)
except Exception as e:
print(f"An error occurred: {e}")
finally:
if rag:
await rag.finalize_storages()
if __name__ == "__main__": if __name__ == "__main__":
main() asyncio.run(main())
``` ```
### 查询参数 ### 查询参数

View File

@@ -143,42 +143,42 @@ from lightrag.utils import setup_logger
setup_logger("lightrag", level="INFO") setup_logger("lightrag", level="INFO")
if not os.path.exists(WORKING_DIR):
os.mkdir(WORKING_DIR)
async def initialize_rag(): async def initialize_rag():
rag = LightRAG( rag = LightRAG(
working_dir="your/path", working_dir=WORKING_DIR,
embedding_func=openai_embed, embedding_func=openai_embed,
llm_model_func=gpt_4o_mini_complete llm_model_func=gpt_4o_mini_complete,
) )
await rag.initialize_storages() await rag.initialize_storages()
await initialize_pipeline_status() await initialize_pipeline_status()
return rag return rag
def main(): def main():
try:
# Initialize RAG instance # Initialize RAG instance
rag = asyncio.run(initialize_rag()) rag = await initialize_rag()
# Insert text
rag.insert("Your text") rag.insert("Your text")
# Perform naive search
mode="naive"
# Perform local search
mode="local"
# Perform global search
mode="global"
# Perform hybrid search # Perform hybrid search
mode="hybrid" mode="hybrid"
# Mix mode Integrates knowledge graph and vector retrieval. print(
mode="mix" await rag.query(
rag.query(
"What are the top themes in this story?", "What are the top themes in this story?",
param=QueryParam(mode=mode) param=QueryParam(mode=mode)
) )
)
except Exception as e:
print(f"An error occurred: {e}")
finally:
if rag:
await rag.finalize_storages()
if __name__ == "__main__": if __name__ == "__main__":
main() asyncio.run(main())
``` ```
### Query Param ### Query Param

View File

@@ -82,7 +82,6 @@ async def initialize_rag():
working_dir=WORKING_DIR, working_dir=WORKING_DIR,
embedding_func=openai_embed, embedding_func=openai_embed,
llm_model_func=gpt_4o_mini_complete, llm_model_func=gpt_4o_mini_complete,
# llm_model_func=gpt_4o_complete
) )
await rag.initialize_storages() await rag.initialize_storages()
@@ -92,7 +91,6 @@ async def initialize_rag():
async def main(): async def main():
rag = None
try: try:
# Initialize RAG instance # Initialize RAG instance
rag = await initialize_rag() rag = await initialize_rag()