我正在尝试从Scala应用程序将数据流式传输到BQ。查看Streaming Data Into BigQuery列出的示例,我发现数据需要使用Map<String, Object>作为TableDataInsertAllRequest.Rows().setJson()传递。

  • 这是传递数据的唯一方法吗?
  • 假设这表示将由BQ连接器库作为JSON流式传输的数据,是否有可能以JSON化的字符串格式而不是Map<String, Object>传递数据?如果没有,原因何在?
  • 最佳答案

    不幸的是,通过我们(或任何Google Cloud Platform)API生成的库不支持直接写出请求正文。这很可能有助于确保请求的有效性。就是说,客户端库方面正在积极开展工作,而助手方法似乎是一个合理的要求。出于上述验证目的,开销可能仍然会存在(与客户端表示形式相对应),但是对于您的方案,客户端接口会稍微简单一些。

    我会转达您的要求。同时,此问题的答案提到了一个似乎可以简化翻译工作的库:

    Convert Json to Map

    10-06 13:11
    查看更多