PutDatabricksSQL 2025.5.31.15

번들

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

설명

Databricks REST API 를 사용하여 SQL 실행을 제출한 다음 JSON 응답을 FlowFile 내용에 작성합니다. 고성능 SELECT 또는 INSERT 쿼리의 경우 대신 ExecuteSQL 을 사용하십시오.

태그

databricks, openflow, sql

입력 요구 사항

민감한 동적 속성 지원

false

속성

속성

설명

Databricks 클라이언트

Databricks 클라이언트 서비스.

기본 카탈로그

기본 테이블 카탈로그,’COPY INTO’와 같은 일부 SQL 문은 기본 카탈로그 사용을 지원하지 않습니다

기본 스키마

기본 테이블 스키마, ‘COPY INTO’와 같은 일부 SQL 문은 기본 스키마 사용을 지원하지 않습니다

Record Writer

FlowFile 에 결과를 기록하는 데 사용할 컨트롤러 서비스를 지정합니다. Record Writer는 스키마 상속을 사용하여 추론된 스키마 동작을 에뮬레이션할 수 있습니다. 즉, 작성기에서 명시적 스키마를 정의할 필요가 없으며 열 유형에서 스키마를 추론하는 데 사용된 것과 동일한 로직이 제공될 것입니다.

SQL 웨어하우스 ID

SQL 실행에 사용되는 웨어하우스 ID

SQL 웨어하우스 이름

SQL 을 실행하는 데 사용되는 SQL 웨어하우스 이름은 모든 SQL 웨어하우스를 검색하여 일치하는 이름을 찾습니다.

실행할 SQL 문

관계

이름

설명

실패

Databricks 장애 관계

http.response

SQL API 요청에 대한 HTTP 응답

원본

처리가 성공하면 원본 FlowFile 은 이 관계로 라우팅됩니다.

레코드

직렬화된 SQL 레코드

Writes 특성

이름

설명

statement.state

실행된 SQL 문의 최종 상태

error.code

오류가 발생한 경우 SQL 문에 대한 오류 코드입니다.

error.message

오류가 발생한 경우 SQL 문에 대한 오류 메시지입니다.