PutBigQuery 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-gcp-nar
描述¶
将 FlowFile 的内容写入 Google BigQuery 表中。处理器以记录为基础，因此所使用的架构由 RecordReader 驱动。跳过与目标架构不匹配的属性。通过数据流偏移实现精确的一次传递语义。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
GCP 凭据提供商服务 |
用于获取 Google Cloud Platform 凭据的控制器服务。 |
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 项目 ID |
gcp-retry-count |
路由到“failure”关系之前应尝试重试多少次。 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果 Google BigQuery 操作失败，则将 FlowFiles 路由到此关系。 |
success |
Google BigQuery 操作成功后，将 FlowFiles 路由到此关系。 |
写入属性¶
名称 |
描述 |
|---|---|
bq.records.count |
成功插入的记录数 |