MongoDB 读取器¶

演示我们的 MongoDB 数据连接器

In [ ]

%pip install llama-index-readers-mongodb

%pip install llama-index-readers-mongodb

In [ ]

import logging
import sys

logging.basicConfig(stream=sys.stdout, level=logging.INFO)
logging.getLogger().addHandler(logging.StreamHandler(stream=sys.stdout))

import logging import sys logging.basicConfig(stream=sys.stdout, level=logging.INFO) logging.getLogger().addHandler(logging.StreamHandler(stream=sys.stdout))

如果您在 Colab 上打开此 Notebook，您可能需要安装 LlamaIndex 🦙 和 pymongo。

In [ ]

!pip install llama-index pymongo

!pip install llama-index pymongo

In [ ]

from llama_index.core import SummaryIndex
from llama_index.readers.mongodb import SimpleMongoReader
from IPython.display import Markdown, display
import os

from llama_index.core import SummaryIndex from llama_index.readers.mongodb import SimpleMongoReader from IPython.display import Markdown, display import os

In [ ]

host = "<host>"
port = "<port>"
db_name = "<db_name>"
collection_name = "<collection_name>"
# query_dict is passed into db.collection.find()
query_dict = {}
field_names = ["text"]
reader = SimpleMongoReader(host, port)
documents = reader.load_data(
    db_name, collection_name, field_names, query_dict=query_dict
)

host = "" port = "" db_name = "" collection_name = "" # query_dict is passed into db.collection.find() query_dict = {} field_names = ["text"] reader = SimpleMongoReader(host, port) documents = reader.load_data( db_name, collection_name, field_names, query_dict=query_dict )

In [ ]

index = SummaryIndex.from_documents(documents)

index = SummaryIndex.from_documents(documents)

In [ ]

# set Logging to DEBUG for more detailed outputs
query_engine = index.as_query_engine()
response = query_engine.query("<query_text>")

# set Logging to DEBUG for more detailed outputs query_engine = index.as_query_engine() response = query_engine.query("")

In [ ]

display(Markdown(f"<b>{response}</b>"))

display(Markdown(f"{response}"))