小编Jav*_*oda的帖子

Go 库的 BigQuery 行插入失败

当我尝试在 bigquery 中插入时,我收到此错误“X 行插入失败”,其中 X 是行数。

我在 Golang 中使用这个库“cloud.google.com/go/bigquery”

我在这里附上代码:

    u := table.Uploader()

    var inserts []*bigquery.StructSaver
    for _, insert := range value {
        aux := bigquery.StructSaver{Struct: insert, Schema: schema}
        inserts = append(inserts, &aux)
    }

    err := u.Put(ctx, inserts)
    if err != nil {
        fmt.Printf("%v\n", err)
    }
Run Code Online (Sandbox Code Playgroud)

这不会在每次尝试中发生,我不知道是什么可以产生它。有人遇到同样的错误吗?

go google-bigquery

5
推荐指数
1
解决办法
1864
查看次数

使用前缀键删除行范围

我正在使用数据包“ org.apache.hadoop.hbase.client”来管理Google的BigTable数据。

删除行的示例:

key = "PROV|CLI|800|20160714|8|30302.30301|ES";
byte[] byteKey = Bytes.toBytes(key);
Delete delete = new Delete(byteKey);
Run Code Online (Sandbox Code Playgroud)

这可以正常工作,但是我需要一种删除以键“ PROV | CLI | 800 |”开头的所有行的方法

反正有这样做吗?

java google-cloud-dataflow google-cloud-bigtable

2
推荐指数
1
解决办法
793
查看次数

Google Cloud Bigtable上的TTL

我有一个只有一个列族的表,这个列的TTL为24小时,但我需要在截止日期之前删除一些数据.

为了实现这个目标,我伪造了插入日期.例如:如果我需要在插入后1小时删除一行,我将插入日期设置为23小时前.这个机制运行正常,Bigtable在一小时后删除了我的数据,但我不知道这是否会在Bigtable的内部工作流程中产生错误.

我可以继续使用它还是有其他方法可以做到这一点?

google-cloud-bigtable

2
推荐指数
1
解决办法
1057
查看次数