PutBigQuery 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-gcp-nar
説明¶
FlowFile のコンテンツを Google BigQuery のテーブルに書き込みます。プロセッサーは記録ベースなので、使用されるスキーマは RecordReader によって動作します。ターゲットスキーマにマッチしない属性はスキップされます。ストリームオフセットにより、正確な1回配信のセマンティクスが達成されます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
GCP 認証情報 プロバイダーサービス |
Google Cloud Platform の認証情報の取得に使用する Controller Service。 |
bigquery-api-endpoint |
デフォルトの BigQuery エンドポイントを上書きするために使用できます。デフォルトは bigquerystorage.googleapis.com:443 です。形式はホスト名:ポートでなければなりません。 |
bq.append.record.count |
書き込みストリームに一度に追加する記録数。バッチタイプとストリームタイプの両方に適用可能 |
bq.dataset |
BigQuery データセット名 (注意 - データセットは GCP に存在する必要があります) |
bq.record.reader |
受信データの解析に使用するController Serviceを指定します。 |
bq.skip.invalid.rows |
無効な行が存在する場合でも、リクエストの有効な行をすべて挿入するかどうかをセットします。セットされていない場合、無効な行が含まれていると、挿入リクエスト全体が失敗します。 |
bq.table.name |
BigQuery テーブル名 |
bq.transfer.type |
優先する転送タイプ ストリーミングまたはバッチを定義します。 |
gcp-project-id |
Google Cloud Project ID |
gcp-retry-count |
障害関係にルーティングする前に、何回リトライを試みるか。 |
proxy-configuration-service |
ネットワークリクエストをプロキシするプロキシ構成Controller Serviceを指定します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
FlowFiles は、Google BigQuery の操作に失敗した場合、このリレーションシップにルーティングされます。 |
success |
FlowFiles は、Google BigQuery の操作が成功すると、このリレーションシップにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
bq.records.count |
挿入に成功した記録数 |