Stream DB V1 (Descontinuado)

Conheça o componente e saiba como utilizá-lo.

O Stream DB V1 efetua operações através da conexão com um banco de dados, transmitindo dados para um subpipeline que os processa.

Parâmetros

Dê uma olhada nas opções de configuração do componente:

Parâmetro	Descrição	Valor padrão	Tipo de dado
Account	Conta a ser utilizada pelo componente.	N/A	String
Database URL	String de conexão ao banco de dados.	N/A	String
SQL Statement	Instrução SQL a ser executada.	N/A	String
Column Name	Nome da coluna a ser lida.	N/A	String
Coalesce	Quando ativada, essa opção controla se os objetos de dados são fundidos em uma sequência ou se um erro é gerado.	N/A	Booleano
Parallel Execution Of Each Iteration	Ocorre em paralelo com a execução do loop.	N/A	Booleano
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).	N/A	Booleano
Custom Connection Properties	Propriedades de conexão específicas definidas pelo usuário.	N/A	N/A
Keep Connections	Se ativada, a opção vai manter as conexões com a base de dados por no máximo 30 minutos; do contrário, será por apenas 5 minutos.	N/A	Booleano
Advanced	Configurações avançadas.	N/A	N/A
Connection Test Query	Instrução SQL a ser utilizada antes que cada conexão seja estabelecida - esse parâmetro é opcional e deve ser aplicado a bancos de dados que não possuem informações confiáveis sobre o status da conexão.	N/A	String

Fluxo de Mensagens

Entrada

O componente espera uma mensagem no seguinte formato:

{
	"parameters": {
		"name": "value"
		...
	}
}

Estrutura de mensagem "onProcess"

{	
    "column1":"data1", "column2":"data2", ... 
}

Saída com erro

{	
    "code": error_code,	
    "error": error_message,	
    "processedId": the_id_column_value
}

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

Importante: quando as linhas são processadas corretamente, os seus respectivos subpipelines retornam { "success": true } para cada uma delas.

Este componente realiza processamento em lote. Para entender melhor o conceito, clique aqui.