BigQuery:使用NodeJS客户端库从Cloud Storage执行加载作业时,似乎不遵守useAvroLogicalTypes。
创始人
2024-12-13 03:00:16
0

要在使用Node.js客户端库从Cloud Storage执行加载作业时启用useAvroLogicalTypes,可以通过以下代码示例来实现:

首先,安装必需的依赖项。在命令行中运行以下命令:

npm install --save @google-cloud/bigquery avsc

接下来,使用以下代码示例执行加载作业:

const { BigQuery } = require('@google-cloud/bigquery');
const fs = require('fs');
const avro = require('avsc');

async function loadAvro() {
  // 客户端库初始化
  const bigquery = new BigQuery();

  // 读取Avro模式
  const schema = avro.Type.forSchema({
    type: 'record',
    name: 'MyRecord',
    fields: [
      { name: 'id', type: 'int' },
      { name: 'name', type: 'string' },
    ],
  });

  // 从Cloud Storage加载作业
  const metadata = {
    sourceFormat: 'AVRO',
    schema: {
      fields: schema.fields.map(field => ({
        name: field.name,
        type: field.type.typeName,
        mode: 'NULLABLE',
      })),
      useAvroLogicalTypes: true,
    },
  };

  const dataset = bigquery.dataset('my_dataset');
  const table = dataset.table('my_table');
  const [job] = await table.load('gs://my-bucket/my-file.avro', metadata);

  // 等待加载作业完成
  const [jobResult] = await job.getMetadata();

  // 检查加载作业是否成功
  if (jobResult.status.errors && jobResult.status.errors.length > 0) {
    console.error('加载作业出错:', jobResult.status.errors);
    return;
  }

  console.log('加载作业成功!');
}

loadAvro();

在上面的代码示例中,我们首先导入所需的依赖项,包括@google-cloud/bigqueryavsc。然后,我们使用avsc库定义了一个Avro数据模式,该模式包含一个id字段和一个name字段。

接下来,我们使用BigQuery类初始化了一个BigQuery客户端实例,并读取了Avro模式。然后,我们为加载作业指定了sourceFormatAVRO,并在metadata中将schema设置为useAvroLogicalTypestrue

然后,我们使用table.load()方法从Cloud Storage加载作业,并等待作业完成。最后,我们检查作业是否成功,并打印出相应的消息。

确保将my_datasetmy_table替换为您的目标数据集和表的名称,并将gs://my-bucket/my-file.avro替换为您的实际Avro文件的路径。

通过使用上述代码示例,您可以在使用Node.js客户端库从Cloud Storage执行加载作业时启用useAvroLogicalTypes选项。

相关内容

热门资讯

安卓换鸿蒙系统会卡吗,体验流畅... 最近手机圈可是热闹非凡呢!不少安卓用户都在议论纷纷,说鸿蒙系统要来啦!那么,安卓手机换上鸿蒙系统后,...
app安卓系统登录不了,解锁登... 最近是不是你也遇到了这样的烦恼:手机里那个心爱的APP,突然就登录不上了?别急,让我来帮你一步步排查...
安卓系统拦截短信在哪,安卓系统... 你是不是也遇到了这种情况:手机里突然冒出了很多垃圾短信,烦不胜烦?别急,今天就来教你怎么在安卓系统里...
安卓系统要维护多久,安卓系统维... 你有没有想过,你的安卓手机里那个陪伴你度过了无数日夜的安卓系统,它究竟要陪伴你多久呢?这个问题,估计...
windows官网系统多少钱 Windows官网系统价格一览:了解正版Windows的购买成本Windows 11官方价格解析微软...
安卓系统如何卸载app,轻松掌... 手机里的App越来越多,是不是感觉内存不够用了?别急,今天就来教你怎么轻松卸载安卓系统里的App,让...
怎么复制照片安卓系统,操作步骤... 亲爱的手机控们,是不是有时候想把自己的手机照片分享给朋友,或者备份到电脑上呢?别急,今天就来教你怎么...
安卓系统应用怎么重装,安卓应用... 手机里的安卓应用突然罢工了,是不是让你头疼不已?别急,今天就来手把手教你如何重装安卓系统应用,让你的...
iwatch怎么连接安卓系统,... 你有没有想过,那款时尚又实用的iWatch,竟然只能和iPhone好上好?别急,今天就来给你揭秘,怎...
iphone系统与安卓系统更新... 最近是不是你也遇到了这样的烦恼?手机更新系统总是失败,急得你团团转。别急,今天就来给你揭秘为什么iP...