无法使用beam管道将数据写入内部SQL server

import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
from apache_beam.io.gcp.bigquery import WriteToBigQuery

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

    def process(self, element):
        # 这里添加连接数据库并写入数据的逻辑
        pass

def run():
    options = PipelineOptions()
    p = beam.Pipeline(options=options)

    data = p | 'Create' >> beam.Create([('row1', 1), ('row2', 2)])

    data | 'WriteToSQLServer' >> beam.ParDo(WriteToSQLServer('jdbc:sqlserver://yourserver;databaseName=yourdb', 'yourtable'))

    result = p.run()
    result.wait_until_finish()

if __name__ == '__main__':
    run()

class ConvertToSQLFormat(beam.DoFn):
    def process(self, element):
        # 这里添加数据转换逻辑
        yield (element[0], int(element[1]))