simple_pipeline.py

from __future__ import absolute_import

import logging

import apache_beam as beam
from apache_beam.utils.options import PipelineOptions
from apache_beam.utils.options import SetupOptions
from apache_beam.utils.options import StandardOptions


def run():
  options = PipelineOptions()
  options.view_as(SetupOptions).requirements_file = 'requirements.txt'
  options.view_as(StandardOptions).runner = 'DataflowPipelineRunner'
  p = beam.Pipeline(options=options)
  p | beam.Create(['foo', 'bar'])
  p.run()

if __name__ == '__main__':
  logging.getLogger().setLevel(logging.INFO)
  run()