当前位置: 首页 > 知识库问答 >
问题:

通过命令行将Avro数据加载到BigQuery?

连昊天
2023-03-14

我创建了一个avro配置单元表,并使用配置单元插入覆盖命令将数据从另一个表加载到avro表中。我可以在avro配置单元表中看到数据,但当我尝试将其加载到bigQuery表中时,会出现错误。表架构:-

CREATE TABLE `adityadb1.gold_hcth_prfl_datatype_acceptence`(  
  `prfl_id` bigint,     
  `crd_dtl` array< struct < cust_crd_id:bigint,crd_nbr:string,crd_typ_cde:string,crd_typ_cde_desc:string,crdhldr_nm:string,crd_exprn_dte:string,acct_nbr:string,cre_sys_cde:string,cre_sys_cde_desc:string,last_upd_sys_cde:string,last_upd_sys_cde_desc:string,cre_tmst:string,last_upd_tmst:string,str_nbr:int,lng_crd_nbr:string>>)        
STORED AS AVRO;

我收到的错误:-

Error encountered during job execution:
Error while reading data, error message: The Apache Avro library failed to read data with the follwing error: Cannot resolve:

我使用以下命令将数据加载到bigquery中:-

bq load --source_format=AVRO dataset.tableName avro-filePath

共有1个答案

翟缪文
2023-03-14

确保您指向的gs文件夹中有可用的数据,并且数据包含架构(如果您从Hive创建它,则应该如此)。这里有一个如何加载数据的示例

bq --location=US load --source_format=AVRO  --noreplace my_dataset.my_avro_table gs://myfolder/mytablefolder/part-m-00001.avro
 类似资料:
  • 在通过Maven运行时,我需要传递给Karate的附加设置可以在karate-config.js中获得。目前,我可以使用karate.env属性传入一个字符串--是否需要将参数编码为JSON对象并通过这个属性传入,或者我可以做如下操作: 我肯定我错过了一些明显的东西...

  • 问题内容: 我正在尝试将很大的.csv文件(〜4gb)导入mysql。我正在考虑使用phpmyadmin,但是您的最大上传大小为2mb。有人告诉我,我必须使用命令行。 我打算按照以下说明将其导入:http : //dev.mysql.com/doc/refman/5.0/en/mysqlimport.html#c5680 将.csv表中的第一行设置为mysql表中的列名的命令是什么?该选项可通过p

  • 一些注意事项: 1。我最初使用的TestNG jar来自java项目中的maven repo。下面的所有方法都是用maven testNG jar和新的TestNG6.9.12下载进行测试的。 2。我可以从Eclipse中运行这个文件。只有当我尝试从命令行运行时才有问题。 3。最终目标是通过javafx应用程序按钮触发命令行来运行测试。如果提供的解决方案避免在cmd中键入绝对路径,因为应用程序将在

  • 我想将参数传入这个文件。 以下命令对int和string参数有效,但对boolean无效。 如何传入布尔参数?我尝试将作为的参数,但这不起作用。

  • 加载命令load读出含有由早期MATLAB版本形成的矩阵的二进制文件,或者读出含有数值数据的文本文件。文本文件应该由一个数字的矩阵表格构成,由空格隔开,每一线排一行,而且每一行有相同数量的元素。例如,在MATLAB外部,创建一个含有这四行的文本文件。 16.0 3.0 2.0 13.0 5.0 10.0 11.0 8.0 9.0

  • 我正试图通过命令行重新部署战争。我正在尝试: java-classpath"C:/bea/weblogic12c/wlserver_12.1/server/lib/weblogic.jar"weblogic. Deployer-adminurl t3://localhost:7101-user用户名-密码-上传-重新部署-name myapp-source myApp.war-目标myServer