首页 > 解决方案 > `WriteToBigQuery` 和 `BigQuerySink` 之间有什么区别

问题描述

按照这个答案,我想知道Apache Beam Python SDK之间的主要区别(如果有的话)是什么WriteToBigQueryBigQuerySink

使用一个比另一个有什么考虑或限制?

标签: google-bigqueryapache-beamapache-beam-io

解决方案


查看来源

BigQuerySink 触发 BigQuery 的 Dataflow 本机接收器,该接收器仅支持批处理管道。请使用适用于批处理和流式管道的 WriteToBigQuery 转换,而不是直接使用此接收器。

否则,他们似乎都在做类似 的事情。


推荐阅读