Pipeline 的 with 语句运行管道.具体:

The with statement for Pipeline runs the pipeline. Specifically:

with beam.Pipeline(...) as p:
  [...code...]

相当于:

p = beam.Pipeline(...)
[...code...]
p.run().wait_until_finish()

参见实现.