我正在尝试从GC读取一个csv文件，但是read方法正在生成一个'typeError'，下面是我正在使用的代码片段：from apache_beam.dataframe.convertimport to_dataframe
print(row)
浏览 6提问于2022-09-09得票数 0
在GCP BigQuery中，可以创建表的视图。文档在这里：https://cloud.google.com/bigquery/docs/views。我想知道是否有可能通过Apache光束在BigQuery中创建一个视图，如果可以，它不在文档https://beam.apache.org/documentation/io/built-in/go
浏览 9提问于2021-08-20得票数 0
1回答
<init>(Bigquery.java:3498) at org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.access;
import org.apac
浏览 2提问于2018-07-06得票数 0
/runners/common.py", line 1233, in apache_beam.runners.common.DoFnRunner.process File "apache_beam/runners/common.py", line 1395, in apache_<em
浏览 38提问于2021-09-13得票数 0
回答已采纳
我在Google Dataflow中运行了一个Apache beam流水线。它从Kafka中读取数据并将其流式插入到Bigquery。(BigQueryServicesImpl.java:1255)at org.apache.beam.sdk.io.
浏览 7提问于2021-06-01得票数 5
java.util.concurrent.FutureTask.awaitDone(FutureTask.java:429) at org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.insertAll(BigQueryServicesImpl.java:765)
at org.apache.<
浏览 11提问于2019-03-16得票数 0
1回答
当我尝试使用Apache编写BigQuery时，我得到了： "github.com/apache/beam/sdks/go/pkg/beam/io/bigqueryio"
"github.com/<
浏览 5提问于2021-07-20得票数 1
从数据流sdk中的流管道获取BigQuery.IO.Write上的以下错误
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.insertAll(BigQueryServicesImpl.java:759) org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.inser
浏览 1提问于2018-01-10得票数 0
回答已采纳
我还可以使用beam.Create和beam.ParDo正确地运行自定义管道。python脚本如下。import apache_beam as beamfrom apache_beam.io)
File
浏览 0提问于2017-03-12得票数 0
1回答
这是代码from datetime import datetimefromapache_beam.options.pipeline_options import PipelineOptions以及UT的尝试
import <em
浏览 5提问于2020-01-02得票数 2
;import org.apache.beam.sdk.coders.Coder;import org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations;
import org.
浏览 0提问于2018-04-17得票数 0
回答已采纳
我试图使用JDBC到BigQuery Dataflow 将数据从Postgres数据库复制到BigQuery。at org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers$PendingJob.runJob ( org/apache.beam.sdk.io.gcp.bigquery/BigQueryHelpers.java:200 )
at org.apache.<e
浏览 11提问于2022-11-19得票数 2
回答已采纳
File "/usr/local/lib/python3.8/site-packages/apache_beam/io/gcp/bigquery.py", line 1288, in finish_bundle_flush_all_batches()
File "/usr/local/lib/python3.8/site-packages/apache
浏览 20提问于2021-02-23得票数 0
回答已采纳
1回答
我正在开发一个数据流管道，它正在从谷歌云存储读取协议的文件，并解析它，并试图写入到BigQuery表。当不是时，它工作得很好。行的大小约为20k，但如果不是。行数约为200k，则失败。org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers$PendingJob.runJob(BigQueryHelpers.java:199)
org.apache.beam.sdk.io.gcp.bigquery.BigQueryH
浏览 21提问于2021-10-28得票数 0
任务：我们必须设置从扳手到大查询的记录的定期同步。我们的扳手数据库有一个关系表层次结构。
浏览 4提问于2019-05-28得票数 1
回答已采纳
我希望通过在Apache中使用FileIO和writeDynamic() (使用Java)将键、值对写入GCS中的文本文件。
浏览 2提问于2019-11-06得票数 0
回答已采纳
1回答
(BigQueryServicesImpl.java:1262) at org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$<init> (BigQueryServicesImpl.java:52
浏览 44提问于2021-11-17得票数 0
lib/python3.6/site-packages/apache_beam/io/gcp/bigquery.py", line 1024, in process File"/usr/local/lib/python3.6/site-packages/apache_beam/io/gcp/bigque
浏览 29提问于2020-02-25得票数 3
2回答
java.util.concurrent.FutureTask.awaitDone(FutureTask.java:429) at java.util.concurrent.FutureTask.get(FutureTask.java:191) at org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.insertAll(BigQueryServicesImpl.java:765) at org.apache.bea
浏览 4提问于2019-02-16得票数 4
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号