如何在Python中为Google数据流管道设置编码器？

from apache_beam.coders.coders import Coder
from apache_beam.coders.coders import FastPrimitivesCoder

class MyEncoder(Coder):
    def encode(self, value):
        # 将数据编码为字节流
        encoded_value = ...  # 编码逻辑
        return encoded_value

    def decode(self, encoded_value):
        # 将字节流解码为数据
        decoded_value = ...  # 解码逻辑
        return decoded_value

import apache_beam as beam

# 创建数据流管道
pipeline = beam.Pipeline()

# 应用自定义编码器
custom_coder = MyEncoder()
data = pipeline | beam.Create([1, 2, 3], coder=custom_coder)

# 其他数据处理操作
...

# 运行数据流管道
result = pipeline.run()