add JSON loader
This commit is contained in:
parent
7a0935aa26
commit
244a0abed5
|
|
@ -0,0 +1,74 @@
|
||||||
|
import { INode, INodeData, INodeParams } from '../../../src/Interface'
|
||||||
|
import { TextSplitter } from 'langchain/text_splitter'
|
||||||
|
import { JSONLoader } from 'langchain/document_loaders/fs/json'
|
||||||
|
|
||||||
|
class Json_DocumentLoaders implements INode {
|
||||||
|
label: string
|
||||||
|
name: string
|
||||||
|
description: string
|
||||||
|
type: string
|
||||||
|
icon: string
|
||||||
|
category: string
|
||||||
|
baseClasses: string[]
|
||||||
|
inputs: INodeParams[]
|
||||||
|
|
||||||
|
constructor() {
|
||||||
|
this.label = 'Json File'
|
||||||
|
this.name = 'jsonFile'
|
||||||
|
this.type = 'Document'
|
||||||
|
this.icon = 'json.svg'
|
||||||
|
this.category = 'Document Loaders'
|
||||||
|
this.description = `Load data from JSON files`
|
||||||
|
this.baseClasses = [this.type]
|
||||||
|
this.inputs = [
|
||||||
|
{
|
||||||
|
label: 'Json File',
|
||||||
|
name: 'jsonFile',
|
||||||
|
type: 'file',
|
||||||
|
fileType: '.json'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Text Splitter',
|
||||||
|
name: 'textSplitter',
|
||||||
|
type: 'TextSplitter',
|
||||||
|
optional: true
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Pointers Extraction (separated by commas)',
|
||||||
|
name: 'pointersName',
|
||||||
|
type: 'string',
|
||||||
|
description: 'Extracting multiple pointers',
|
||||||
|
placeholder: 'Enter pointers name',
|
||||||
|
optional: true
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
async init(nodeData: INodeData): Promise<any> {
|
||||||
|
const textSplitter = nodeData.inputs?.textSplitter as TextSplitter
|
||||||
|
const jsonFileBase64 = nodeData.inputs?.jsonFile as string
|
||||||
|
const pointersName = nodeData.inputs?.pointersName as string
|
||||||
|
const splitDataURI = jsonFileBase64.split(',')
|
||||||
|
splitDataURI.pop()
|
||||||
|
const bf = Buffer.from(splitDataURI.pop() || '', 'base64')
|
||||||
|
|
||||||
|
let pointers: string[] = []
|
||||||
|
if (pointersName) {
|
||||||
|
const outputString = pointersName.replace(/[^a-zA-Z0-9,]+/g, ',')
|
||||||
|
pointers = outputString.split(',').map((pointer) => "/" + pointer.trim())
|
||||||
|
}
|
||||||
|
|
||||||
|
const blob = new Blob([bf])
|
||||||
|
const loader = new JSONLoader(blob, pointers.length != 0 ? pointers : undefined)
|
||||||
|
|
||||||
|
if (textSplitter) {
|
||||||
|
const docs = await loader.loadAndSplit(textSplitter)
|
||||||
|
return docs
|
||||||
|
} else {
|
||||||
|
const docs = await loader.load()
|
||||||
|
return docs
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = { nodeClass: Json_DocumentLoaders }
|
||||||
|
|
@ -0,0 +1,7 @@
|
||||||
|
<svg xmlns="http://www.w3.org/2000/svg" class="icon icon-tabler icon-tabler-json" width="24" height="24" viewBox="0 0 24 24" stroke-width="2" stroke="currentColor" fill="none" stroke-linecap="round" stroke-linejoin="round">
|
||||||
|
<path stroke="none" d="M0 0h24v24H0z" fill="none"></path>
|
||||||
|
<path d="M20 16v-8l3 8v-8"></path>
|
||||||
|
<path d="M15 8a2 2 0 0 1 2 2v4a2 2 0 1 1 -4 0v-4a2 2 0 0 1 2 -2z"></path>
|
||||||
|
<path d="M1 8h3v6.5a1.5 1.5 0 0 1 -3 0v-.5"></path>
|
||||||
|
<path d="M7 15a1 1 0 0 0 1 1h1a1 1 0 0 0 1 -1v-2a1 1 0 0 0 -1 -1h-1a1 1 0 0 1 -1 -1v-2a1 1 0 0 1 1 -1h1a1 1 0 0 1 1 1"></path>
|
||||||
|
</svg>
|
||||||
|
After Width: | Height: | Size: 591 B |
Loading…
Reference in New Issue