apache_beam (python SDK)是否支持.zip压缩类型

import apache_beam as beam
import zipfile

def process_zip_file(zip_file_path):
    with zipfile.ZipFile(zip_file_path, 'r') as zip_file:
        for file_name in zip_file.namelist():
            with zip_file.open(file_name) as file:
                # 在这里对文件进行处理
                # 例如，可以读取文件内容并进行相应的操作
                pass

# 创建一个Pipeline对象
pipeline = beam.Pipeline()

# 从.zip文件中读取数据
zip_file_path = 'path/to/your/zip/file.zip'
data = pipeline | 'Read from zip' >> beam.Create([zip_file_path])

# 处理.zip文件中的数据
processed_data = data | 'Process zip file' >> beam.Map(process_zip_file)

# 运行Pipeline
result = pipeline.run()
result.wait_until_finish()