Раздувать от узла до нескольких экземпляров функции узла в Langchain's Langgraph? ⇐ Python

[Anonymous]

Я проектирую приложение Langgraph и имею сценарий, в котором мне нужно обработать документ параллелью. Мой текущий концептуальный поток, аналогичный прикрепленной диаграмме, включает в себя: < /p>

Код: Выделить всё

Document Chunking: An initial node takes a document and splits it into multiple chunks.
Parallel Processing: Each of these chunks needs to be processed independently by the same document processing logic.
Post-processing: Once all chunks are processed, their results need to be aggregated in a final post-processing step.
< /code>
По сути, я хочу «раздувать» из одного «Узел Document Chunking» до нескольких, одновременных выполнений «функции обработки документов», каждая из которых обрабатывает свой кусок. После завершения этих параллельных выполнений мне нужно «фанат» на «пост-обработку». Если да, то каковы рекомендуемые шаблоны или функции для использования? В частности, я ищу руководство по: < /p>
How to define a graph structure that allows a single output from one node to trigger multiple instances of the next node.
How to pass different inputs (e.g., individual chunks) to each instance of the parallel processing node.
How to collect and aggregate the results from all parallel instances before proceeding to a final node.

Любые примеры кода или концептуальные объяснения были бы очень оценены!

Подробнее здесь: https://stackoverflow.com/questions/796 ... hains-lang