@@ -29,7 +29,8 @@ In this guide, we mainly focus on step 1, 2, and 3.
2929First, you need to install the ` dbgpt ` library.
3030
3131``` bash
32- pip install " dbgpt[rag]>=0.7.0" -U
32+ pip install " dbgpt[rag, agent, client, simple_framework]>=0.7.0" " dbgpt_ext>=0.7.0" -U
33+ pip install openai
3334````
3435
3536# # Build Knowledge Base
@@ -92,17 +93,17 @@ shutil.rmtree("/tmp/awel_with_data_vector_store", ignore_errors=True)
9293vector_store = ChromaStore(
9394 ChromaVectorConfig(
9495 persist_path="/tmp/tmp_ltm_vector_store",
95- name="ltm_vector_store" ,
96- embedding_fn=embeddings ,
97- )
96+ ) ,
97+ name="ltm_vector_store" ,
98+ embedding_fn=embeddings,
9899)
99100
100101with DAG("load_schema_dag") as load_schema_dag:
101102 input_task = InputOperator.dummy_input()
102103 # Load database schema to vector store
103104 assembler_task = DBSchemaAssemblerOperator(
104105 connector=db_conn,
105- index_store =vector_store,
106+ table_vector_store_connector =vector_store,
106107 chunk_parameters=ChunkParameters(chunk_strategy="CHUNK_BY_SIZE")
107108 )
108109 input_task >> assembler_task
@@ -122,7 +123,8 @@ with DAG("retrieve_schema_dag") as retrieve_schema_dag:
122123 # Retrieve database schema from vector store
123124 retriever_task = DBSchemaRetrieverOperator(
124125 top_k=1,
125- index_store=vector_store,
126+ table_vector_store_connector=vector_store,
127+ field_vector_store_connector=vector_store
126128 )
127129 input_task >> retriever_task
128130
@@ -487,10 +489,10 @@ db_conn.create_temp_tables(
487489
488490vector_store = ChromaStore(
489491 ChromaVectorConfig(
490- embedding_fn=embeddings,
491- name=" db_schema_vector_store" ,
492492 persist_path=" /tmp/awel_with_data_vector_store" ,
493- )
493+ ),
494+ embedding_fn=embeddings,
495+ name=" db_schema_vector_store" ,
494496)
495497
496498antv_charts = [
@@ -623,7 +625,7 @@ with DAG("load_schema_dag") as load_schema_dag:
623625 # Load database schema to vector store
624626 assembler_task = DBSchemaAssemblerOperator(
625627 connector=db_conn,
626- index_store =vector_store,
628+ table_vector_store_connector =vector_store,
627629 chunk_parameters=ChunkParameters(chunk_strategy=" CHUNK_BY_SIZE" ),
628630 )
629631 input_task >> assembler_task
0 commit comments