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 클라이언트 서비스. |
기본 카탈로그 |
기본 테이블 카탈로그,’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 문에 대한 오류 메시지입니다. |