如何在apache中使用ParDo和DoFn写入GCS

import apache_beam as beam
from apache_beam.io import WriteToText
from apache_beam.io.gcp.gcsfilesystem import GCSFileSystem

class MyDoFn(beam.DoFn):
    def process(self, element):
        # 处理数据的逻辑
        # 将处理后的数据写入GCS
        gcs_filesystem = GCSFileSystem()
        with gcs_filesystem.open('gs://your-bucket/your-file.txt', 'w') as f:
            f.write(element)

with beam.Pipeline() as p:
    data = p | beam.Create(['data1', 'data2', 'data3'])  # 替换为你的数据源
    data | beam.ParDo(MyDoFn())

    data | WriteToText('gs://your-bucket/your-output.txt')  # 替换为你的输出路径