使用 insertAll 时丢失行 - BigQuery

Posted 2023-04-14

【中文标题】使用 insertAll 时丢失行 - BigQuery

【英文标题】：Getting missing row while using insertAll - BigQuery

【发布时间】：2016-05-03 11:00:14

【问题描述】：

在将数据插入 BigQuery 时，我在响应中出现无效原因的缺失行。

"errors":["message":"Missing row.","re​​ason":"invalid"],"index":0, "errors":["message":"Missing行。","原因":"无效"]

下面是我正在执行的代码：

/以下行调用dfp API来获取所有adunits AdUnitPage page = inventoryService.getAdUnitsByStatement(statementBuilder.toStatement()); 列表 dfpadunits = new ArrayList();

                if (page.getResults() != null) 
                    totalResultSetSize = page.getTotalResultSetSize();
                    int i = page.getStartIndex();
                    for (AdUnit adUnit : page.getResults()) 
                        /*System.out.printf(
                                "%d) Ad unit with ID '%s' and name '%s' was found.%n", i++,
                                adUnit.getId(), adUnit.getName());*/

                        //Map<String,Object> dfpadunitrow = new HashMap<String,Object>();
                        //dfpadunitrow.put(adUnit.getId(), adUnit.getName());
                        Rows dfpadunit = new TableDataInsertAllRequest.Rows();
                        dfpadunit.setInsertId(adUnit.getId());
                        dfpadunit.set("id",adUnit.getId());
                        dfpadunit.set("name",adUnit.getName());
                        dfpadunits.add(dfpadunit);

                    
                

                TableDataInsertAllRequest content = new TableDataInsertAllRequest();
                content.setRows(dfpadunits);
                content.setSkipInvalidRows(true);
                content.setIgnoreUnknownValues(true);
                System.out.println(dfpadunits.get(0));
                Bigquery.Tabledata.InsertAll request = bigqueryService.tabledata().insertAll(projectId, datasetId, tableId, content);
                TableDataInsertAllResponse response = request.execute();
                System.out.println(response.getInsertErrors());

我使用记录器来检查我的数据是否正确填充，但是当我尝试使用 insertAll 将记录插入到 bigquery 中时，我得到了响应无效的行。

谢谢， 卡皮尔

【问题讨论】：

我的回答对你有用吗？

【参考方案1】：

您需要使用TableRow 对象。这有效（我测试过）：

TableDataInsertAllRequest.Rows dfpadunit = new TableDataInsertAllRequest.Rows();

TableRow row = new TableRow();
row.set("id",adUnit.getId());
row.set("name",adUnit.getName());

dfpadunit.setInsertId(adUnit.getId());
dfpadunit.setJson(row);

dfpadunits.add(dfpadunit);