python - 在Python中使用Google数据流从Bigquery到Bigtable数据传输

标签 python google-bigquery google-cloud-dataflow dataflow bigtable

我们使用 JAVA 编写的数据流管道将数据从 bigquery 传输到 bigtable。 例如https://github.com/GoogleCloudPlatform/cloud-bigtable-examples/blob/master/java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/BigQueryBigtableTransfer.java

我正在尝试用 python 编写相同的代码。但我无法获得 python 的 bigtable 数据流连接器。知道如何做到这一点吗?

最佳答案

只是不要让这个问题得不到解答,正如 Graham Polley 评论的那样: "The Python SDK doesn't have support for Bigtable yet." 。我看到 Bigtable 的工程师已经参与其中,但如果您愿意,您也可以在 Public Issue Tracker 中创建功能请求。

关于python - 在Python中使用Google数据流从Bigquery到Bigtable数据传输,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49770632/

相关文章:

python - 如果该 RGB 值属于列表,如何替换图像中的所有 RGB 值

python - 从文件导入对象而不运行该文件的导入

google-bigquery - Google BigQuery 似乎在太平洋时区而不是 UTC 运行。这有什么好的理由吗?有没有办法改变它?

google-bigquery - totalBytesBilled与totalBytesProcessed不同

python - 使用 Apache Beam 以 CSV 格式将 BigQuery 结果写入 GCS

google-cloud-dataflow - Python SDK中等效的Apache Beam : DoFn.安装程序

python - 以编程方式生成 if elif elif elif else

python - ParserError : Error tokenizing data. C 错误 : Expected 7 fields in line 4, 在读取 csv 文件 pandas 时看到 10 个错误

sql - 如何按同一查询中生成的列进行过滤?

java - TextIO.将 GCS 文件夹读入管道,以过去 30 天的日期作为名称