我正在尝试使用新的Bigquery Storage API从Golang进行流式插入。根据this page,我了解到该API替换了旧的流式插入bigquery API。
然而,文档中示例都没有展示如何实际插入行。为了创建一个AppendRowsRequest,我得到了以下内容:
然而,文档中示例都没有展示如何实际插入行。为了创建一个AppendRowsRequest,我得到了以下内容:
&storagepb.AppendRowsRequest{
WriteStream: resp.Name,
Rows: &storagepb.AppendRowsRequest_ProtoRows{
ProtoRows: &storagepb.AppendRowsRequest_ProtoData{
WriterSchema: nil, // protobuf schema??
Rows: &storagepb.ProtoRows{
SerializedRows: [][]byte{}, // serialized protocol buffer data??
},
},
},
}
我应该将什么数据放入上面的SerializedRows字段中?
上面的storagepb.ProtoRows
结构在这里有文档记录。不幸的是,只给出了一个链接到协议缓冲区的主要概述页面。
有人能给我一个使用新的Bigquery存储API从Golang流式传输行到bigquery的示例吗?