如何在Python中使用apache beam Pipeline处理异常？

import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions

class MyDoFn(beam.DoFn):
    def process(self, element):
        try:
            # 处理输入元素并产生输出
            output = do_something(element)
            yield output
        except Exception as e:
            # 处理异常
            logging.error('An error occurred: %s', str(e))

def run_pipeline(input_data):
    pipeline_options = PipelineOptions(['--runner=DirectRunner'])

    with beam.Pipeline(options=pipeline_options) as pipeline:
        (
            pipeline
            | 'ReadInput' >> beam.Create(input_data)
            | 'Process' >> beam.ParDo(MyDoFn())
            | 'WriteOutput' >> beam.io.WriteToText('output.txt')
        )