ConsumeSnowflakeStream 2025.5.31.15¶

Pacote¶

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

Descrição¶

Obtém dados de um fluxo Snowflake e os grava em FlowFile. O fluxo deve ser criado no banco de dados antes de usar esse processador. O processador consumirá o fluxo e gravará os registros no FlowFile usando o Record Writer especificado. O processador também adicionará um atributo ao FlowFile com o nome do fluxo. O processador não funcionará se o fluxo estiver obsoleto. Em vez disso, ele registrará uma mensagem de erro e interromperá o processamento. O fluxo obsoleto precisa ser recriado no banco de dados. Depois que o fluxo for recriado no banco de dados, o processador continuará a ler e processar os registros da CDC. Para obter mais informações sobre os fluxos Snowflake, consulte a <a href=»https://docs.snowflake.com/pt/user-guide/streams-intro»>documentação do Snowflake</a>.

Tags¶

connection, database, jdbc, openflow, snowflake, stream, table, view

Requisito de entrada¶

FORBIDDEN

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Tamanho máximo de parte	Número de registros a serem gravados em um único FlowFile. Esse valor pode ser ligeiramente excedido.
Record Writer	O Record Writer a ser usado para a serialização do registro CDC
Serviço de conexão Snowflake	Serviço de conexão de banco de dados para acessar o Snowflake
Nome de fluxo	O nome do fluxo no banco de dados

Relações¶

Nome	Descrição
success	Para FlowFiles com registros CDC de fluxo

Grava atributos¶

Nome	Descrição
snowflake.stream.name	Nome do Snowflake Stream