PubSub到BigQuery -数据流/波束模板在Python中？

import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions, GoogleCloudOptions
from apache_beam.io.gcp.pubsub import ReadFromPubSub
from apache_beam.io.gcp.bigquery import WriteToBigQuery

# 定义Pipeline选项
options = PipelineOptions()
gcp_options = options.view_as(GoogleCloudOptions)
gcp_options.project = 'your-project-id'
gcp_options.region = 'your-region'
gcp_options.job_name = 'pubsub-to-bigquery'

# 定义Pipeline
with beam.Pipeline(options=options) as p:
    (p
     | 'Read from Pub/Sub' >> ReadFromPubSub(topic='projects/your-project-id/topics/your-topic')
     | 'Convert to JSON' >> beam.Map(lambda x: x.decode('utf-8'))
     | 'Write to BigQuery' >> WriteToBigQuery(
         table='your-project-id:your_dataset.your_table',
         schema='field1:STRING,field2:INTEGER',
         write_disposition=beam.io.BigQueryDisposition.WRITE_APPEND,
         create_disposition=beam.io.BigQueryDisposition.CREATE_IF_NEEDED
     )
    )