如何在apache beam中使用python SDK从BIG QUERY读取数据到PCollection时将源列重命名

Question

如何在apache beam中使用python SDK从BIG QUERY读取数据到PCollection时将源列重命名为目标列名称

Answer 1

这可以通过Beam DataFrames API实现，更具体地说是DataframeTransform。与标准的熊猫还是有区别的，一定要注意它们。

如果你还需要具体例子的帮助，请告诉我。