时间戳

首页 > 解决方案 > Bigquery存储grpc写api

go - Bigquery存储grpc写api

问题描述

我的用例是从数据库中读取数据并将其写入 bigquery 表。为此，我正在尝试使用grpc api

并遵循此示例文件。考虑到自己是 protobuf 和 golang 的新手，我无法弄清楚如何将 DB 行写入 bigquery 表。对这部分特别困惑。无法找到在 protobuf 字节序列中创建请求并将其流式传输的任何特定示例。

任何帮助深表感谢。

标签： gogoogle-bigqueryprotocol-buffers

解决方案

Go 客户端提供了一个managedWriter，您可以使用它更轻松地流式传输数据。您可以看到它是如何在集成测试中使用的。

另外，如果你是 Go 新手，你会考虑改用 Java 吗？Java 中有一个可用的 JsonStreamWriter，它允许您附加 JSONArray 对象（而不是 protobuf 行），示例在这里：https ://github.com/googleapis/java-bigquerystorage/tree/main/samples/snippets/src /main/java/com/example/bigquerystorage

推荐阅读