Google Dataflow python中的API版本BigQuery

Question

有人可以告诉我当前与 Python 中的 Google Dataflow 一起使用的 BigQuery API 版本是否为 0.25？

当我安装 apache-beam 时使用：

pip install apache-beam[gcp]

我得到的版本是：0.25

但适用于 Python 的 BigQuery API 的最终版本是 1.7.x

这是为什么？

Answer 1

Apache Beam 仅将google-cloud-bigquery 用于testing 目的。与 BigQuery（或任何其他 GCP 工具）的连接使用基于 apitools 的专有 client，因为代码必须尽可能优先考虑性能。