Read-JSON pipeline

import vectorshift
from vectorshift.pipeline import Pipeline, InputNode, OutputNode, ReadJsonValuesNode

pipeline = Pipeline.fetch(id="698d6768a07ed4bec88d7aed")

pipeline.nodes.clear()

string_input = InputNode(node_name='query', input_type='string')

read_json_node = ReadJsonValuesNode(
    json_string=string_input.text, keys=["hello", "hi"], processed_outputs={}
)

output_node = OutputNode(
    node_name='result',
    output_type='string',
    value=read_json_node.json_values,
)

output_node_2 = OutputNode(
    node_name="result_2", output_type="string", value=read_json_node.hello
)

pipeline.nodes = [string_input, read_json_node, output_node, output_node_2]
pipeline.save()