在python中的管道运行期间访问Apache光束度量值？

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

class MetricsCollector(beam.DoFn):
    def process(self, element):
        # 在这里可以访问和记录度量值
        yield element

def run():
    options = PipelineOptions()
    gcp_options = options.view_as(GoogleCloudOptions)
    gcp_options.project = 'your-project-id'
    gcp_options.region = 'your-region'
    gcp_options.job_name = 'your-job-name'
    gcp_options.staging_location = 'gs://your-bucket/staging'
    gcp_options.temp_location = 'gs://your-bucket/temp'

    with beam.Pipeline(options=options) as p:
        (p
         | 'Read' >> beam.io.ReadFromText('gs://your-bucket/input.txt')
         | 'Process' >> beam.ParDo(MetricsCollector())
         | 'Write' >> beam.io.WriteToText('gs://your-bucket/output.txt'))

if __name__ == '__main__':
    run()