[Question]: 我应该如何读取RedisDocumentStore并转换为nodes？

[rzechen]

Question Validation

• I have searched both the documentation and discord for an answer.

Question

我已经通过add_document将文档存储到redis中，如何将文档读取出来？
conn = redis.Redis(host=redis_host, port=redis_port, db=redis_db, password=redis_password)
docstore = RedisDocumentStore.from_redis_client(redis_client=conn, namespace="llama_index2")
storage_context = StorageContext.from_defaults(docstore=docs_store)

为什么已经读取为storage context了，还需要传入nodes，或者如何将docstore转换为nodes呢？
summary_index = SummaryIndex(nodes, storage_context=storage_context)

[dosubot[bot]]

🤖

您好，

要从RedisDocumentStore读取文档并将其转换为在LlamaIndex框架的SummaryIndex中使用的节点，您可以按照以下步骤操作：

1. 使用get_ref_doc_info(ref_doc_id)方法从RedisDocumentStore检索文档。此方法返回已摄取文档及其节点+元数据的字典映射。

ref_doc_info = docstore.get_ref_doc_info(ref_doc_id)

2. 一旦您有了文档，您可以使用_add_nodes_to_index(index_struct, nodes)方法将其转换为节点。此方法接受一个IndexDocumentSummary对象和一系列BaseNode对象，并将它们添加到索引中。

_add_nodes_to_index(index_struct, nodes)

3. 要将文档转换为BaseNode对象，您可以使用TextNode类，它是BaseNode的子类。TextNode构造函数接受一个文本字符串和一个关系字典。

text_node = TextNode(
    text=summary_response.response,
    relationships={
        NodeRelationship.SOURCE: RelatedNodeInfo(node_id=doc_id)
    },
)

4. 最后，您可以使用_insert(nodes)方法将TextNode对象添加到DocumentSummaryIndex。

_insert([text_node])

请注意，您需要将docstore替换为您的RedisDocumentStore实例，并将index_struct替换为您的IndexDocumentSummary实例。另外，将ref_doc_id替换为您想从RedisDocumentStore检索的文档的id，将nodes替换为您想添加到索引的BaseNode对象序列。

源代码：

• llama_index/indices/document_summary/base.py

关于get_ref_doc_info(ref_doc_id)方法在LlamaIndex框架的RedisDocumentStore类中的确切功能，我在存储库中找不到答案，但答案可能在其他地方可用，或者我可能错过了它。

Sources

• llama_index/indices/document_summary/base.py

---

This response is meant to be useful and save you time. It is not meant to be a precise solution, but rather a starting point for your own research.

Help me be more useful! Please leave a 👍 if this is helpful and 👎 if it is irrelevant.

If you want to continue the conversation, start your reply with @dosu-bot.

[rzechen]

def query_service_stream(self, question, top_k):
query_engine = CitationQueryEngine.from_args(
self.index, similarity_top_k=top_k,
citation_qa_template=CITATION_QA_TEMPLATE,
citation_refine_template=CITATION_REFINE_TEMPLATE,
citation_chunk_size=512, streaming=True
)
response = query_engine.query(question)
increment_response = ""
for word in response.response_gen:
increment_response = increment_response + word
yield {"trunk": word, "response": increment_response, "finished": False}
response.response_gen.close()
yield {"trunk": "", "finished": True, "response": increment_response}

总是报错： raise RuntimeError("Session and connector has to use same event loop")
RuntimeError: Session and connector has to use same event loop