在Python中使用Apache Beam进行批处理 该存储库包含在线微型课程进行的源代码。 在本课程中，我们使用Python中的Apache Beam来构建以下批处理数据处理管道。 订阅以参加本课程。 设置您的本地环境 在安装Apache Beam之前，请创建并激活虚拟环境。 Beam Python SDK支持Python 2.7、3.5、3.6和3.7。 我建议您使用Python 3+创建一个虚拟环境。 # create a virtual environment using co