PutDatabricksSQL 2025.5.31.15¶

Pacote¶

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

Descrição¶

Envie uma execução SQL usando a Databricks REST API e, em seguida, escreva a resposta JSON no conteúdo de FlowFile. Para consultas de alto desempenho em SELECT ou INSERT, use ExecuteSQL.

Tags¶

databricks, openflow, sql

Requisito de entrada¶

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Cliente Databricks	Serviço ao cliente Databricks.
Catálogo padrão	Catálogo de tabela padrão – algumas instruções SQL, como “COPY INTO”, não oferecem suporte ao uso de um catálogo padrão
Esquema padrão	Esquema de tabela padrão – algumas instruções SQL, como “COPY INTO”, não oferecem suporte ao uso de um esquema padrão
Record Writer	Especifica o Controller Service a ser usado para gravar resultados em um FlowFile. O Record Writer pode usar a herança de esquema para emular o comportamento do esquema inferido, ou seja, um esquema explícito não precisa ser definido no gravador e será fornecido pela mesma lógica usada para inferir o esquema a partir dos tipos de coluna.
ID de warehouse SQL	ID do warehouse usado para executar SQL
Nome do warehouse SQL	Nome do warehouse SQL usado para executar SQL; pesquisará em todos os warehouses SQL para encontrar o nome correspondente.
Instrução	Instrução SQL a ser executada

Relações¶

Nome	Descrição
failure	Relação de falha do Databricks
http.response	Resposta HTTP à solicitação da SQL API
original	O FlowFile original é encaminhado para essa relação quando o processamento é bem-sucedido.
records	Registros SQL serializados

Grava atributos¶

Nome	Descrição
statement.state	O estado final da instrução SQL executada
error.code	O código de erro para a instrução SQL se ocorrer um erro.
error.message	A mensagem de erro para a instrução SQL se ocorrer um erro.