用于分支管道的 Apache Beam python 代码

Question

我正在使用 Dataflow 加载 CSV 文件，其中需要将取决于第一列值的每条记录写入特定的 bigquery 表。

简单解释如下： 输入文件 -

1,X1,Y1
2,X2,Y2
3,X3,Y3

代码逻辑-

If col1 = 1 then write into table1
If col2 = 2 then write into table2
and so on so forth....

出于这个原因，我正在阅读 Apache Beam 文档https://beam.apache.org/documentation/pipelines/design-your-pipeline/ 但这显示了 JAVA 代码。我不懂 JAVA，想用 Python 写。任何人都可以分享 Python 代码的此类文档的链接吗？

Answer 1

Beam 编程指南包含 Java 和 Python SDK 的说明。 https://beam.apache.org/documentation/programming-guide/