PutDatabricksSQL

Databricks REST API를 사용해 SQL 문을 제출하고, JSON 응답을 FlowFile 콘텐츠로 작성하는 프로세서예요.

출처: Snowflake 문서 — PutDatabricksSQL

본문

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

Databricks REST API를 사용해 SQL 문을 제출한 다음 JSON 응답을 FlowFile 콘텐츠로 작성해요. 고성능 SELECT 또는 INSERT 쿼리에는 대신 ExecuteSQL을 사용하세요.

선택 (OPTIONAL) — 입력 FlowFile이 선택적이에요.

false — 지원하지 않아요.

속성	설명
Databricks Client	Databricks Client Service예요.
Default Catalog	기본 테이블 카탈로그예요. 'COPY INTO' 같은 일부 SQL 문은 기본 카탈로그 사용을 지원하지 않아요.
Default Schema	기본 테이블 스키마예요. 'COPY INTO' 같은 일부 SQL 문은 기본 스키마 사용을 지원하지 않아요.
Record Writer	결과를 FlowFile로 작성하는 데 사용할 Controller Service를 지정해요. Record Writer는 Inherit Schema를 사용해 추론된 스키마 동작을 모방할 수 있어요. 즉 명시적 스키마를 라이터에 정의할 필요가 없고, 열 유형에서 스키마를 추론하는 데 사용되는 것과 같은 로직으로 제공돼요.
SQL Warehouse ID	SQL 실행에 사용되는 Warehouse ID예요.
SQL Warehouse Name	SQL 실행에 사용되는 SQL Warehouse 이름이에요. 일치하는 이름을 찾기 위해 모든 SQL Warehouses를 검색해요.
Statement	실행할 SQL 문이에요.

이름	설명
`failure`	Databricks 실패 관계예요.
`http.response`	SQL API 요청에 대한 HTTP 응답이에요.
`original`	처리가 성공하면 원본 FlowFile이 이 관계로 라우팅돼요.
`records`	직렬화된 SQL 레코드예요.