После этого ответа Интересно, каковы принципиальные различия (если таковые имеются) между WriteToBigQuery и BigQuerySink Apache Beam Python SDK.
WriteToBigQuery
BigQuerySink
Каковы соображения или ограниченияиспользования одного над другим?
Просмотр источников :
BigQuerySink запускает собственный приемник потока данных для BigQuery, который поддерживает только пакетные конвейеры.Вместо того чтобы использовать этот приемник напрямую, используйте преобразование WriteToBigQuery, которое работает как для пакетного, так и для потокового конвейеров.
Кажется, что оба они делают похожую вещь под нейв противном случае.