允许 Dataflow 读取指向云端硬盘的 BigQuery table？
Permissioning Dataflow to read a BigQuery table that is pointing to Drive?
BigQuery 可以从 Google 驱动器中读取作为联合源。参见 here。我希望能够将 BigQuery 中的 table 读取到指向云端硬盘文档的数据流管道中。
将 BigQuery 连接到云端硬盘中的文件工作得很好：
但是，当我随后尝试将 table 读入我的数据流管道时，我（可以理解）收到以下错误：
No suitable credentials found to access Google Drive. Contact the
table owner for assistance.
[..]
PCollection<TableRow> results = pipeline.apply("whatever",
BigQueryIO.Read.fromQuery("SELECT * from [CPT_7414_PLAYGROUND.google_drive_test]"))
.apply(ParDo.of(new DoFn<TableRow, TableRow>() {
[..]
如何允许 Dataflow 能够读取 BigQuery 中指向云端硬盘的 table？
Dataflow 目前不支持从云端硬盘支持的联合 table 中读取数据，但即将推出。
BigQuery 可以从 Google 驱动器中读取作为联合源。参见 here。我希望能够将 BigQuery 中的 table 读取到指向云端硬盘文档的数据流管道中。
将 BigQuery 连接到云端硬盘中的文件工作得很好：
但是，当我随后尝试将 table 读入我的数据流管道时，我（可以理解）收到以下错误：
No suitable credentials found to access Google Drive. Contact the table owner for assistance.
[..]
PCollection<TableRow> results = pipeline.apply("whatever",
BigQueryIO.Read.fromQuery("SELECT * from [CPT_7414_PLAYGROUND.google_drive_test]"))
.apply(ParDo.of(new DoFn<TableRow, TableRow>() {
[..]
如何允许 Dataflow 能够读取 BigQuery 中指向云端硬盘的 table？
Dataflow 目前不支持从云端硬盘支持的联合 table 中读取数据，但即将推出。