如何使用Apache Beam中的运行时值提供程序写入Big Query？

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

options = PipelineOptions()
google_cloud_options = options.view_as(GoogleCloudOptions)
google_cloud_options.project = 'your-project-id'
google_cloud_options.job_name = 'your-job-name'
google_cloud_options.staging_location = 'gs://your-bucket/staging'
google_cloud_options.temp_location = 'gs://your-bucket/temp'
options.view_as(StandardOptions).runner = 'DataflowRunner'

class RuntimeValueProvider(beam.DoFn):
    def __init__(self, value_provider):
        self.value_provider = value_provider

    def process(self, element):
        runtime_value = self.value_provider.get()
        yield runtime_value

class WriteToBigQuery(beam.DoFn):
    def __init__(self, table_name):
        self.table_name = table_name

    def process(self, element):
        # 将element写入Big Query的代码逻辑
        yield None

with beam.Pipeline(options=options) as p:
    runtime_value = p | 'Get Runtime Value' >> beam.ParDo(RuntimeValueProvider('your-runtime-value'))
    data = ...
    data | 'Write to Big Query' >> beam.ParDo(WriteToBigQuery('your-table-name'))