# Stream JSON File Reader O **Stream JSON File Reader** lê um arquivo JSON local, aplica uma expressão JSON Path, devolve em um estrutura JSON conforme a expressão definida e dispara *subpipelines* para processar cada mensagem. O componente deve ser utilizado para arquivos grandes. ## Parâmetros Dê uma olhada nos parâmetros de configuração do componente. Parâmetros suportados por [expressões *Double Braces*](/documentation/connectors-and-triggers/pt-br/double-braces/overview.md) estão marcados com `(DB)`.
ParâmetroDescriçãoValor padrãoTipo de dado
File Name (DB)Nome do arquivo ou full file path (ex.: tmp/processed/file.json) do arquivo JSON local.data.jsonString
JSON PathExpressão JSON Path que irá determinar como será feita a leitura em stream desse arquivo JSON.$String
Element IdentifierAtributo que será enviado em caso de erros.dataString
Parallel Execution Of Each IterationOcorre em paralelo com a execução do loop.FalseBooleano
Fail On Error

A habilitação desse parâmetro suspende a execução do pipeline apenas quando há uma ocorrência grave na estrutura da iteração, impedindo a sua conclusão por completo.

A ativação do parâmetro Fail On Error não tem ligação com erros ocorridos nos componentes utilizados para a construção dos subpipelines (onProcess e onException).

FalseBooleano
## Fluxo de mensagens ### Entrada Não se espera nenhuma mensagem de entrada específica e sim apenas a posse de um arquivo JSON no diretório local do *pipeline* e o preenchimento dos campos **File Name** e **JSON Path** para o processamento do arquivo. ### Saída ``` { "total": 0, "success": 0, "failed": 0 } ``` * **total:** número total de linhas processadas. * **success:** número total de linhas processadas com sucesso. * **failed:** número total de linhas cujo processamento falhou. {% hint style="info" %} Para saber se uma linha foi processada corretamente, deve haver o retorno `{ "success": true }` para cada linha processada. {% endhint %} O componente joga uma exceção se o **File Name** não existir ou não puder ser lido. A manipulação de arquivos dentro de um *pipeline* ocorre de forma protegida. Todos os arquivos podem ser acessados apenas por um diretório temporário, no qual cada *pipeline key* dá acesso ao seu próprio conjunto de arquivos. O **Stream JSON File Reader** realiza processamento em lote, o que significa processar os dados de forma contínua e controlada em lotes menores. ## Stream JSON File Reader em Ação ### Realizando o stream do arquivo sem filtros no JSON Path #### **Entrada** * file.json ``` { "products" : [ { "product": "Chair", "price": 20.75, "tags": ["NEW", "FURNITURE"] }, { "product": "TV", "price": 399.99, "tags": ["NEW", "FURNITURE"] }, { "product": "Couch", "price": 100, "tags": ["NEW", "FURNITURE"] }, { "product": "Table", "price": 78.99, "tags": ["NEW", "FURNITURE"] } ] } ``` * **File Name:** file.json * **JSON Path:** $.products\[\*] #### **Saída** ``` { "total": 4, "success": 4, "failed": 0 } ``` Cada objeto dentro do *array* `"products"` do arquivo informado será processado de forma independente: * **Primeiro subfluxo** ``` {"data": { "product": "Chair", "price": 20.75, "tags": ["NEW", "FURNITURE"] }} ``` * **Segundo subfluxo** ``` {"data": { "product": "TV", "price": 399.99, "tags": ["NEW", "FURNITURE"] }} ``` * **Terceiro subfluxo** ``` {"data": { "product": "Couch", "price": 100, "tags": ["NEW", "FURNITURE"] }} ``` * **Quarto subfluxo** ``` {"data": { "product": "Table", "price": 78.99, "tags": ["NEW", "FURNITURE"] }} ``` ### Realizando o stream do arquivo com filtros no JSON Path #### **Entrada** * file.json ``` { "products" : [ { "product": "Chair", "price": 20.75, "tags": ["NEW", "FURNITURE"] }, { "product": "TV", "price": 399.99, "tags": ["NEW", "FURNITURE"] }, { "product": "Couch", "price": 100, "tags": ["NEW", "FURNITURE"] }, { "product": "Table", "price": 78.99, "tags": ["NEW", "FURNITURE"] } ] } ``` * **File Name:** file.json * **JSON Path:** $.products\[?(@.price < 80)] #### **Saída** ``` { "total": 2, "success": 2, "failed": 0 } ``` Cada objeto dentro do *array* `"products"` do arquivo informado será processado de forma independente: * **Primeiro subfluxo** ``` {"data": { "product": "Chair", "price": 20.75, "tags": ["NEW", "FURNITURE"] } } ``` * **Segundo subfluxo** ``` {"data": { "product": "Table", "price": 78.99, "tags": ["NEW", "FURNITURE"] }} ``` ### Realizando o stream do arquivo com filtros no JSON Path e retornando somente o valor do atributo 'product' #### **Entrada** * file.json ``` { "products" : [ { "product": "Chair", "price": 20.75, "tags": ["NEW", "FURNITURE"] }, { "product": "TV", "price": 399.99, "tags": ["NEW", "FURNITURE"] }, { "product": "Couch", "price": 100, "tags": ["NEW", "FURNITURE"] }, { "product": "Table", "price": 78.99, "tags": ["NEW", "FURNITURE"] } ] } ``` * **File Name:** file.json * **JSON Path:** $.products\[?(@.price < 80)].product #### **Saída** ``` { "total": 2, "success": 2, "failed": 0 } ``` Cada objeto dentro do *array* `"products"` do arquivo informado será processado de forma independente: * **Primeiro subfluxo** ``` {"data": "Chair" } ``` * **Segundo subfluxo** ``` {"data": "Table" } ``` --- # Agent Instructions: Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter: ``` GET https://docs.digibee.com/documentation/connectors-and-triggers/pt-br/connectors/files/stream-json-file-reader.md?ask= ``` The question should be specific, self-contained, and written in natural language. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.