apache beam batch processing:使用Apache Beam(Python)进行批处理的公共源代码在线课程 apache source

在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 conda or virtualenv conda create -n apache-beam-tutorial python=3.7 # activate your virtual environment conda activate apache-beam-tutorial 现在,使用pip安装B