这是一个有关使用Apache Beam的Python SDK和GCP DataFlow Runner创建管道的存储库； 这也是我在准备GCP数据工程师考试时使用的GCP提供的服务的一些简短说明。 笔记：- Apache Beam是用于创建批处理和流传输管道的统一框架。 GCP的数据流实现了Beam框架，该框架提供了用于创建批处理和流管道的统一方法。 管道驱动程序：创建管道的程序。 它定义了构成管道的输入，转换和输出。 管道在运行程序上运行：runitme引擎，它执行诸如DataFlow