Storage Write API (gRPC) 简介

您可以使用 BigQuery Storage Write API (gRPC) 将数据流式传输到 BigQuery 中。本文档介绍了 Storage Write API (gRPC) 的架构、功能和使用情形。

对于新项目，我们建议使用 Storage Write API (gRPC)，而不是 Storage Write API (REST)。Storage Write API (gRPC) 价格更低且功能更强大，包括“正好一次”传送语义。

所需权限

如需使用 Storage Write API (gRPC)，您必须具有 bigquery.tables.updateData 权限。

以下预定义的 Identity and Access Management (IAM) 角色包含 bigquery.tables.updateData 权限：

• bigquery.dataEditor
• bigquery.dataOwner
• bigquery.admin

如需详细了解 BigQuery 中的 IAM 角色和权限，请参阅预定义的角色和权限。

身份验证范围

使用 Storage Write API (gRPC) 需要以下 OAuth 范围之一：

• https://www.googleapis.com/auth/bigquery
• https://www.googleapis.com/auth/cloud-platform
• https://www.googleapis.com/auth/bigquery.insertdata

如需了解详情，请参阅身份验证概览。

Storage Write API (gRPC) 概览

Storage Write API (gRPC) 中的核心抽象为流。系统通过流将数据写入 BigQuery 表。多个流可以并发写入同一个表。

默认流

Storage Write API (gRPC) 提供默认流，适用于数据不断到达的流式场景。它具有以下特征：

• 写入默认流的数据可立即用于查询。
• 默认流支持“至少一次”语义。
• 您无需明确创建默认流。

如果您要从 Storage Write API (REST) 进行迁移，请考虑使用默认流。它可提供类似的写入语义，并且具备更高的数据弹性和更少的伸缩限制。

API 流：

1. AppendRows（循环）

如需了解详情和相关的示例代码，请参阅