Node JS - Big Query 将请求对象完全插入到记录数据类型中

Question

我有从客户端获取的 Json。我需要将整个请求插入到一个大查询表中。

如何在不指定单个字段的情况下编写插入查询

下面是req对象

var reqBody = {
   "Name":"testing",
   "columns":[
      {
         "fieldExistsIn":"BOTH",
         "columnWidth":5,
         "hide":false
      },
      {
         "fieldExistsIn":"BOTH",
         "columnWidth":10,
         "hide":false
      }
   ],
   "Range":{
      "startDate":"20-Oct-2022",
      "endDate":"26-Oct-2022"
   }
}

我需要将它插入到如下所示的“requestData”字段中。但是下面的查询不起作用

"INSERT INTO table_name(requestData) VALUES(reqBody)"

1.BigQuery 表架构

reqData RECORD  NULLABLE    
  Name  STRING  NULLABLE    
  column    RECORD  REPEATED
      fieldExistsIn STRING  NULLABLE
      columnWidth   INTEGER NULLABLE    
      hide  BOOLEAN NULLABLE

2.样本输出表

"requestData": {
      "Name": "testing",
      "columns": [
        {
          "fieldExistsIn":"BOTH",
          "columnWidth": 10,
          "hide": false
        },
        {
          "fieldExistsIn":"BOTH",
          "columnWidth": 5,
          "hide": false
        }]
    }
   

3.你是如何插入 JSON 文件的

using nodejs application

Answer 1

根据您提供的表架构和示例数据，我尝试在我的一端复制它。

表架构：

使用INSERT查询插入json数据会报​​错。

insert into project.try.tab5 (reqData) values(var1) 

我在 var1 中存储了 json 数据的位置。

错误： 插入的行列数错误；有 1 个，预期 2 个

所以，如果要使用 Node.js 客户端，可以使用insertRowsAsStream 方法向表中插入行。

您可以参考下面的代码和相应的输出。

Sample.js：

const {BigQuery} = require('@google-cloud/bigquery');
const bigquery = new BigQuery();
async function insertRowsAsStream() {
   const datasetId = 'sandeep';
   const tableId = 'tab8';
  const rows = [

    {
        "reqData": {
          "Name": [
            "testing"
          ],
          "column": [
            {
              "fieldExistsIn": "BOTH",
              "columnWidth": "10",
              "hide": false
            },
            {
              "fieldExistsIn": "BOTH",
              "columnWidth": "5",
              "hide": false
            }
          ]
        }
      }

  ];
    
  await bigquery
    .dataset(datasetId)
    .table(tableId)
    .insert(rows);
  console.log(`Inserted ${rows.length} rows`);
}
insertRowsAsStream();

输出：