PutBigQuery 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-gcp-nar
설명¶
FlowFile 의 내용을 Google BigQuery 테이블에 씁니다. 프로세서는 레코드 기반이므로 사용되는 스키마는 RecordReader 에 의해 구동됩니다. 대상 스키마와 일치하지 않는 특성은 건너뜁니다. 스트림 오프셋을 통해 정확히 한 번만 전송 의미 체계를 달성하면 됩니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
GCP 자격 증명 공급자 서비스 |
컨트롤러 서비스는 Google 클라우드 플랫폼 자격 증명을 얻는 데 사용됩니다. |
bigquery-api-endpoint |
기본 BigQuery 엔드포인트를 재정의하는 데 사용할 수 있습니다. 기본값은 bigquerystorage.googleapis.com:443입니다. 형식은 hostname:port여야 합니다. |
bq.append.record.count |
쓰기 스트림에 한 번에 추가할 레코드의 수입니다. 배치 및 스트림 유형 모두에 적용 가능 |
bq.dataset |
BigQuery 데이터 세트 이름(참고 - 데이터 세트는 GCP 에 있어야 함) |
bq.record.reader |
수신 데이터를 구문 분석하는 데 사용할 컨트롤러 서비스를 지정합니다. |
bq.skip.invalid.rows |
유효하지 않은 행이 있더라도 요청의 모든 유효한 행을 삽입할지 여부를 설정합니다. 설정하지 않으면 전체 삽입 요청에 유효하지 않은 행이 포함되어 있으면 실패합니다. |
bq.table.name |
BigQuery 테이블 이름 |
bq.transfer.type |
선호하는 전송 유형 스트림 또는 배치를 정의합니다 |
gcp-project-id |
Google Cloud Project ID |
gcp-retry-count |
실패 관계로 라우팅하기 전에 시도해야 하는 재시도 횟수입니다. |
프록시 구성 서비스 |
네트워크 요청을 프록시할 프록시 구성 컨트롤러 서비스를 지정합니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFiles 은 Google BigQuery 작업이 실패하면 이 관계로 라우팅됩니다. |
성공 |
FlowFiles 은 성공적인 Google BigQuery 작업 후 이 관계로 라우팅됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
bq.records.count |
성공적으로 삽입된 레코드 수 |