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âmetroDescriçãoValor padrãoTipo 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.

Atualizado