PutDatabricksSQL 2025.5.31.15¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-databricks-processors-nar
描述¶
使用 Databricks REST API 提交一条 SQL 执行请求，并将返回的 JSON 响应写入 FlowFile 内容中。对于高性能的 SELECT 或 INSERT 查询，请使改为使用 ExecuteSQL 处理器。
输入要求¶
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
Databricks 客户端 |
Databricks 客户端服务。 |
Default 目录 |
默认表目录，某些 SQL 语句（如“COPY INTO”）不支持使用默认目录 |
默认架构 |
默认表架构，某些 SQL 语句（如“COPY INTO”）不支持使用默认架构 |
记录写入器 |
指定用于将结果写入到 FlowFile 的控制器服务。记录写入器可以使用 Inherit Schema 来模拟推断架构的行为，即无需在写入器中显式定义架构，架构将由同样用于根据列类型推断架构的逻辑提供。 |
SQL 仓库 ID |
用来执行 SQL 的仓库 ID |
SQL 仓库名称 |
用于执行 SQL 的 SQL Warehouse 名称，将在所有 SQL Warehouses 中搜索匹配的名称。 |
语句 |
要执行的 SQL 语句 |
关系¶
名称 |
描述 |
|---|---|
failure |
Databricks failure 关系 |
http.response |
SQL API 请求的 HTTP 响应 |
original |
处理成功后，原始 FlowFile 将路由到此关系。 |
records |
序列化的 SQL 记录 |
写入属性¶
名称 |
描述 |
|---|---|
statement.state |
已执行 SQL 语句的最终状态 |
error.code |
发生错误时 SQL 语句的错误代码。 |
error.message |
发生错误时 SQL 语句的错误消息。 |